org.apache.flink.formats.protobuf

Class PbDecodingFormat

java.lang.Object

org.apache.flink.formats.protobuf.PbDecodingFormat

All Implemented Interfaces:

DecodingFormat<DeserializationSchema<RowData>>, Format

public class PbDecodingFormat
extends Object
implements DecodingFormat<DeserializationSchema<RowData>>

DecodingFormat for protobuf decoding.

Constructor Summary

Constructors

Constructor and Description
PbDecodingFormat(PbFormatConfig formatConfig)

Method Summary

Modifier and Type	Method and Description
DeserializationSchema<RowData>	createRuntimeDecoder(DynamicTableSource.Context context, DataType producedDataType) Creates runtime decoder implementation that is configured to produce data of the given data type.
ChangelogMode	getChangelogMode() Returns the set of changes that a connector (and transitively the planner) can expect during runtime.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.connector.format.DecodingFormat

applyReadableMetadata, listReadableMetadata

Constructor Detail

PbDecodingFormat

public PbDecodingFormat(PbFormatConfig formatConfig)

Method Detail

createRuntimeDecoder

public DeserializationSchema<RowData> createRuntimeDecoder(DynamicTableSource.Context context,
                                                           DataType producedDataType)

Description copied from interface: DecodingFormat

Creates runtime decoder implementation that is configured to produce data of the given data type.

Specified by:

createRuntimeDecoder in interface DecodingFormat<DeserializationSchema<RowData>>

Parameters:

context - the context provides several utilities required to instantiate the runtime decoder implementation of the format

producedDataType - For more details check the documentation of DecodingFormat.

getChangelogMode

public ChangelogMode getChangelogMode()

Description copied from interface: Format

Returns the set of changes that a connector (and transitively the planner) can expect during runtime.

Specified by:

getChangelogMode in interface Format