class RecordWriter implements AvailabilityProvider {

public abstract void broadcastEmit(T record) throws IOExceptionpublic abstract void broadcastEmit(T record) throws IOException;

public abstract void broadcastEmit(T record) throws IOException  RecordWriter(ResultPartitionWriter writer, long timeout, String taskName);

}