org.apache.storm.coordination

Class CoordinatedBolt.IdStreamSpec

java.lang.Object

org.apache.storm.coordination.CoordinatedBolt.IdStreamSpec

All Implemented Interfaces:

Serializable

Enclosing class:

CoordinatedBolt

public static class CoordinatedBolt.IdStreamSpec
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	IdStreamSpec(String component, String stream)

Method Summary

Modifier and Type	Method and Description
GlobalStreamId	getGlobalStreamId()
static CoordinatedBolt.IdStreamSpec	makeDetectSpec(String component, String stream)

Methods inherited from class java.lang.Object

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

Constructor Detail

IdStreamSpec

protected IdStreamSpec(String component,
                       String stream)

Method Detail

getGlobalStreamId

public GlobalStreamId getGlobalStreamId()

makeDetectSpec

public static CoordinatedBolt.IdStreamSpec makeDetectSpec(String component,
                                                          String stream)