org.wikimedia.eventutilities.flink.table.catalog

Class CreateTableLikeEventStreamCatalogConfiguration

java.lang.Object

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

org.wikimedia.eventutilities.flink.table.catalog.CreateTableLikeEventStreamCatalogConfiguration

public class CreateTableLikeEventStreamCatalogConfiguration
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

CreateTableLikeEventStreamCatalogConfiguration(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 LIKE.

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

CreateTableLikeEventStreamCatalogConfiguration

public CreateTableLikeEventStreamCatalogConfiguration(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 LIKE. CREATE TABLE LIKE tableOptions have already been processed once by CREATE TABLE, so this handles removing options if the user switches from kafka or event-json

Specified by:

getProcessedOptions in class EventStreamCatalogConfiguration