org.wikimedia.eventutilities.flink.table.catalog

Class EventStreamCatalogConfigurationFactory

java.lang.Object

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

public class EventStreamCatalogConfigurationFactory
extends Object

Constructor Summary

Constructors

Constructor and Description
EventStreamCatalogConfigurationFactory()

Method Summary

Modifier and Type	Method and Description
EventStreamCatalogConfiguration	createTableEventConfiguration(@NonNull Map<String,String> tableOptions, @NonNull EventStreamFactory eventStreamFactory)
EventStreamCatalogConfiguration	createTableLikeEventConfiguration(@NonNull Map<String,String> tableOptions, @NonNull EventStreamFactory eventStreamFactory)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventStreamCatalogConfigurationFactory

public EventStreamCatalogConfigurationFactory()

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)