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 field of the table to be a processing time attribute.
		 * The configured field must be present in the tabel schema and of type {@link Types#SQL_TIMESTAMP()}.
		 *
		 * @param proctimeAttribute The name of the processing time attribute in the table schema.
		 * @return The builder.
		 */
Configures a field of the table to be a processing time attribute.
The configured field must be present in the tabel schema and of type  Types#SQL_TIMESTAMP().

@param proctimeAttribute The name of the processing time attribute in the table schema.
@return The builder.
Configures a field of the table to be a processing time attribute . The configured field must be present in the tabel schema and of type Types#SQL_TIMESTAMP () . @param proctimeAttribute The name of the processing time attribute in the table schema . @return The builder .
public B withProctimeAttribute(String proctimeAttribute) {
			Preconditions.checkNotNull(proctimeAttribute, "Proctime attribute must not be null.");
			Preconditions.checkArgument(!proctimeAttribute.isEmpty(), "Proctime attribute must not be empty.");
			Preconditions.checkArgument(this.proctimeAttribute == null, "Proctime attribute has already been set.");
			this.proctimeAttribute = proctimeAttribute;
			return builder();
		}
public B withProctimeAttribute ( String proctimeAttribute ) { Preconditions . checkNotNull ( proctimeAttribute , "Proctime attribute must not be null." ) ; Preconditions . checkArgument ( ! proctimeAttribute . isEmpty ( ) , "Proctime attribute must not be empty." ) ; Preconditions . checkArgument ( this . proctimeAttribute == null , "Proctime attribute has already been set." ) ; this . proctimeAttribute = proctimeAttribute ; return builder ( ) ; }
Configures a field of the table to be a processing time attribute.
Configures a field of the table to be a processing time attribute .