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 from the earliest offset for all partitions.
		 *
		 * @see FlinkKafkaConsumerBase#setStartFromEarliest()
		 */
Configures the TableSource to start reading from the earliest offset for all partitions.
Configures the TableSource to start reading from the earliest offset for all partitions .
public B fromEarliest() {
			this.startupMode = StartupMode.EARLIEST;
			this.specificStartupOffsets = null;
			return builder();
		}
public B fromEarliest ( ) { this . startupMode = StartupMode . EARLIEST ; this . specificStartupOffsets = null ; return builder ( ) ; }
Configures the TableSource to start reading from the earliest offset for all partitions.
Configures the TableSource to start reading from the earliest offset for all partitions .