public interface Projector
| Modifier and Type | Field and Description |
|---|---|
static TemplateClassDefinition<Projector> |
TEMPLATE_DEFINITION |
| Modifier and Type | Method and Description |
|---|---|
int |
projectRecords(RecordBatch incomingBatch,
int startIndex,
int recordCount,
int firstOutputIndex) |
void |
setup(FragmentContext context,
RecordBatch incoming,
RecordBatch outgoing,
List<TransferPair> transfers) |
static final TemplateClassDefinition<Projector> TEMPLATE_DEFINITION
void setup(FragmentContext context, RecordBatch incoming, RecordBatch outgoing, List<TransferPair> transfers) throws SchemaChangeException
SchemaChangeExceptionint projectRecords(RecordBatch incomingBatch, int startIndex, int recordCount, int firstOutputIndex)
Copyright © 2021 The Apache Software Foundation. All rights reserved.