public class SingleSenderCreator extends Object implements RootCreator<SingleSender>
| Modifier and Type | Class and Description |
|---|---|
static class |
SingleSenderCreator.SingleSenderRootExec |
| Constructor and Description |
|---|
SingleSenderCreator() |
| Modifier and Type | Method and Description |
|---|---|
RootExec |
getRoot(ExecutorFragmentContext context,
SingleSender config,
List<RecordBatch> children) |
public RootExec getRoot(ExecutorFragmentContext context, SingleSender config, List<RecordBatch> children)
getRoot in interface RootCreator<SingleSender>Copyright © 2021 The Apache Software Foundation. All rights reserved.