public class PartitionSenderCreator extends Object implements RootCreator<HashPartitionSender>
| Constructor and Description |
|---|
PartitionSenderCreator() |
| Modifier and Type | Method and Description |
|---|---|
RootExec |
getRoot(ExecutorFragmentContext context,
HashPartitionSender config,
List<RecordBatch> children) |
public RootExec getRoot(ExecutorFragmentContext context, HashPartitionSender config, List<RecordBatch> children) throws ExecutionSetupException
getRoot in interface RootCreator<HashPartitionSender>ExecutionSetupExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.