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 the TableSource to start reading partitions from specific offsets, set independently for each partition.
		 *
		 * @param specificStartupOffsets the specified offsets for partitions
		 * @see FlinkKafkaConsumerBase#setStartFromSpecificOffsets(Map)
		 */
Configures the TableSource to start reading partitions from specific offsets, set independently for each partition.
Configures the TableSource to start reading partitions from specific offsets set independently for each partition .
public B fromSpecificOffsets(Map<KafkaTopicPartition, Long> specificStartupOffsets) {
			this.startupMode = StartupMode.SPECIFIC_OFFSETS;
			this.specificStartupOffsets = Preconditions.checkNotNull(specificStartupOffsets);
			return builder();
		}
public B fromSpecificOffsets ( Map < KafkaTopicPartition , Long > specificStartupOffsets ) { this . startupMode = StartupMode . SPECIFIC_OFFSETS ; this . specificStartupOffsets = Preconditions . checkNotNull ( specificStartupOffsets ) ; return builder ( ) ; }
Configures the TableSource to start reading partitions from specific offsets, set independently for each partition.
Configures the TableSource to start reading partitions from specific offsets set independently for each partition .