org.wikimedia.eventutilities.flink.formats.json

Class EventJsonFormatOptions

java.lang.Object

org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatOptions

public final class EventJsonFormatOptions
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static com.google.common.collect.ImmutableMap<String,String>	DEFAULT_FORMAT_OPTIONS Default options that are applied to every table with event-json format that is created.
static org.apache.flink.configuration.ConfigOption<List<String>>	EVENT_SCHEMAS_BASE_URIS
static org.apache.flink.configuration.ConfigOption<String>	EVENT_STREAM_CONFIG_URI
static com.google.common.collect.ImmutableList<org.apache.flink.configuration.ConfigOption<?>>	FORWARD_OPTIONS
static org.apache.flink.configuration.ConfigOption<Map<String,String>>	HTTP_ROUTES
static org.apache.flink.configuration.ConfigOption<String>	SCHEMA_VERSION
static org.apache.flink.configuration.ConfigOption<String>	STREAM_NAME

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

EVENT_SCHEMAS_BASE_URIS

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

EVENT_STREAM_CONFIG_URI

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

STREAM_NAME

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

SCHEMA_VERSION

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

HTTP_ROUTES

public static final org.apache.flink.configuration.ConfigOption<Map<String,String>> HTTP_ROUTES

FORWARD_OPTIONS

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

DEFAULT_FORMAT_OPTIONS

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

Default options that are applied to every table with event-json format that is created.