Package org.apache.drill.exec.physical.impl.broadcastsender

Class BroadcastSenderRootExec

java.lang.Object

org.apache.drill.exec.physical.impl.BaseRootExec

org.apache.drill.exec.physical.impl.broadcastsender.BroadcastSenderRootExec

All Implemented Interfaces:

AutoCloseable, RootExec

public class BroadcastSenderRootExec
extends BaseRootExec

Broadcast Sender broadcasts incoming batches to all receivers (one or more). This is useful in cases such as broadcast join where sending the entire table to join to all nodes is cheaper than merging and computing all the joins in the same node.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	BroadcastSenderRootExec.Metric

Field Summary

Fields inherited from class org.apache.drill.exec.physical.impl.BaseRootExec

ENABLE_BATCH_DUMP_CONFIG, fragmentContext, oContext, stats

Constructor Summary

Constructors

Constructor	Description
BroadcastSenderRootExec(RootFragmentContext context, RecordBatch incoming, BroadcastSender config)

Method Summary

Modifier and Type	Method	Description
boolean	innerNext()
void	updateStats(FragmentWritableBatch writableBatch)

Methods inherited from class org.apache.drill.exec.physical.impl.BaseRootExec

close, dumpBatches, findLeaf, next, next, receivingFragmentFinished

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BroadcastSenderRootExec

public BroadcastSenderRootExec(RootFragmentContext context,
 RecordBatch incoming,
 BroadcastSender config)
                        throws OutOfMemoryException

Throws:

OutOfMemoryException

Method Details

innerNext

public boolean innerNext()

Specified by:

innerNext in class BaseRootExec

updateStats

public void updateStats(FragmentWritableBatch writableBatch)