Package | Description |
---|---|
org.apache.flink.table.planner.plan.abilities.sink | |
org.apache.flink.table.planner.plan.nodes.exec.spec |
Modifier and Type | Class and Description |
---|---|
class |
OverwriteSpec
A sub-class of
SinkAbilitySpec that can not only serialize/deserialize the overwrite flag
to/from JSON, but also can overwrite existing data for SupportsOverwrite . |
class |
PartitioningSpec
A sub-class of
SinkAbilitySpec that can not only serialize/deserialize the partition
to/from JSON, but also can write partitioned data for SupportsWritingMetadata . |
class |
WritingMetadataSpec
A sub-class of
SinkAbilitySpec that can not only serialize/deserialize the metadata
columns to/from JSON, but also can write the metadata columns for SupportsWritingMetadata . |
Constructor and Description |
---|
DynamicTableSinkSpec(ObjectIdentifier objectIdentifier,
ResolvedCatalogTable catalogTable,
List<SinkAbilitySpec> sinkAbilitySpecs) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.