Package org.apache.beam.sdk.transforms

Class Redistribute

java.lang.Object

org.apache.beam.sdk.transforms.Redistribute

public class Redistribute
extends 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	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	Description
Redistribute()

Method Summary

Modifier and Type	Method	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 Details

Redistribute

public Redistribute()

Method Details

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.