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 and Description
JoinInfo(JoinBolt.FieldSelector field)
JoinInfo(JoinBolt.FieldSelector field, String otherStream, JoinBolt.JoinInfo otherStreamJoinInfo, JoinBolt.JoinType joinType)

Method Summary

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