public class BatchOutputCollectorImpl extends BatchOutputCollector
Constructor and Description |
---|
BatchOutputCollectorImpl(OutputCollector collector) |
Modifier and Type | Method and Description |
---|---|
void |
ack(Tuple tup) |
List<Integer> |
emit(String streamId,
List<Object> tuple) |
void |
emitDirect(int taskId,
String streamId,
List<Object> tuple) |
void |
fail(Tuple tup) |
void |
flush()
Flush any buffered tuples (when batching is enabled).
|
void |
reportError(Throwable error) |
emit, emitDirect
public BatchOutputCollectorImpl(OutputCollector collector)
public List<Integer> emit(String streamId, List<Object> tuple)
emit
in class BatchOutputCollector
public void emitDirect(int taskId, String streamId, List<Object> tuple)
emitDirect
in class BatchOutputCollector
public void flush()
BatchOutputCollector
flush
in class BatchOutputCollector
public void reportError(Throwable error)
reportError
in class BatchOutputCollector
public void ack(Tuple tup)
public void fail(Tuple tup)
Copyright © 2023 The Apache Software Foundation. All rights reserved.