storm.trident.planner
Class BridgeReceiver

java.lang.Object
  storm.trident.planner.BridgeReceiver

All Implemented Interfaces:

TupleReceiver

public class BridgeReceiver
extends java.lang.Object
implements TupleReceiver

Constructor Summary

BridgeReceiver(BatchOutputCollector collector)

Method Summary

void	execute(ProcessorContext context, java.lang.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,
                    java.lang.String streamId,
                    TridentTuple tuple)

Specified by:

execute in interface TupleReceiver