org.apache.flink.storm.util

Class SplitStreamType<T>

java.lang.Object

org.apache.flink.storm.util.SplitStreamType<T>

public class SplitStreamType<T>
extends Object

Used by org.apache.flink.storm.wrappers.AbstractStormCollector to wrap output tuples if multiple output streams are declared. For this case, the Flink output data stream must be split via .split(...) using StormStreamSelector.

Field Summary

Fields

Modifier and Type	Field and Description
String	streamId The stream ID this tuple belongs to.
T	value The actual data value.

Constructor Summary

Constructors

Constructor and Description
SplitStreamType()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

streamId

public String streamId

The stream ID this tuple belongs to.

value

public T value

The actual data value.

Constructor Detail

SplitStreamType

public SplitStreamType()

Method Detail

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object