org.wikimedia.eventutilities.flink.table.catalog

Class EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder

java.lang.Object

org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder

Enclosing class:

EventStreamCatalogConfigurationFactory

public static class EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder
extends Object

Method Summary

Modifier and Type	Method and Description
EventStreamCatalogConfigurationFactory	build()
EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder	catalogOptions(Map<String,String> catalogOptions)
EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder	defaultFormatOptions(Map<String,String> defaultFormatOptions)
EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder	defaultKafkaOptions(Map<String,String> defaultKafkaOptions)
EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder	defaultTableOptions(Map<String,String> defaultTableOptions)
EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder	overrideOptions(Collection<org.apache.flink.configuration.ConfigOption<?>> overrideOptions)
EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder	pseudoTableOptions(Collection<org.apache.flink.configuration.ConfigOption<?>> pseudoTableOptions)
EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder	sharedOptions(Collection<org.apache.flink.configuration.ConfigOption<?>> sharedOptions)
String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

catalogOptions

public EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder catalogOptions(Map<String,String> catalogOptions)

Returns:

this.

pseudoTableOptions

public EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder pseudoTableOptions(Collection<org.apache.flink.configuration.ConfigOption<?>> pseudoTableOptions)

Returns:

this.

overrideOptions

public EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder overrideOptions(Collection<org.apache.flink.configuration.ConfigOption<?>> overrideOptions)

Returns:

this.

sharedOptions

public EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder sharedOptions(Collection<org.apache.flink.configuration.ConfigOption<?>> sharedOptions)

Returns:

this.

defaultTableOptions

public EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder defaultTableOptions(Map<String,String> defaultTableOptions)

Returns:

this.

defaultKafkaOptions

public EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder defaultKafkaOptions(Map<String,String> defaultKafkaOptions)

Returns:

this.

defaultFormatOptions

public EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder defaultFormatOptions(Map<String,String> defaultFormatOptions)

Returns:

this.

build

public EventStreamCatalogConfigurationFactory build()

toString

public String toString()

Overrides:

toString in class Object