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