Modifier and Type | Class and Description |
---|---|
class |
AbstractExchange |
Modifier and Type | Method and Description |
---|---|
RETURN |
PhysicalVisitor.visitExchange(Exchange exchange,
EXTRA value) |
T |
AbstractPhysicalVisitor.visitExchange(Exchange exchange,
X value) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractDeMuxExchange
DeMuxExchange is opposite of MuxExchange.
|
class |
AbstractMuxExchange
Multiplexing Exchange (MuxExchange) is used when results from multiple minor fragments belonging to the same
major fragment running on a node need to be collected at one fragment on the same node before distributing the
results further.
|
class |
BroadcastExchange |
class |
HashToMergeExchange |
class |
HashToRandomExchange |
class |
OrderedMuxExchange
OrderedMuxExchange is a version of MuxExchange where the incoming batches are sorted
merge operation is performed to produced a sorted stream as output.
|
class |
OrderedPartitionExchange |
class |
RangePartitionExchange |
class |
SingleMergeExchange |
class |
UnionExchange |
class |
UnorderedDeMuxExchange
UnorderedDeMuxExchange is a version of DeMuxExchange where the incoming batches are not sorted.
|
class |
UnorderedMuxExchange
UnorderedMuxExchange is a version of MuxExchange where the incoming batches are not sorted.
|
Modifier and Type | Method and Description |
---|---|
RET |
AbstractOpWrapperVisitor.visitExchange(Exchange exchange,
Wrapper wrapper) |
RET |
AbstractOpWrapperVisitor.visitReceivingExchange(Exchange exchange,
Wrapper wrapper) |
RET |
AbstractOpWrapperVisitor.visitSendingExchange(Exchange exchange,
Wrapper wrapper) |
Modifier and Type | Method and Description |
---|---|
Exchange |
Fragment.ExchangeFragmentPair.getExchange() |
Exchange |
Fragment.getSendingExchange() |
Modifier and Type | Method and Description |
---|---|
void |
Fragment.addReceiveExchange(Exchange e,
Fragment fragment) |
void |
Fragment.addSendExchange(Exchange e,
Fragment sendingToFragment) |
Fragment |
MakeFragmentsVisitor.visitExchange(Exchange exchange,
Fragment receivingFragment) |
PhysicalOperator |
Materializer.visitExchange(Exchange exchange,
Materializer.IndexedFragmentNode iNode) |
Void |
StatsCollector.visitReceivingExchange(Exchange exchange,
Wrapper wrapper) |
Void |
MemoryCalculator.visitReceivingExchange(Exchange exchange,
Wrapper fragment) |
Void |
StatsCollector.visitSendingExchange(Exchange exchange,
Wrapper wrapper) |
Void |
MemoryCalculator.visitSendingExchange(Exchange exchange,
Wrapper fragment) |
Constructor and Description |
---|
ExchangeFragmentPair(Exchange exchange,
Fragment fragXchgTo) |
Modifier and Type | Method and Description |
---|---|
PhysicalOperator |
ExchangeRemoverMaterializer.visitExchange(Exchange exchange,
Materializer.IndexedFragmentNode iNode) |
Copyright © 1970 The Apache Software Foundation. All rights reserved.