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 and Description
BridgeReceiver(BatchOutputCollector collector)

Method Summary

Modifier and Type	Method and 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 Detail

BridgeReceiver

public BridgeReceiver(BatchOutputCollector collector)

Method Detail

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