| Modifier and Type | Method and Description |
|---|---|
void |
AccountingDataTunnel.sendRecordBatch(FragmentWritableBatch batch) |
| Modifier and Type | Method and Description |
|---|---|
void |
SingleSenderCreator.SingleSenderRootExec.updateStats(FragmentWritableBatch writableBatch) |
| Modifier and Type | Method and Description |
|---|---|
void |
BroadcastSenderRootExec.updateStats(FragmentWritableBatch writableBatch) |
| Modifier and Type | Method and Description |
|---|---|
void |
PartitionerTemplate.OutgoingRecordBatch.updateStats(FragmentWritableBatch writableBatch) |
| Modifier and Type | Method and Description |
|---|---|
static FragmentWritableBatch |
FragmentWritableBatch.getEmptyBatchWithSchema(boolean isLast,
UserBitShared.QueryId queryId,
int sendMajorFragmentId,
int sendMinorFragmentId,
int receiveMajorFragmentId,
int receiveMinorFragmentId,
BatchSchema schema) |
static FragmentWritableBatch |
FragmentWritableBatch.getEmptyLast(UserBitShared.QueryId queryId,
int sendMajorFragmentId,
int sendMinorFragmentId,
int receiveMajorFragmentId,
int receiveMinorFragmentId) |
static FragmentWritableBatch |
FragmentWritableBatch.getEmptyLast(UserBitShared.QueryId queryId,
int sendMajorFragmentId,
int sendMinorFragmentId,
int receiveMajorFragmentId,
int[] receiveMinorFragmentIds) |
static FragmentWritableBatch |
FragmentWritableBatch.getEmptyLastWithSchema(UserBitShared.QueryId queryId,
int sendMajorFragmentId,
int sendMinorFragmentId,
int receiveMajorFragmentId,
int receiveMinorFragmentId,
BatchSchema schema) |
| Modifier and Type | Method and Description |
|---|---|
void |
DataTunnel.sendRecordBatch(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener,
FragmentWritableBatch batch) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.