flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/Kafka09JsonTableSource.java
/**
		 * Builds and configures a {@link Kafka09JsonTableSource}.
		 *
		 * @return A configured {@link Kafka09JsonTableSource}.
		 */
Builds and configures a  Kafka09JsonTableSource.
@return A configured  Kafka09JsonTableSource.
Builds and configures a Kafka09JsonTableSource . @return A configured Kafka09JsonTableSource .
@Override
		public Kafka09JsonTableSource build() {
			Kafka09JsonTableSource tableSource = new Kafka09JsonTableSource(
				getTopic(),
				getKafkaProps(),
				getTableSchema(),
				getJsonSchema());
			super.configureTableSource(tableSource);
			return tableSource;
		}
@ Override public Kafka09JsonTableSource build ( ) { Kafka09JsonTableSource tableSource = new Kafka09JsonTableSource ( getTopic ( ) , getKafkaProps ( ) , getTableSchema ( ) , getJsonSchema ( ) ) ; super . configureTableSource ( tableSource ) ; return tableSource ; }
Builds and configures a {@link Kafka09JsonTableSource}.
Builds and configures a { @link Kafka09JsonTableSource } .