public interface RecordWriterDelegate<T extends IOReadableWritable> extends AvailabilityProvider, AutoCloseable
RecordWriter
or multiple RecordWriter
instances in specific
implementations.AvailabilityProvider.AvailabilityHelper
AVAILABLE
Modifier and Type | Method and Description |
---|---|
void |
broadcastEvent(AbstractEvent event)
Broadcasts the provided event to all the internal record writer instances.
|
RecordWriter<T> |
getRecordWriter(int outputIndex)
Returns the internal actual record writer instance based on the output index.
|
getAvailableFuture, isApproximatelyAvailable, isAvailable
close
void broadcastEvent(AbstractEvent event) throws IOException
event
- the event to be emitted to all the output channels.IOException
RecordWriter<T> getRecordWriter(int outputIndex)
outputIndex
- the index respective to the record writer instance.Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.