storm.trident.planner

Class BridgeReceiver

java.lang.Object

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

Methods

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

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