flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
/**
		 * Configures a TableSource with optional parameters.
		 *
		 * @param tableSource The TableSource to configure.
		 */
Configures a TableSource with optional parameters.
@param tableSource The TableSource to configure.
Configures a TableSource with optional parameters . @param tableSource The TableSource to configure .
protected void configureTableSource(T tableSource) {
			tableSource.setProctimeAttribute(proctimeAttribute);
			if (rowtimeAttributeDescriptor == null) {
				tableSource.setRowtimeAttributeDescriptors(Collections.emptyList());
			} else {
				tableSource.setRowtimeAttributeDescriptors(Collections.singletonList(rowtimeAttributeDescriptor));
			}
			tableSource.setStartupMode(startupMode);
			switch (startupMode) {
				case EARLIEST:
				case LATEST:
				case GROUP_OFFSETS:
					break;
				case SPECIFIC_OFFSETS:
					tableSource.setSpecificStartupOffsets(specificStartupOffsets);
					break;
			}
		}
protected void configureTableSource ( T tableSource ) { tableSource . setProctimeAttribute ( proctimeAttribute ) ; if ( rowtimeAttributeDescriptor == null ) { tableSource . setRowtimeAttributeDescriptors ( Collections . emptyList ( ) ) ; } else { tableSource . setRowtimeAttributeDescriptors ( Collections . singletonList ( rowtimeAttributeDescriptor ) ) ; } tableSource . setStartupMode ( startupMode ) ; switch ( startupMode ) { case EARLIEST : case LATEST : case GROUP_OFFSETS : break ; case SPECIFIC_OFFSETS : tableSource . setSpecificStartupOffsets ( specificStartupOffsets ) ; break ; } }
Configures a TableSource with optional parameters.
Configures a TableSource with optional parameters .
// configure processing time attributes // configure rowtime attributes