public class BridgeReceiver extends Object implements TupleReceiver
| Constructor and Description |
|---|
BridgeReceiver(BatchOutputCollector collector) |
| Modifier and Type | Method and Description |
|---|---|
void |
execute(ProcessorContext context,
String streamId,
TridentTuple tuple) |
void |
flush() |
public BridgeReceiver(BatchOutputCollector collector)
public void execute(ProcessorContext context, String streamId, TridentTuple tuple)
execute in interface TupleReceiverpublic void flush()
flush in interface TupleReceiverCopyright © 2021 The Apache Software Foundation. All rights reserved.