org.wikimedia.eventutilities.flink.formats.json

Class EventJsonFormatFactory

java.lang.Object

org.apache.flink.formats.json.JsonFormatFactory

org.wikimedia.eventutilities.flink.formats.json.EventJsonFormatFactory

All Implemented Interfaces:

org.apache.flink.table.factories.DecodingFormatFactory<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>>, org.apache.flink.table.factories.DeserializationFormatFactory, org.apache.flink.table.factories.EncodingFormatFactory<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>>, org.apache.flink.table.factories.Factory, org.apache.flink.table.factories.FormatFactory, org.apache.flink.table.factories.SerializationFormatFactory

public class EventJsonFormatFactory
extends org.apache.flink.formats.json.JsonFormatFactory

Field Summary

Fields

Modifier and Type	Field and Description
static String	IDENTIFIER

Constructor Summary

Constructors

Constructor and Description
EventJsonFormatFactory()

Method Summary

Modifier and Type	Method and Description
org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>>	createEncodingFormat(org.apache.flink.table.factories.DynamicTableFactory.Context context, org.apache.flink.configuration.ReadableConfig formatOptions)
String	factoryIdentifier()
Set<org.apache.flink.configuration.ConfigOption<?>>	forwardOptions()
Set<org.apache.flink.configuration.ConfigOption<?>>	optionalOptions()
Set<org.apache.flink.configuration.ConfigOption<?>>	requiredOptions()

Methods inherited from class org.apache.flink.formats.json.JsonFormatFactory

createDecodingFormat

Methods inherited from class java.lang.Object

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

Field Detail

IDENTIFIER

public static final String IDENTIFIER

See Also:

Constant Field Values

Constructor Detail

EventJsonFormatFactory

public EventJsonFormatFactory()

Method Detail

factoryIdentifier

public String factoryIdentifier()

Specified by:

factoryIdentifier in interface org.apache.flink.table.factories.Factory

Overrides:

factoryIdentifier in class org.apache.flink.formats.json.JsonFormatFactory

requiredOptions

public Set<org.apache.flink.configuration.ConfigOption<?>> requiredOptions()

Specified by:

requiredOptions in interface org.apache.flink.table.factories.Factory

Overrides:

requiredOptions in class org.apache.flink.formats.json.JsonFormatFactory

optionalOptions

public Set<org.apache.flink.configuration.ConfigOption<?>> optionalOptions()

Specified by:

optionalOptions in interface org.apache.flink.table.factories.Factory

Overrides:

optionalOptions in class org.apache.flink.formats.json.JsonFormatFactory

forwardOptions

public Set<org.apache.flink.configuration.ConfigOption<?>> forwardOptions()

Specified by:

forwardOptions in interface org.apache.flink.table.factories.FormatFactory

Overrides:

forwardOptions in class org.apache.flink.formats.json.JsonFormatFactory

createEncodingFormat

public org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>> createEncodingFormat(org.apache.flink.table.factories.DynamicTableFactory.Context context,
                                                                                                                                                                                       org.apache.flink.configuration.ReadableConfig formatOptions)

Specified by:

createEncodingFormat in interface org.apache.flink.table.factories.EncodingFormatFactory<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>>

Overrides:

createEncodingFormat in class org.apache.flink.formats.json.JsonFormatFactory