DEFAULT_OUTPUT_FLUSH_THREAD_NAME, flushAlways, numberOfChannels, rng, serializer, targetPartition
|Modifier and Type||Method and Description|
This is used to broadcast streaming Watermarks in-band with records.
This is used to send regular records.
broadcastEvent, broadcastEvent, checkErroneous, close, emit, flushAll, getAvailableFuture, randomEmit, serializeRecord, setMetricGroup
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public void emit(T record) throws IOException
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.