T
- the type of the record that can be emitted with this record writerpublic class BroadcastRecordWriter<T extends IOReadableWritable> extends RecordWriter<T>
The BroadcastRecordWriter extends the RecordWriter
and handles emit(IOReadableWritable)
operation via RecordWriter.broadcastEmit(IOReadableWritable)
directly in a more efficient way.
Modifier and Type | Method and Description |
---|---|
void |
emit(T record) |
broadcastEmit, broadcastEvent, clearBuffers, close, flushAll, randomEmit, setMetricGroup
public void emit(T record) throws IOException, InterruptedException
emit
in class RecordWriter<T extends IOReadableWritable>
IOException
InterruptedException
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.