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 any buffered tuples (when batching is enabled).
flush
in class BatchOutputCollector
public void reportError(Throwable error)
reportError
in class BatchOutputCollector
public void ack(Tuple tup)
public void fail(Tuple tup)
Copyright © 2022 The Apache Software Foundation. All rights reserved.