Package org.apache.storm.bolt

Class JoinBolt.JoinInfo

java.lang.Object

org.apache.storm.bolt.JoinBolt.JoinInfo

All Implemented Interfaces:

Serializable

Enclosing class:

JoinBolt

protected static class JoinBolt.JoinInfo
extends Object
implements Serializable

Describes how to join the other stream with the current stream.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
JoinInfo(JoinBolt.FieldSelector field)
JoinInfo(JoinBolt.FieldSelector field, String otherStream, JoinBolt.JoinInfo otherStreamJoinInfo, JoinBolt.JoinType joinType)

Method Summary

Modifier and Type	Method	Description
JoinBolt.FieldSelector	getJoinField()
JoinBolt.JoinType	getJoinType()
String[]	getOtherField()
String	getOtherStream()

Methods inherited from class java.lang.Object

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

Constructor Detail

JoinInfo

public JoinInfo(JoinBolt.FieldSelector field)

JoinInfo

public JoinInfo(JoinBolt.FieldSelector field,
                String otherStream,
                JoinBolt.JoinInfo otherStreamJoinInfo,
                JoinBolt.JoinType joinType)

Method Detail

getJoinField

public JoinBolt.FieldSelector getJoinField()

getOtherStream

public String getOtherStream()

getOtherField

public String[] getOtherField()

getJoinType

public JoinBolt.JoinType getJoinType()