org.apache.flink.api.java.io

Class SplitDataProperties.SourcePartitionerMarker<T>

java.lang.Object

org.apache.flink.api.java.io.SplitDataProperties.SourcePartitionerMarker<T>

Type Parameters:

T - The type of the partitioned data.

All Implemented Interfaces:

Serializable, Function, Partitioner<T>

Enclosing class:

SplitDataProperties<T>

public static class SplitDataProperties.SourcePartitionerMarker<T>
extends Object
implements Partitioner<T>

A custom partitioner to mark compatible split partitionings.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
SourcePartitionerMarker(String partitionMarker)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
int	partition(T key, int numPartitions) Computes the partition for the given key.

Methods inherited from class java.lang.Object

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

Constructor Detail

SourcePartitionerMarker

public SourcePartitionerMarker(String partitionMarker)

Method Detail

partition

public int partition(T key,
                     int numPartitions)

Description copied from interface: Partitioner

Computes the partition for the given key.

Specified by:

partition in interface Partitioner<T>

Parameters:

key - The key.

numPartitions - The number of partitions to partition into.

Returns:

The partition index.

equals

public boolean equals(Object o)

Overrides:

equals in class Object