org.wikimedia.eventutilities.flink.table.catalog

Class EventStreamCatalogFactoryOptions

java.lang.Object

org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactoryOptions

public final class EventStreamCatalogFactoryOptions
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static com.google.common.collect.ImmutableMap<String,String>	DEFAULT_KAFKA_OPTIONS Default options that are applied to every kafka table that is created.
static com.google.common.collect.ImmutableMap<String,String>	DEFAULT_OPTIONS Default options that are applied to every table that is created.
static com.google.common.collect.ImmutableList<org.apache.flink.configuration.ConfigOption<?>>	OVERRIDE_OPTIONS Options that can be overridden by options passed in through the table.
static com.google.common.collect.ImmutableList<org.apache.flink.configuration.ConfigOption<?>>	PSEUDO_TABLE_OPTIONS Options that are provided through the table but only used by the catalog.
static org.apache.flink.configuration.ConfigOption<String>	STREAM_PREFIX
static org.apache.flink.configuration.ConfigOption<String>	WATERMARK_COLUMN
static org.apache.flink.configuration.ConfigOption<Integer>	WATERMARK_DELAY

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

STREAM_PREFIX

public static final org.apache.flink.configuration.ConfigOption<String> STREAM_PREFIX

WATERMARK_COLUMN

public static final org.apache.flink.configuration.ConfigOption<String> WATERMARK_COLUMN

WATERMARK_DELAY

public static final org.apache.flink.configuration.ConfigOption<Integer> WATERMARK_DELAY

DEFAULT_OPTIONS

public static final com.google.common.collect.ImmutableMap<String,String> DEFAULT_OPTIONS

Default options that are applied to every table that is created.

DEFAULT_KAFKA_OPTIONS

public static final com.google.common.collect.ImmutableMap<String,String> DEFAULT_KAFKA_OPTIONS

Default options that are applied to every kafka table that is created.

OVERRIDE_OPTIONS

public static final com.google.common.collect.ImmutableList<org.apache.flink.configuration.ConfigOption<?>> OVERRIDE_OPTIONS

Options that can be overridden by options passed in through the table.

PSEUDO_TABLE_OPTIONS

public static final com.google.common.collect.ImmutableList<org.apache.flink.configuration.ConfigOption<?>> PSEUDO_TABLE_OPTIONS

Options that are provided through the table but only used by the catalog.