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–2022 The Apache Software Foundation. All rights reserved.