org.wikimedia.eventutilities.flink.table

Class EventTableUtils

java.lang.Object

org.wikimedia.eventutilities.flink.table.EventTableUtils

public final class EventTableUtils
extends Object

Method Summary

Modifier and Type	Method and Description
static org.apache.flink.table.catalog.CatalogBaseTable	getTableOfEventStream(EventStream eventStream, String schemaVersion, Map<String,String> tableOptions, String comment, List<org.apache.flink.table.api.Schema.UnresolvedColumn> otherColumns) Creates a table with a schema from the given event stream.
static org.apache.flink.table.catalog.CatalogBaseTable	getTableOfEventStream(EventStream eventStream, String schemaVersion, Map<String,String> tableOptions, String comment, List<org.apache.flink.table.api.Schema.UnresolvedColumn> otherColumns, String watermarkColumn, Integer watermarkDelay) Creates a table with a schema from the given event stream and merges it with custom columns.

Methods inherited from class java.lang.Object

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

Method Detail

getTableOfEventStream

public static org.apache.flink.table.catalog.CatalogBaseTable getTableOfEventStream(EventStream eventStream,
                                                                                    String schemaVersion,
                                                                                    Map<String,String> tableOptions,
                                                                                    @Nullable
                                                                                    String comment,
                                                                                    @Nullable
                                                                                    List<org.apache.flink.table.api.Schema.UnresolvedColumn> otherColumns)
                                                                             throws org.apache.flink.table.catalog.exceptions.CatalogException

Creates a table with a schema from the given event stream.

Parameters:

eventStream - to get the schema from

schemaVersion - version of the schema

tableOptions - normalized options

comment - catalog table comment

otherColumns - additional columns

Returns:

CatalogBaseTable

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException - if there is a column conflict

getTableOfEventStream

public static org.apache.flink.table.catalog.CatalogBaseTable getTableOfEventStream(EventStream eventStream,
                                                                                    String schemaVersion,
                                                                                    @Nonnull
                                                                                    Map<String,String> tableOptions,
                                                                                    @Nullable
                                                                                    String comment,
                                                                                    @Nullable
                                                                                    List<org.apache.flink.table.api.Schema.UnresolvedColumn> otherColumns,
                                                                                    @Nullable
                                                                                    String watermarkColumn,
                                                                                    @Nullable
                                                                                    Integer watermarkDelay)
                                                                             throws org.apache.flink.table.catalog.exceptions.CatalogException

Creates a table with a schema from the given event stream and merges it with custom columns.

Parameters:

eventStream - to get the schema from

schemaVersion - version of the schema

tableOptions - processed options

comment - catalog table comment

otherColumns - additional columns

watermarkColumn - column name for kafka timestamp watermark

watermarkDelay - delay for watermark

Returns:

CatalogBaseTable

Throws:

org.apache.flink.table.catalog.exceptions.CatalogException - if there is a column conflict