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, emitDirectpublic BatchOutputCollectorImpl(OutputCollector collector)
public List<Integer> emit(String streamId, List<Object> tuple)
emit in class BatchOutputCollectorpublic void emitDirect(int taskId,
String streamId,
List<Object> tuple)
emitDirect in class BatchOutputCollectorpublic void flush()
BatchOutputCollectorFlush any buffered tuples (when batching is enabled).
flush in class BatchOutputCollectorpublic void reportError(Throwable error)
reportError in class BatchOutputCollectorpublic void ack(Tuple tup)
public void fail(Tuple tup)
Copyright © 2021 The Apache Software Foundation. All rights reserved.