org.wikimedia.eventutilities.flink.table.catalog

Class CreateTableEventStreamCatalogConfiguration

java.lang.Object

org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration

org.wikimedia.eventutilities.flink.table.catalog.CreateTableEventStreamCatalogConfiguration

public class CreateTableEventStreamCatalogConfiguration
extends EventStreamCatalogConfiguration

Field Summary

Fields inherited from class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration

catalogOptions, defaultFormatOptions, defaultKafkaOptions, defaultTableOptions, eventStreamFactory, overrideOptions, pseudoTableOptions, sharedOptions, tableOptions

Constructor Summary

Constructors

Constructor and Description

CreateTableEventStreamCatalogConfiguration(org.apache.flink.configuration.Configuration catalogOptions, org.apache.flink.configuration.Configuration tableOptions, Collection<org.apache.flink.configuration.ConfigOption<?>> pseudoTableOptions, Collection<org.apache.flink.configuration.ConfigOption<?>> overrideOptions, Collection<org.apache.flink.configuration.ConfigOption<?>> sharedOptions, Map<String,String> defaultTableOptions, Map<String,String> defaultKafkaOptions, Map<String,String> defaultFormatOptions, EventStreamFactory eventStreamFactory)

Method Summary

Modifier and Type	Method and Description
Map<String,String>	getProcessedOptions() Processes options for CREATE TABLE.

Methods inherited from class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration

get, isEventJson, isKafkaTable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CreateTableEventStreamCatalogConfiguration

public CreateTableEventStreamCatalogConfiguration(org.apache.flink.configuration.Configuration catalogOptions,
                                                  org.apache.flink.configuration.Configuration tableOptions,
                                                  Collection<org.apache.flink.configuration.ConfigOption<?>> pseudoTableOptions,
                                                  Collection<org.apache.flink.configuration.ConfigOption<?>> overrideOptions,
                                                  Collection<org.apache.flink.configuration.ConfigOption<?>> sharedOptions,
                                                  Map<String,String> defaultTableOptions,
                                                  Map<String,String> defaultKafkaOptions,
                                                  Map<String,String> defaultFormatOptions,
                                                  EventStreamFactory eventStreamFactory)

Method Detail

getProcessedOptions

public Map<String,String> getProcessedOptions()

Processes options for CREATE TABLE. CREATE TABLE tableOptions are set by the user and should take precedence over any funky things the catalog does

Specified by:

getProcessedOptions in class EventStreamCatalogConfiguration