org.apache.flink.table.planner.plan.abilities.sink

Class PartitioningSpec

java.lang.Object

org.apache.flink.table.planner.plan.abilities.sink.PartitioningSpec

All Implemented Interfaces:

SinkAbilitySpec

public final class PartitioningSpec
extends Object
implements SinkAbilitySpec

A sub-class of SinkAbilitySpec that can not only serialize/deserialize the partition to/from JSON, but also can write partitioned data for SupportsPartitioning.

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_NAME_PARTITION

Constructor Summary

Constructors

Constructor and Description
PartitioningSpec(Map<String,String> partition)

Method Summary

Modifier and Type	Method and Description
void	apply(DynamicTableSink tableSink) Apply the ability to the given DynamicTableSink.
boolean	equals(Object o)
int	hashCode()

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_NAME_PARTITION

public static final String FIELD_NAME_PARTITION

See Also:

Constant Field Values

Constructor Detail

PartitioningSpec

public PartitioningSpec(Map<String,String> partition)

Method Detail

apply

public void apply(DynamicTableSink tableSink)

Description copied from interface: SinkAbilitySpec

Apply the ability to the given DynamicTableSink.

Specified by:

apply in interface SinkAbilitySpec

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object