Package org.apache.storm.trident.planner

Class BridgeReceiver

java.lang.Object

org.apache.storm.trident.planner.BridgeReceiver

All Implemented Interfaces:

TupleReceiver

public class BridgeReceiver
extends Object
implements TupleReceiver

Constructor Summary

Constructors

Constructor	Description
BridgeReceiver(BatchOutputCollector collector)

Method Summary

Modifier and Type	Method	Description
void	execute(ProcessorContext context, String streamId, TridentTuple tuple)
void	flush()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BridgeReceiver

public BridgeReceiver(BatchOutputCollector collector)

Method Details

execute

public void execute(ProcessorContext context,
 String streamId,
 TridentTuple tuple)

Specified by:

execute in interface TupleReceiver

flush

public void flush()

Specified by:

flush in interface TupleReceiver