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>	A by-key redistribute transform.
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()	Returns a Redistribute.RedistributeArbitrarily transform with default configuration.
static <K, V> Redistribute.RedistributeByKey<K,V>	byKey()	Returns a Redistribute.RedistributeByKey transform with default configuration.

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.