org.wikimedia.eventutilities.flink.table.catalog

Class EventStreamCatalogConfigurationFactory

java.lang.Object

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

public class EventStreamCatalogConfigurationFactory
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder

Method Summary

Modifier and Type	Method and Description
static EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder	builder()
EventStreamCatalogConfiguration	createTableEventConfiguration(@NonNull Map<String,String> tableOptions, @NonNull EventStreamFactory eventStreamFactory)
EventStreamCatalogConfiguration	createTableLikeEventConfiguration(@NonNull Map<String,String> tableOptions, @NonNull EventStreamFactory eventStreamFactory)
EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder	toBuilder()

Methods inherited from class java.lang.Object

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

Method Detail

createTableEventConfiguration

public EventStreamCatalogConfiguration createTableEventConfiguration(@NonNull
                                                                     @NonNull Map<String,String> tableOptions,
                                                                     @NonNull
                                                                     @NonNull EventStreamFactory eventStreamFactory)

createTableLikeEventConfiguration

public EventStreamCatalogConfiguration createTableLikeEventConfiguration(@NonNull
                                                                         @NonNull Map<String,String> tableOptions,
                                                                         @NonNull
                                                                         @NonNull EventStreamFactory eventStreamFactory)

builder

public static EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder builder()

toBuilder

public EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder toBuilder()