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()