Index (Wikimedia Event Platform Flink Utilities 1.4.1-SNAPSHOT API)

A B C D E F G H I J K L O P R S T V W

A

AbstractEventStreamCatalog - Class in org.wikimedia.eventutilities.flink.table.catalog: Contains override methods for Catalog that are unsupported.
AbstractEventStreamCatalog(String) - Constructor for class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
AbstractEventStreamCatalog(String, String) - Constructor for class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
alterDatabase(String, CatalogDatabase, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
alterPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
alterPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec, CatalogColumnStatistics, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
alterPartitionStatistics(ObjectPath, CatalogPartitionSpec, CatalogTableStatistics, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
alterTable(ObjectPath, CatalogBaseTable, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
alterTableColumnStatistics(ObjectPath, CatalogColumnStatistics, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
alterTableStatistics(ObjectPath, CatalogTableStatistics, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog

B

build() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema.Builder
build() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema.Builder: Finalizes the configuration and checks validity.
build() - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder
build() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder
build() - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Applies all the collected configs and options to build a TableDescriptor using information from the EventStream.
Builder(TypeInformation<Row>) - Constructor for class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema.Builder: Creates a JSON deserialization schema for the given type information.
builder() - Static method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema: Creates a builder for JsonRowSerializationSchema.Builder.
builder() - Static method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory
Builder() - Constructor for class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder
builder() - Static method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory
buildFieldDataType(String, DataType, String) - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions: Helper for constructing a DataTypes.Field with name, DataType, and optional description.

C

cancel() - Method in class org.wikimedia.eventutilities.flink.stream.SSESourceFunction
canEqual(Object) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo
canEqual(Object) - Method in class org.wikimedia.eventutilities.flink.formats.json.RowDataToJsonConverters
catalogOptions - Variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration: Option values that are passed in when first instantiating the catalog via CREATE CATALOG.
catalogOptions(Map<String, String>) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder
clear() - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Clears all collected configs and options from this EventTableDescriptorBuilder so that it can be used to build another TableDescriptor.
connector(String) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Sets the connector.
convert(JsonNode) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema: Convert a JsonNode to a Row following this schema.
convert(ObjectMapper, JsonNode, Object) - Method in interface org.wikimedia.eventutilities.flink.formats.json.RowDataToJsonConverters.RowDataToJsonConverter
copy(Row) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
copy(Row, Row) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
copy(DataInputView, DataOutputView) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
create(String[], TypeInformation<?>...) - Static method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo
create(Map<String, String>, String[], TypeInformation<?>...) - Static method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo
create(RowTypeInfo) - Static method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo
create(RowTypeInfo, Map<String, String>) - Static method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo
create() - Static method in class org.wikimedia.eventutilities.flink.stream.EventTimeAssigner: A timestamp extractor that reads the event time field from Event Platform events.
createCatalog(CatalogFactory.Context) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactory
createConverter(LogicalType) - Method in class org.wikimedia.eventutilities.flink.formats.json.RowDataToJsonConverters: Creates a runtime converter which is null safe.
createDatabase(String, CatalogDatabase, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
createEmptyRow() - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Creates a new empty Row matching this RowTypeInfo.
createEmptySubRow(String) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Creates a new empty instance of a sub Row identified by fieldPath.
createEncodingFormat(DynamicTableFactory.Context, ReadableConfig) - Method in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatFactory
createEventStreamSchemaBuilder(EventStream) - Static method in class org.wikimedia.eventutilities.flink.table.SchemaBuilderUtil: Given an EventStream, converts its latest schema to Flink columns and returns a new Schema.Builder with all columns.
createEventStreamSchemaBuilder(EventStream, String) - Static method in class org.wikimedia.eventutilities.flink.table.SchemaBuilderUtil: Given an EventStream, converts its schema at the given version to Flink columns and returns a new Schema.Builder with all columns.
createInstance() - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
createPartition(ObjectPath, CatalogPartitionSpec, CatalogPartition, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
createReader(Configuration, FSDataInputStream) - Method in class org.wikimedia.eventutilities.flink.stream.LineStreamFormat
createSerializer(ExecutionConfig) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Deprecated.
createSerializer(SerializerConfig) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo
createTable(ObjectPath, CatalogBaseTable, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
createTableEventConfiguration(Map<String, String>, EventStreamFactory) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory
CreateTableEventStreamCatalogConfiguration - Class in org.wikimedia.eventutilities.flink.table.catalog
CreateTableEventStreamCatalogConfiguration(Configuration, Configuration, Collection<ConfigOption<?>>, Collection<ConfigOption<?>>, Collection<ConfigOption<?>>, Map<String, String>, Map<String, String>, Map<String, String>, EventStreamFactory) - Constructor for class org.wikimedia.eventutilities.flink.table.catalog.CreateTableEventStreamCatalogConfiguration
createTableLikeEventConfiguration(Map<String, String>, EventStreamFactory) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory
CreateTableLikeEventStreamCatalogConfiguration - Class in org.wikimedia.eventutilities.flink.table.catalog
CreateTableLikeEventStreamCatalogConfiguration(Configuration, Configuration, Collection<ConfigOption<?>>, Collection<ConfigOption<?>>, Collection<ConfigOption<?>>, Map<String, String>, Map<String, String>, Map<String, String>, EventStreamFactory) - Constructor for class org.wikimedia.eventutilities.flink.table.catalog.CreateTableLikeEventStreamCatalogConfiguration

D

databaseExists(String) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
DataTypeSchemaConversions - Class in org.wikimedia.eventutilities.flink.formats.json: Implementation of SchemaConversions that can convert to Flink Table API DataType.
DataTypeSchemaConversions() - Constructor for class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions
DEFAULT_FORMAT_OPTIONS - Static variable in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatOptions: Default options that are applied to every table with event-json format that is created.
DEFAULT_KAFKA_OPTIONS - Static variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactoryOptions: Default options that are applied to every kafka table that is created.
DEFAULT_NON_PROJECTED_FIELDS - Static variable in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: List of fields that should not be projected by default when projecting a source event to a target event.
DEFAULT_OPTIONS - Static variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactoryOptions: Default options that are applied to every table that is created.
defaultFormatOptions - Variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration
defaultFormatOptions(Map<String, String>) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder
defaultKafkaOptions - Variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration
defaultKafkaOptions(Map<String, String>) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder
defaultTableOptions - Variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration
defaultTableOptions(Map<String, String>) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder
deserialize(DataInputView) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
deserialize(Row, DataInputView) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
deserialize(byte[]) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema
deserializer(String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Gets a JSON to Row DeserializationSchema by streamName and its latest schema version.
deserializer(String, String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Gets a JSON to Row DeserializationSchema by streamName.
dropDatabase(String, boolean, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
dropPartition(ObjectPath, CatalogPartitionSpec, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
dropTable(ObjectPath, boolean) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
duplicate() - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer

E

encode(Row, OutputStream) - Method in class org.wikimedia.eventutilities.flink.stream.FileSinkJsonRowEncoder
equals(Object) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
equals(Object) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo
equals(Object) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDataSerializationSchema
equals(Object) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema
equals(Object) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema
equals(Object) - Method in class org.wikimedia.eventutilities.flink.formats.json.RowDataToJsonConverters
EVENT_SCHEMAS_BASE_URIS - Static variable in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatOptions
EVENT_STREAM_CONFIG_URI - Static variable in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatOptions
EventDataStreamFactory - Class in org.wikimedia.eventutilities.flink.stream: Wraps EventStreamFactory with Flink DataStream API to provide helper methods to instantiate DataStream of Row using EventStream JSONSchemas and other metadata.
EventDataStreamFactory(EventStreamFactory, JsonEventGenerator) - Constructor for class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Deprecated.
use EventDataStreamFactory.builder()
EventDataStreamFactory.Builder - Class in org.wikimedia.eventutilities.flink.stream
EventJsonFormatFactory - Class in org.wikimedia.eventutilities.flink.formats.json
EventJsonFormatFactory() - Constructor for class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatFactory
EventJsonFormatOptions - Class in org.wikimedia.eventutilities.flink.formats.json
EventRowSerializer - Class in org.wikimedia.eventutilities.flink: Row serializer that supports simple schema evolution as defined by the WMF event platform.
EventRowSerializer(TypeSerializer<?>[], LinkedHashMap<String, Integer>) - Constructor for class org.wikimedia.eventutilities.flink.EventRowSerializer
EventRowSerializer.EventRowSerializerSnapshot - Class in org.wikimedia.eventutilities.flink: The serialiazer snapshot, this object is meant to represent the state of a particular EventRowSerializer.
EventRowSerializerSnapshot() - Constructor for class org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot
EventRowSerializerSnapshot(TypeSerializer<?>[], LinkedHashMap<String, Integer>) - Constructor for class org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot
EventRowTypeInfo - Class in org.wikimedia.eventutilities.flink: Simple subclasss of RowTypeInfo that provides support for: WMF Event Platform rules flink application state schema evolution for the Row type (following WMF guidelines) NOTE: the serialization format is not compatible with the flink RowSerialization and thus RowTypeInfo and EventRowTypeInfo should not be mixed up.
EventRowTypeInfo(TypeInformation<?>[], String[]) - Constructor for class org.wikimedia.eventutilities.flink.EventRowTypeInfo
EventRowTypeInfo(TypeInformation<?>[], String[], Map<String, String>) - Constructor for class org.wikimedia.eventutilities.flink.EventRowTypeInfo
eventStream(EventStream) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Sets the EventStream that will be used to build the TableDescriptor.
eventStream(String) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Sets the EventStream by streamName that will be used to build the TableDescriptor.
EventStreamCatalog - Class in org.wikimedia.eventutilities.flink.table.catalog
EventStreamCatalog(String, List<String>, String, Map<String, String>, Map<String, String>) - Constructor for class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
EventStreamCatalogConfiguration - Class in org.wikimedia.eventutilities.flink.table.catalog: A wrapper for all the configuration of the EventStreamCatalog.
EventStreamCatalogConfiguration(Configuration, Configuration, Collection<ConfigOption<?>>, Collection<ConfigOption<?>>, Collection<ConfigOption<?>>, Map<String, String>, Map<String, String>, Map<String, String>, EventStreamFactory) - Constructor for class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration
EventStreamCatalogConfigurationFactory - Class in org.wikimedia.eventutilities.flink.table.catalog
EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder - Class in org.wikimedia.eventutilities.flink.table.catalog
EventStreamCatalogFactory - Class in org.wikimedia.eventutilities.flink.table.catalog
EventStreamCatalogFactory() - Constructor for class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactory
EventStreamCatalogFactoryOptions - Class in org.wikimedia.eventutilities.flink.table.catalog
eventStreamConfigUri(String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder
eventStreamFactory(EventStreamFactory) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder
eventStreamFactory - Variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration
EventTableDescriptorBuilder - Class in org.wikimedia.eventutilities.flink.table: Builder wrapper to aid in constructing Flink TableDescriptors using Wikimedia Event Streams.
EventTableDescriptorBuilder(EventStreamFactory) - Constructor for class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder
EventTableUtils - Class in org.wikimedia.eventutilities.flink.table
EventTimeAssigner - Class in org.wikimedia.eventutilities.flink.stream: Creates a flink TimestampAssigner that extracts the event time.
extractKey(Row) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Extract a key for a given input Row.

F

factoryIdentifier() - Method in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatFactory
factoryIdentifier() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactory
failOnMissingField() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema.Builder: Configures schema to fail if a JSON field is missing.
fileDataStream(String, String, StreamExecutionEnvironment, WatermarkStrategy<Row>, URI...) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Gets a DataStreamSource of Row for streamName that reads JSON events from files.
fileDataStream(String, StreamExecutionEnvironment, WatermarkStrategy<Row>, URI...) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Gets a DataStreamSource of Row for streamName that reads JSON events from files using the latest schema version to deserialize.
fileSinkBuilderRowFormat(String, String, String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Shortcut helper for calling fileSinkBuilderRowFormat using a String path.
fileSinkBuilderRowFormat(String, String, Path) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: A FileSink FileSink.RowFormatBuilder used to output serialize event Rows to JSON.
fileSinkEncoder(String, String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: A Row to JSON string Encoder for use with FileSinks.
FileSinkJsonRowEncoder - Class in org.wikimedia.eventutilities.flink.stream: A FileSink Encoder that encodes event Rows to JSON strings.
FileSinkJsonRowEncoder(RowTypeInfo, SerializationSchema<Row>, SerializableClock) - Constructor for class org.wikimedia.eventutilities.flink.stream.FileSinkJsonRowEncoder
fileStreamSourceBuilder(String, String, Path...) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Gets a FileSource.FileSourceBuilder that will generate Rows of events in JSON files.
fileStreamSourceBuilder(String, Path...) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Gets a FileSource.FileSourceBuilder that will generate Rows of events in JSON files.
format(String) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Sets the format for the TableDescriptor.Builder.
FORWARD_OPTIONS - Static variable in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatOptions
forwardOptions() - Method in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatFactory
from(List<String>, String) - Static method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: EventDataStreamFactory factory method.
from(List<String>, String, Map<String, String>) - Static method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: EventDataStreamFactory factory method.
from(List<String>, String) - Static method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: EventTableDescriptorBuilder factory method.
from(List<String>, String, Map<String, String>) - Static method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: EventTableDescriptorBuilder factory method.

G

generator(JsonEventGenerator) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder
get(ConfigOption<T>) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration: Gets values from Event Configuration.
getCurrentVersion() - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot
getDatabase(String) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
getEventStreamFactory() - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Convenience method to get the EventStreamFactory used by this EventDataStreamFactory.
getEventStreamFactory() - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Convenience method to get the EventStreamFactory used by this EventTableDescriptorBuilder.
getEventTime(Row) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Read the event time field.
getIngestionTime(Row) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Get the ingestion time of this event if set.
getLength() - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
getPartition(ObjectPath, CatalogPartitionSpec) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
getPartitionColumnStatistics(ObjectPath, CatalogPartitionSpec) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
getPartitionStatistics(ObjectPath, CatalogPartitionSpec) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
getProcessedOptions() - Method in class org.wikimedia.eventutilities.flink.table.catalog.CreateTableEventStreamCatalogConfiguration: Processes options for CREATE TABLE.
getProcessedOptions() - Method in class org.wikimedia.eventutilities.flink.table.catalog.CreateTableLikeEventStreamCatalogConfiguration: Processes options for CREATE TABLE LIKE.
getProcessedOptions() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration: This should implement logic that produces a map of finalized table options that is ready to be used in CatalogTable.of.
getProducedType() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema
getProducedType() - Method in class org.wikimedia.eventutilities.flink.stream.LineStreamFormat
getProducedType() - Method in class org.wikimedia.eventutilities.flink.stream.SSESourceFunction
getSchemaBuilder() - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Use this to get the schemaBuilder for the eventStream in order to augment and reset it before calling build().
getTable(ObjectPath) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
getTableColumnStatistics(ObjectPath) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
getTableOfEventStream(EventStream, String, Map<String, String>, String, List<Schema.UnresolvedColumn>) - Static method in class org.wikimedia.eventutilities.flink.table.EventTableUtils: Creates a table with a schema from the given event stream.
getTableOfEventStream(EventStream, String, Map<String, String>, String, List<Schema.UnresolvedColumn>, String, Integer) - Static method in class org.wikimedia.eventutilities.flink.table.EventTableUtils: Creates a table with a schema from the given event stream and merges it with custom columns.
getTableStatistics(ObjectPath) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
getTypeInformation() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema: The type information supported by this serializer.

H

hashCode() - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
hashCode() - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo
hashCode() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDataSerializationSchema
hashCode() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema
hashCode() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema
hashCode() - Method in class org.wikimedia.eventutilities.flink.formats.json.RowDataToJsonConverters
hasKey() - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Check if the EventRowTypeInformation instance has a partition key.
HTTP_ROUTES - Static variable in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatOptions
httpClientRoutes(Map<String, String>) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder

I

IDENTIFIER - Static variable in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatFactory
IDENTIFIER - Static variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactory
ignoreParseErrors() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema.Builder: Configures schema to fail when parsing json failed.
isEndOfStream(Row) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema
isEventJson() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration
isImmutableType() - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
isKafkaTable() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration

J

JsonRowDataSerializationSchema - Class in org.wikimedia.eventutilities.flink.formats.json: Serialization schema that serializes an object of Flink internal data structure into a JSON bytes.
JsonRowDataSerializationSchema(RowType, Function<Consumer<ObjectNode>, ObjectNode>, ObjectMapper, TimestampFormat, JsonFormatOptions.MapNullKeyMode, String, boolean) - Constructor for class org.wikimedia.eventutilities.flink.formats.json.JsonRowDataSerializationSchema
JsonRowDeserializationSchema - Class in org.wikimedia.eventutilities.flink.formats.json: Deserialization schema from JSON to Flink Row type.
JsonRowDeserializationSchema(TypeInformation<Row>, boolean, boolean, JsonRowDeserializationSchema.RowFieldMode) - Constructor for class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema
JsonRowDeserializationSchema(TypeInformation<Row>, boolean, boolean) - Constructor for class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema: Default constructor that will deserialize Rows in hybrid POSITION_WITH_NAMES mode.
JsonRowDeserializationSchema.Builder - Class in org.wikimedia.eventutilities.flink.formats.json: Builder for JsonRowDeserializationSchema.
JsonRowDeserializationSchema.RowFieldMode - Enum in org.wikimedia.eventutilities.flink.formats.json: Used to determine which of the Row field modes in which this deserializer should create Rows.
JsonRowSerializationSchema - Class in org.wikimedia.eventutilities.flink.formats.json: Serialization schema that serializes an object of Flink types into a JSON bytes.
JsonRowSerializationSchema.Builder - Class in org.wikimedia.eventutilities.flink.formats.json: Builder for JsonRowSerializationSchema.
JsonSchemaFlinkConverter - Class in org.wikimedia.eventutilities.flink.formats.json: Converts from JSONSchemas to Flink types.

K

KafkaEventSerializationSchema - Class in org.wikimedia.eventutilities.flink.formats.json: This class is designed to produce events compliant with the WMF Event Platform.
KafkaEventSerializationSchema(RowTypeInfo, SerializationSchema<Row>, SerializableClock, String, KafkaRecordTimestampStrategy, FlinkKafkaPartitioner<Row>) - Constructor for class org.wikimedia.eventutilities.flink.formats.json.KafkaEventSerializationSchema
KafkaRecordTimestampStrategy - Enum in org.wikimedia.eventutilities.flink.formats.json: Strategy regarding how to assign the kafka timestamp of the output messages.
kafkaSinkBuilder(String, String, String, String, KafkaRecordTimestampStrategy) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Prepare a KafkaSinkBuilder with all the required components to produce to kafka using a json format matching the provided schema.
kafkaSinkBuilder(String, String, String, String, KafkaRecordTimestampStrategy, FlinkKafkaPartitioner<Row>) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Prepare a KafkaSinkBuilder with all the required components to produce to kafka using a json format matching the provided schema.
kafkaSourceBuilder(String, String, String, String, List<String>) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Get a KafkaSourceBuilder that is primed with settings needed to consume the streamName from Kafka.
kafkaSourceBuilder(String, String, String, List<String>) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Get a KafkaSourceBuilder that is primed with settings needed to consume the streamName from Kafka using the latest schema version.
kafkaSourceBuilder(String, String, String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Get a KafkaSourceBuilder that is primed with settings needed to consume the streamName from Kafka from the stream's configured topics that matching the topic filter or topic prefix using the latest schema version.
keyTypeInfo() - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Return a TypeInfo representing the schema of Row keys.

L

LineStreamFormat<T> - Class in org.wikimedia.eventutilities.flink.stream: A reader format that reads text lines from a file, and uses the provided DeserializationSchema to deserialize them.
LineStreamFormat(DeserializationSchema<T>) - Constructor for class org.wikimedia.eventutilities.flink.stream.LineStreamFormat
listDatabases() - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
listPartitions(ObjectPath) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
listPartitions(ObjectPath, CatalogPartitionSpec) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
listPartitionsByFilter(ObjectPath, List<Expression>) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
listTables(String) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
listViews(String) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog

O

open(SerializationSchema.InitializationContext, KafkaRecordSerializationSchema.KafkaSinkContext) - Method in class org.wikimedia.eventutilities.flink.formats.json.KafkaEventSerializationSchema
open() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
option(String, String) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Sets a single TableDescriptor.Builder option.
optionalOptions() - Method in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatFactory
optionalOptions() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactory
options(Map<String, String>) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Sets the TableDescriptor.Builder options.
org.wikimedia.eventutilities.flink - package org.wikimedia.eventutilities.flink
org.wikimedia.eventutilities.flink.formats.json - package org.wikimedia.eventutilities.flink.formats.json
org.wikimedia.eventutilities.flink.stream - package org.wikimedia.eventutilities.flink.stream
org.wikimedia.eventutilities.flink.table - package org.wikimedia.eventutilities.flink.table
org.wikimedia.eventutilities.flink.table.catalog - package org.wikimedia.eventutilities.flink.table.catalog
OVERRIDE_OPTIONS - Static variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactoryOptions: Options that can be overridden by options passed in through the table.
overrideOptions - Variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration: List of options that can be overridden by pseudoTableOptions.
overrideOptions(Collection<ConfigOption<?>>) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder

P

partitionedBy(String...) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Sets the partitionKeys for the TableDescriptor.Builder.
partitionExists(ObjectPath, CatalogPartitionSpec) - Method in class org.wikimedia.eventutilities.flink.table.catalog.AbstractEventStreamCatalog
PLACEHOLDER - Static variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
projectFrom(Row, boolean, Set<String>) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Project an input Row to a new Row matching the TypeInformation of this class.
projectFrom(Row, boolean) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Project an input Row to a new Row matching the TypeInformation of this class.
PSEUDO_TABLE_OPTIONS - Static variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactoryOptions: Options that are provided through the table but only used by the catalog.
pseudoTableOptions - Variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration: List of options that can be passed in via the table but not used by the table.
pseudoTableOptions(Collection<ConfigOption<?>>) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder

R

readSnapshot(int, DataInputView, ClassLoader) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot
readV1(DataInputView, ClassLoader) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot
requiredOptions() - Method in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatFactory
requiredOptions() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactory
resolveSchemaCompatibility(TypeSerializerSnapshot<Row>) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot
resolveSubFieldCompat(TypeSerializerSnapshot<?>, TypeSerializerSnapshot<?>) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot
restoreSerializer() - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot
RowDataToJsonConverters - Class in org.wikimedia.eventutilities.flink.formats.json: Tool class used to convert from RowData to JsonNode.
RowDataToJsonConverters(TimestampFormat, JsonFormatOptions.MapNullKeyMode, String) - Constructor for class org.wikimedia.eventutilities.flink.formats.json.RowDataToJsonConverters
RowDataToJsonConverters.RowDataToJsonConverter - Interface in org.wikimedia.eventutilities.flink.formats.json: Runtime converter that converts objects of Flink Table and SQL internal data structures to corresponding JsonNodes.
rowFieldMode(JsonRowDeserializationSchema.RowFieldMode) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema.Builder
rowTypeInfo(String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Gets the EventRowTypeInfo (which is a TypeInformation of Row) for the streamName.
rowTypeInfo(String, String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Gets the EventRowTypeInfo (which is a TypeInformation of Row) for the streamName and a particular schema version.
run(SourceFunction.SourceContext<T>) - Method in class org.wikimedia.eventutilities.flink.stream.SSESourceFunction

S

SCHEMA_VERSION - Static variable in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatOptions
schemaBaseUris(List<String>) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder
schemaBuilder(Schema.Builder) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Sets the Schema.Builder.
SchemaBuilderUtil - Class in org.wikimedia.eventutilities.flink.table: Helper functions for creating and adding to Flink Schema.Builder for WMF event streams.
serialize(Row, DataOutputView) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
serialize(RowData) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowDataSerializationSchema
serialize(Row) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema
serialize(Row, KafkaRecordSerializationSchema.KafkaSinkContext, Long) - Method in class org.wikimedia.eventutilities.flink.formats.json.KafkaEventSerializationSchema
serializer(String, String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Create a SerializationSchema suited for producing json to the stream identified by streamName using the provided schema version.
setEventTime(Row, Instant) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Set the event time (dt) as per WMF event platform rules.
setIngestionTime(Row, Instant) - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Set the ingestion time (meta.dt) as per WMF event platform rules.
setupKafka(String, String) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Helper to aid in setting up a kafka connector for the EventStream.
sharedOptions - Variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration: List of options that are shared across the catalog and format.
sharedOptions(Collection<ConfigOption<?>>) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder
snapshotConfiguration() - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer
sseSourceFunction(String, String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Returns a SourceFunction that reads JSON event Rows from the SSE EventSource.
sseSourceFunction(String, String, String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory: Returns a SourceFunction that reads JSON event Rows from the SSE EventSource.
SSESourceFunction<T> - Class in org.wikimedia.eventutilities.flink.stream: Server Sent Events (AKA EventSource) Flink SourceFunction.
SSESourceFunction(URI, DeserializationSchema<T>) - Constructor for class org.wikimedia.eventutilities.flink.stream.SSESourceFunction
SSESourceFunction(String, DeserializationSchema<T>) - Constructor for class org.wikimedia.eventutilities.flink.stream.SSESourceFunction
STREAM_NAME - Static variable in class org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatOptions
STREAM_PREFIX - Static variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactoryOptions

T

tableExists(ObjectPath) - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalog
tableOptions - Variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfiguration: Option values are passed in when instantiating a table within the catalog via CREATE TABLE.
toBuilder() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory
toDataType(ObjectNode) - Static method in class org.wikimedia.eventutilities.flink.formats.json.JsonSchemaFlinkConverter: Converts this JSONSchema to a Flink Table API DataType.
toDeserializationSchemaRow(ObjectNode) - Static method in class org.wikimedia.eventutilities.flink.formats.json.JsonSchemaFlinkConverter: Gets a JSON deserializer to Row in hybrid named position mode for the jsonSchema.
topicFilter(Predicate<String>) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder: The filter to apply when extracting the configured topics of a stream.
topicPrefix(String) - Method in class org.wikimedia.eventutilities.flink.stream.EventDataStreamFactory.Builder: Filter source topics with a particular prefix (generally the datacenter name).
toRowTypeInfo() - Method in class org.wikimedia.eventutilities.flink.EventRowTypeInfo: Obtain the equivalent RowTypeInfo.
toRowTypeInfo(ObjectNode) - Static method in class org.wikimedia.eventutilities.flink.formats.json.JsonSchemaFlinkConverter: Converts this JSONSchema to a Flink DataStream API EventRowTypeInfo, which is an instance of TypeInformation<Row>.
toRowTypeInfo(ObjectNode, ObjectNode) - Static method in class org.wikimedia.eventutilities.flink.formats.json.JsonSchemaFlinkConverter: Converts this JSONSchema to a Flink DataStream API EventRowTypeInfo, with stream partitions keys extracted from messageKeyFields mappings.
toSchemaBuilder(ObjectNode) - Static method in class org.wikimedia.eventutilities.flink.formats.json.JsonSchemaFlinkConverter: Returns a Table API Schema Builder starting with a Row DataType converted from the provided JSONSchema.
toString() - Method in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogConfigurationFactory.EventStreamCatalogConfigurationFactoryBuilder
toTypeInformation(ObjectNode) - Static method in class org.wikimedia.eventutilities.flink.formats.json.JsonSchemaFlinkConverter: Converts this JSONSchema to a Flink DataStream API TypeInformation.
toTypeInformation(ObjectNode, ObjectNode) - Static method in class org.wikimedia.eventutilities.flink.formats.json.JsonSchemaFlinkConverter: Converts this JSONSchema to a Flink DataStream API TypeInformation with key TypeInformation extracted from messageKeyFields mappings.
typeArray(DataType, boolean) - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions: elementsAreNullable is ignored; all Flink Table API elements are nullable.
typeArray(TypeInformation<?>, boolean) - Method in class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions: elementsAreNullable is ignored, element values can always be null.
typeBoolean() - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions
typeBoolean() - Method in class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions
typeDecimal() - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions
typeDecimal() - Method in class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions
TypeInformationSchemaConversions - Class in org.wikimedia.eventutilities.flink.formats.json: Implementation of SchemaConversions that can convert to Flink DataStream API TypeInformation.
TypeInformationSchemaConversions() - Constructor for class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions
typeInteger() - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions: Note that the default conversion of LogicalType BigIntType is Long, which is NOT the same as Flink Types.BIG_INT (in the DataStream API).
typeInteger() - Method in class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions
typeMap(DataType, DataType, boolean) - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions: valuesAreNullable is ignored; all Flink Table API elements are nullable.
typeMap(TypeInformation<?>, TypeInformation<?>, boolean) - Method in class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions: valuesAreNullable is ignored, an map values can always be null.
typeNull() - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions
typeNull() - Method in class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions
typeRow(List<SchemaConversions.RowField<DataType>>) - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions: If a RowFields description is not null, it will be used as the DataTypes.Field's description.
typeRow(List<SchemaConversions.RowField<TypeInformation<?>>>) - Method in class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions: Converts rowFields to TypeInformation of Row.
typeString() - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions
typeString() - Method in class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions
typeTimestamp() - Method in class org.wikimedia.eventutilities.flink.formats.json.DataTypeSchemaConversions
typeTimestamp() - Method in class org.wikimedia.eventutilities.flink.formats.json.TypeInformationSchemaConversions: There are many ways to represent timestamps.

V

valueOf(String) - Static method in enum org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema.RowFieldMode: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.wikimedia.eventutilities.flink.formats.json.KafkaRecordTimestampStrategy: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.wikimedia.eventutilities.flink.formats.json.JsonRowDeserializationSchema.RowFieldMode: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.wikimedia.eventutilities.flink.formats.json.KafkaRecordTimestampStrategy: Returns an array containing the constants of this enum type, in the order they are declared.

W

WATERMARK_COLUMN - Static variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactoryOptions
WATERMARK_DELAY - Static variable in class org.wikimedia.eventutilities.flink.table.catalog.EventStreamCatalogFactoryOptions
withKafkaTimestampAsWatermark() - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Adds a "kafka_timestamp" column to the schema and uses it as the watermark field with a default watermark delay of 10 seconds.
withKafkaTimestampAsWatermark(String, int) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Adds kafka timestamp as a virtual column to the schema, and uses it as the watermark with a delay of watermarkDelaySeconds.
withKafkaTimestampAsWatermark(String, String) - Method in class org.wikimedia.eventutilities.flink.table.EventTableDescriptorBuilder: Adds kafka timestamp as a virtual column to the schema, and uses it as the watermark.
withKafkaTimestampAsWatermark(Schema.Builder) - Static method in class org.wikimedia.eventutilities.flink.table.SchemaBuilderUtil: Adds a "kafka_timestamp" column to the schema builder and uses it as the watermark field with a default watermark delay of 10 seconds.
withKafkaTimestampAsWatermark(Schema.Builder, String, int) - Static method in class org.wikimedia.eventutilities.flink.table.SchemaBuilderUtil: Adds kafka timestamp as a virtual column to the schema builder and uses it as the watermark with a delay of watermarkDelaySeconds.
withKafkaTimestampAsWatermark(Schema.Builder, String, String) - Static method in class org.wikimedia.eventutilities.flink.table.SchemaBuilderUtil: Adds kafka timestamp as a virtual column to the schema builder and uses it as the watermark.
withNormalizationFunction(Function<Consumer<ObjectNode>, ObjectNode>) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema.Builder: The normalization function to apply on the provided event data.
withObjectMapper(ObjectMapper) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema.Builder
withoutNormalization() - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema.Builder: Do not apply any normalization to serialized events.
withTypeInfo(TypeInformation<Row>) - Method in class org.wikimedia.eventutilities.flink.formats.json.JsonRowSerializationSchema.Builder: Sets type information for JSON serialization schema.
writeSnapshot(DataOutputView) - Method in class org.wikimedia.eventutilities.flink.EventRowSerializer.EventRowSerializerSnapshot

A B C D E F G H I J K L O P R S T V W