public class RecordAttributesCombiner extends Object
Constructor and Description |
---|
RecordAttributesCombiner(int numInputChannels) |
Modifier and Type | Method and Description |
---|---|
void |
inputRecordAttributes(RecordAttributes recordAttributes,
int channelIdx,
PushingAsyncDataInput.DataOutput<?> output) |
public void inputRecordAttributes(RecordAttributes recordAttributes, int channelIdx, PushingAsyncDataInput.DataOutput<?> output) throws Exception
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.