T
- the type of the record that can be emitted with this record writerpublic final class BroadcastRecordWriter<T extends IOReadableWritable> extends RecordWriter<T>
The BroadcastRecordWriter extends the RecordWriter
and emits records to all channels
for regular emit(IOReadableWritable)
.
AvailabilityProvider.AvailabilityHelper
DEFAULT_OUTPUT_FLUSH_THREAD_NAME, flushAlways, numberOfChannels, rng, serializer, targetPartition
AVAILABLE
Modifier and Type | Method and Description |
---|---|
void |
broadcastEmit(T record)
This is used to broadcast streaming Watermarks in-band with records.
|
void |
emit(T record)
This is used to send regular records.
|
abortCheckpoint, alignedBarrierTimeout, broadcastEvent, broadcastEvent, checkErroneous, close, emit, flushAll, getAvailableFuture, randomEmit, serializeRecord, setMaxOverdraftBuffersPerGate, setMetricGroup
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
and, isApproximatelyAvailable, isAvailable, or
public void emit(T record) throws IOException
RecordWriter
emit
in class RecordWriter<T extends IOReadableWritable>
IOException
public void broadcastEmit(T record) throws IOException
RecordWriter
broadcastEmit
in class RecordWriter<T extends IOReadableWritable>
IOException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.