Uses of Class
org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder

Packages that use EventTableDescriptorBuilder

Package	Description
org.wikimedia.eventutilities.flink.table

Uses of EventTableDescriptorBuilder in org.wikimedia.eventutilities.flink.table

Methods in org.wikimedia.eventutilities.flink.table that return EventTableDescriptorBuilder

Modifier and Type	Method and Description
EventTableDescriptorBuilder	EventTableDescriptorBuilder.clear() Clears all collected configs and options from this EventTableDescriptorBuilder so that it can be used to build another TableDescriptor.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.connector(String connectorIdentifier) Sets the connector.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.eventStream(EventStream eventStream) Sets the EventStream that will be used to build the TableDescriptor.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.eventStream(String streamName) Sets the EventStream by streamName that will be used to build the TableDescriptor.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.format(String format) Sets the format for the TableDescriptor.Builder.
static EventTableDescriptorBuilder	EventTableDescriptorBuilder.from(List<String> eventSchemaBaseUris, String eventStreamConfigUri) EventTableDescriptorBuilder factory method.
static EventTableDescriptorBuilder	EventTableDescriptorBuilder.from(List<String> eventSchemaBaseUris, String eventStreamConfigUri, Map<String,String> httpClientRoutes) EventTableDescriptorBuilder factory method.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.option(String key, String value) Sets a single TableDescriptor.Builder option.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.options(Map<String,String> options) Sets the TableDescriptor.Builder options.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.partitionedBy(String... partitionKeys) Sets the partitionKeys for the TableDescriptor.Builder.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.schemaBuilder(org.apache.flink.table.api.Schema.Builder schemaBuilder) Sets the Schema.Builder.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.setupKafka(String bootstrapServers, String consumerGroup) Helper to aid in setting up a kafka connector for the EventStream.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.withKafkaTimestampAsWatermark() Adds a "kafka_timestamp" column to the schema and uses it as the watermark field with a default watermark delay of 10 seconds.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.withKafkaTimestampAsWatermark(String columnName, int watermarkDelaySeconds) Adds kafka timestamp as a virtual column to the schema, and uses it as the watermark with a delay of watermarkDelaySeconds.
EventTableDescriptorBuilder	EventTableDescriptorBuilder.withKafkaTimestampAsWatermark(String columnName, String sqlExpression) Adds kafka timestamp as a virtual column to the schema, and uses it as the watermark.