org.wikimedia.eventutilities.flink.table.catalog

Class EventStreamCatalogConfiguration

java.lang.Object

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

Direct Known Subclasses:

CreateTableEventStreamCatalogConfiguration, CreateTableLikeEventStreamCatalogConfiguration

public abstract class EventStreamCatalogConfiguration
extends Object

A wrapper for all the configuration of the EventStreamCatalog.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.flink.configuration.Configuration	catalogOptions Option values that are passed in when first instantiating the catalog via CREATE CATALOG.
protected Map<String,String>	defaultFormatOptions
protected Map<String,String>	defaultKafkaOptions
protected Map<String,String>	defaultTableOptions
protected EventStreamFactory	eventStreamFactory
protected Collection<org.apache.flink.configuration.ConfigOption<?>>	overrideOptions List of options that can be overridden by pseudoTableOptions.
protected Collection<org.apache.flink.configuration.ConfigOption<?>>	pseudoTableOptions List of options that can be passed in via the table but not used by the table.
protected Collection<org.apache.flink.configuration.ConfigOption<?>>	sharedOptions List of options that are shared across the catalog and format.
protected org.apache.flink.configuration.Configuration	tableOptions Option values are passed in when instantiating a table within the catalog via CREATE TABLE.

Constructor Summary

Constructors

Constructor and Description

EventStreamCatalogConfiguration(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
<T> T	get(org.apache.flink.configuration.ConfigOption<T> option) Gets values from Event Configuration.
abstract Map<String,String>	getProcessedOptions() This should implement logic that produces a map of finalized table options that is ready to be used in CatalogTable.of.
boolean	isEventJson()
boolean	isKafkaTable()

Methods inherited from class java.lang.Object

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

Field Detail

catalogOptions

protected final org.apache.flink.configuration.Configuration catalogOptions

Option values that are passed in when first instantiating the catalog via CREATE CATALOG.

tableOptions

protected final org.apache.flink.configuration.Configuration tableOptions

Option values are passed in when instantiating a table within the catalog via CREATE TABLE.

pseudoTableOptions

protected final Collection<org.apache.flink.configuration.ConfigOption<?>> pseudoTableOptions

List of options that can be passed in via the table but not used by the table.

overrideOptions

protected final Collection<org.apache.flink.configuration.ConfigOption<?>> overrideOptions

List of options that can be overridden by pseudoTableOptions.

sharedOptions

protected final Collection<org.apache.flink.configuration.ConfigOption<?>> sharedOptions

List of options that are shared across the catalog and format.

defaultTableOptions

protected Map<String,String> defaultTableOptions

defaultKafkaOptions

protected Map<String,String> defaultKafkaOptions

defaultFormatOptions

protected Map<String,String> defaultFormatOptions

eventStreamFactory

protected EventStreamFactory eventStreamFactory

Constructor Detail

EventStreamCatalogConfiguration

@ConstructorProperties(value={"catalogOptions","tableOptions","pseudoTableOptions","overrideOptions","sharedOptions","defaultTableOptions","defaultKafkaOptions","defaultFormatOptions","eventStreamFactory"})
public EventStreamCatalogConfiguration(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 abstract Map<String,String> getProcessedOptions()

This should implement logic that produces a map of finalized table options that is ready to be used in CatalogTable.of.

isKafkaTable

public boolean isKafkaTable()

isEventJson

public boolean isEventJson()

get

public <T> T get(org.apache.flink.configuration.ConfigOption<T> option)

Gets values from Event Configuration. This retrieves the correct values from catalog and table options. It figures out overrides and format prefixes automatically. It can be thought of retrieving options from an intermediate state after overrides have been applied but before any options have been removed.

Type Parameters:

T -

Parameters:

option -

Returns: