I
- runtime interface needed by the table sink@PublicEvolving public interface EncodingFormat<I> extends Format
Format
for a DynamicTableSink
for writing rows.Modifier and Type | Method and Description |
---|---|
I |
createRuntimeEncoder(DynamicTableSink.Context context,
DataType consumedDataType)
Creates runtime encoder implementation that is configured to consume data of the given data
type.
|
getChangelogMode
I createRuntimeEncoder(DynamicTableSink.Context context, DataType consumedDataType)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.