public class KafkaRecordEmitter<T> extends Object implements RecordEmitter<Tuple3<T,Long,Long>,T,KafkaPartitionSplitState>
RecordEmitter
implementation for KafkaSourceReader
.Constructor and Description |
---|
KafkaRecordEmitter() |
Modifier and Type | Method and Description |
---|---|
void |
emitRecord(Tuple3<T,Long,Long> element,
SourceOutput<T> output,
KafkaPartitionSplitState splitState)
Process and emit the records to the
SourceOutput . |
public void emitRecord(Tuple3<T,Long,Long> element, SourceOutput<T> output, KafkaPartitionSplitState splitState) throws Exception
RecordEmitter
SourceOutput
. A few recommendations to the
implementation are following:
emitRecord
in interface RecordEmitter<Tuple3<T,Long,Long>,T,KafkaPartitionSplitState>
element
- The intermediate element read by the SplitReader.output
- The output to which the final records are emit to.splitState
- The state of the split.Exception
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.