E- the type of the record emitted by the
T- the type of records that are eventually emitted to the
SplitStateT- the mutable type of split state.
@PublicEvolving public interface RecordEmitter<E,T,SplitStateT>
void emitRecord(E element, SourceOutput<T> output, SplitStateT splitState) throws Exception
SourceOutput. A few recommendations to the implementation are following:
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.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.