flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSource.java
/**
		 * Sets the schema of the produced table.
		 *
		 * @param schema The schema of the produced table.
		 * @return The builder.
		 */
Sets the schema of the produced table.
@param schema The schema of the produced table.
@return The builder.
Sets the schema of the produced table . @param schema The schema of the produced table . @return The builder .
public B withSchema(TableSchema schema) {
			Preconditions.checkNotNull(schema, "Schema must not be null.");
			Preconditions.checkArgument(this.schema == null, "Schema has already been set.");
			this.schema = schema;
			return builder();
		}
public B withSchema ( TableSchema schema ) { Preconditions . checkNotNull ( schema , "Schema must not be null." ) ; Preconditions . checkArgument ( this . schema == null , "Schema has already been set." ) ; this . schema = schema ; return builder ( ) ; }
Sets the schema of the produced table.
Sets the schema of the produced table .