Package org.apache.storm.bolt

Class JoinBolt.JoinAccumulator

java.lang.Object

org.apache.storm.bolt.JoinBolt.JoinAccumulator

Enclosing class:

JoinBolt

protected class JoinBolt.JoinAccumulator
extends Object

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	JoinAccumulator()

Method Summary

Modifier and Type	Method	Description
Collection<JoinBolt.ResultRecord>	getRecords()
void	insert(JoinBolt.ResultRecord tuple)

Methods inherited from class java.lang.Object

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

Constructor Details

JoinAccumulator

protected JoinAccumulator()

Method Details

insert

public void insert(JoinBolt.ResultRecord tuple)

getRecords

public Collection<JoinBolt.ResultRecord> getRecords()