org.apache.beam.sdk.transforms

Class Redistribute

java.lang.Object

org.apache.beam.sdk.transforms.Redistribute

public class Redistribute
extends java.lang.Object

A family of PTransforms that returns a PCollection equivalent to its input but functions as an operational hint to a runner that redistributing the data in some way is likely useful.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Redistribute.RedistributeArbitrarily<T> Noop transform that hints to the runner to try to redistribute the work evenly, or via whatever clever strategy the runner comes up with.
static class	Redistribute.RedistributeByKey<K,V>
static class	Redistribute.Registrar Registers translators for the Redistribute family of transforms.

Constructor Summary

Constructors

Constructor and Description
Redistribute()

Method Summary

Modifier and Type	Method and Description
static <T> Redistribute.RedistributeArbitrarily<T>	arbitrarily()
static <K,V> Redistribute.RedistributeByKey<K,V>	byKey()

Methods inherited from class java.lang.Object

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

Constructor Detail

Redistribute

public Redistribute()

Method Detail

arbitrarily

public static <T> Redistribute.RedistributeArbitrarily<T> arbitrarily()

Returns:

a Redistribute.RedistributeArbitrarily transform with default configuration.

byKey

public static <K,V> Redistribute.RedistributeByKey<K,V> byKey()

Returns:

a Redistribute.RedistributeByKey transform with default configuration.