public class Connector extends TableDescriptorinterface LikeOption {

	privateenum finalINCLUDING Map<String,implements String> options = new HashMap<>();

	public Connector(String identifier) {
		this.options.put(CONNECTOR.key(), identifier);
	}

	public Connector option(String key, String value) {
		options.put(key, value);
		return this;LikeOption {
		ALL,
		CONSTRAINTS,
		GENERATED,
		OPTIONS,
		PARTITIONS,
		WATERMARKS
	}

	protectedenum Map<String,EXCLUDING String>implements toConnectorOptions()LikeOption {
		return new HashMap<>(options);
	}
}

ALL,
		CONSTRAINTS,
		GENERATED,
		OPTIONS,
		PARTITIONS,
		WATERMARKS
	}

	enum OVERWRITING implements LikeOption {
		GENERATED,
		OPTIONS,
		WATERMARKS
	}
}

public class KafkaConnector extends TableDescriptor {

	private final Map<String, String> options = new HashMap<>();

	public KafkaConnector(String identifier) {
		this.options.put(CONNECTOR.key(), "kafka")identifier);
	}

	public KafkaConnector versionoption(String key, String versionvalue) {
		this.options.put(CONNECTOR.key(), "kafka-" + versionvalue);
		return this;
	}

	public Kafka topic(String topicprotected Map<String, String> toConnectorOptions() {
		this.options.put("topic", topicreturn new HashMap<>(options);
		return this;}
}

public class Kafka extends TableDescriptor {

	private final Map<String, String> options = new HashMap<>();

	public Kafka(	}

	public Kafka format(FormatDescriptor formatDescriptor) {
		this.options.putAllput(formatDescriptorCONNECTOR.toFormatOptionskey());
		return this, "kafka");
	}

	public Kafka  ...
}

/**
 * Describes a schema of a table.
 */
@PublicEvolving
public class Schema {

	/**
	 * Adds a column with the column name and the data type

/**
 * Describes a schema of a table.
 */
@PublicEvolving
public class Schema {

	/**
	 * Adds a column with the column name and the data type.
	 */
	public Schema column(String columnName, DataType columnType) {...}

	/**
	 * Adds a computed column with the column name and the SQL expression string.
	 */
	public Schema column(String columnName, StringDataType sqlExpressioncolumnType) {...}

	/**
	 * Adds a processing-timecomputed column with the givencolumn name and the column nameExpression.
	 */
	public Schema proctimecolumn(String columnName, Expression columnExpr) {...}


	/**
	 * Specifies the primary key constraint for a set of given columns.
	 */
	public Schema primaryKey(String... columnNames) {...}

	/**
	 * Specifies the watermark strategy for rowtime attribute.
	 */
	public SchemaWithWatermark watermarkFor(String rowtimeColumn, Expression watermarkExpr) {...}

	public static class SchemaWithWatermark {

		/**
		 * Specifies a custom watermark strategy using the given SQL expression string.
		 */
        public Schema as(String watermarkSqlExpr) {...}

		/**
		 * Specifies a watermark strategy for situations with monotonously ascending timestamps.
		 */
		public Schema ascendingTimestamps() {...}

		/**
		 * Specifies a watermark strategy for situations where records are out of order, but you can place
		 * an upper bound on how far the events are out of order. An out-of-order bound B means that
		 * once the an event with timestamp T was encountered, no events older than {@code T - B} will
		 * follow any more.
		 */
		public Schema boundedOutOfOrderTimestamps(Duration maxOutOfOrderness) {...}
	}
}}