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 and Description
protected	JoinAccumulator()

Method Summary

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

JoinAccumulator

protected JoinAccumulator()

Method Detail

insert

public void insert(JoinBolt.ResultRecord tuple)

getRecords

public Collection<JoinBolt.ResultRecord> getRecords()