Package 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	Description
protected	IdStreamSpec(String component, String stream)

Method Summary

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

IdStreamSpec

protected IdStreamSpec(String component,
 String stream)

Method Details

makeDetectSpec

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

getGlobalStreamId

public GlobalStreamId getGlobalStreamId()