This operator writes out the key value for the hash join reduce operation similar to POLocalRearrangeTez.
POCounterStatsTez is used to group counters from previous vertex POCounterTez tasks
POFRJoinTez is used on the backend to load replicated table from Tez ShuffleUnorderedKVInput and load fragmented table from data pipeline.
POIdentityInOutTez is used to pass through tuples as is to next vertex from previous vertex's POLocalRearrangeTez.
POLocalRearrangeTez is used to write to a Tez OrderedPartitionedKVOutput (shuffle) or UnorderedKVOutput (broadcast)
The partition rearrange operator is a part of the skewed join implementation.
POShuffledValueInputTez is used read tuples from a Tez Intermediate output from a shuffle edge To be used with POValueOutputTez.
POSimpleTezLoad is used on the backend to read tuples from a Tez MRInput
POStoreTez is used to write to a Tez MROutput
POValueInputTez is used read tuples from a Tez Intermediate output from a 1-1 edge
Copyright © 2007-2017 The Apache Software Foundation