K- The type of key being reshuffled on.
V- The type of value being reshuffled.
@Internal @Deprecated public class Reshuffle<K,V> extends PTransform<PCollection<KV<K,V>>,PCollection<KV<K,V>>>
PTransform that returns a
PCollection equivalent to its input but
operationally provides some of the side effects of a
GroupByKey, in particular preventing
fusion of the surrounding transforms, checkpointing and deduplication by id.
GroupByKey so that the data is key-partitioned. Configures the
WindowingStrategy so that no data is dropped, but doesn't affect the need for the user to
specify allowed lateness and accumulation mode before a user-inserted GroupByKey.
|Modifier and Type||Method and Description|
getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, populateDisplayData, toString, validate
public static <K,V> Reshuffle<K,V> of()
public PCollection<KV<K,V>> expand(PCollection<KV<K,V>> input)
PTransformon the given
InputT, and returns its
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).