public class DynamicTableSinkSpec extends CatalogTableSpecBase
DynamicTableSourceSpec
describes how to serialize/deserialize dynamic table sink table
and create DynamicTableSink
from the deserialization result.Modifier and Type | Field and Description |
---|---|
static String |
FIELD_NAME_SINK_ABILITY_SPECS |
catalogTable, classLoader, configuration, FIELD_NAME_CATALOG_TABLE, FIELD_NAME_IDENTIFIER, objectIdentifier
Constructor and Description |
---|
DynamicTableSinkSpec(ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
List<SinkAbilitySpec> sinkAbilitySpecs) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
getTableSink() |
void |
setTableSink(DynamicTableSink tableSink) |
equals, getCatalogTable, getClassLoader, getObjectIdentifier, getReadableConfig, hashCode, setClassLoader, setReadableConfig
public static final String FIELD_NAME_SINK_ABILITY_SPECS
public DynamicTableSinkSpec(ObjectIdentifier objectIdentifier, ResolvedCatalogTable catalogTable, @Nullable List<SinkAbilitySpec> sinkAbilitySpecs)
public DynamicTableSink getTableSink()
public void setTableSink(DynamicTableSink tableSink)
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.