org.apache.storm.cluster

Class ClusterUtils

java.lang.Object

org.apache.storm.cluster.ClusterUtils

public class ClusterUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	ASSIGNMENTS_ROOT
static String	ASSIGNMENTS_SUBTREE
static String	BACKPRESSURE_ROOT
static String	BACKPRESSURE_SUBTREE
static String	BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_ROOT
static String	BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_SUBTREE
static String	BLOBSTORE_ROOT
static String	BLOBSTORE_SUBTREE
static String	CREDENTIALS_ROOT
static String	CREDENTIALS_SUBTREE
static String	ERRORS_ROOT
static String	ERRORS_SUBTREE
static String	LOGCONFIG_ROOT
static String	LOGCONFIG_SUBTREE
static String	NIMBUSES_ROOT
static String	NIMBUSES_SUBTREE
static String	PROFILERCONFIG_ROOT
static String	PROFILERCONFIG_SUBTREE
static String	STORMS_ROOT
static String	STORMS_SUBTREE
static String	SUPERVISORS_ROOT
static String	SUPERVISORS_SUBTREE
static String	WORKERBEATS_ROOT
static String	WORKERBEATS_SUBTREE
static String	ZK_SEPERATOR

Constructor Summary

Constructors

Constructor and Description
ClusterUtils()

Method Summary

Modifier and Type	Method and Description
static String	assignmentPath(String id)
static String	backpressurePath(String stormId, String node, Long port)
static String	backpressureStormRoot(String stormId)
static String	blobstoreMaxKeySequenceNumberPath(String key)
static String	blobstorePath(String key)
static Map<ExecutorInfo,ExecutorBeat>	convertExecutorBeats(List<ExecutorInfo> executors, ClusterWorkerHeartbeat workerHeartbeat) Ensures that we only return heartbeats for executors assigned to this worker
static String	credentialsPath(String stormId)
static String	errorPath(String stormId, String componentId)
static String	errorStormRoot(String stormId)
static String	lastErrorPath(String stormId, String componentId)
static String	logConfigPath(String stormId)
static <T> T	maybeDeserialize(byte[] serialized, Class<T> clazz)
static IStateStorage	mkStateStorage(Map config, Map auth_conf, List<org.apache.zookeeper.data.ACL> acls, ClusterStateContext context)
IStateStorage	mkStateStorageImpl(Map config, Map auth_conf, List<org.apache.zookeeper.data.ACL> acls, ClusterStateContext context)
static IStormClusterState	mkStormClusterState(Object StateStorage, List<org.apache.zookeeper.data.ACL> acls, ClusterStateContext context)
IStormClusterState	mkStormClusterStateImpl(Object stateStorage, List<org.apache.zookeeper.data.ACL> acls, ClusterStateContext context)
static List<org.apache.zookeeper.data.ACL>	mkTopoReadOnlyAcls(Map<String,Object> topoConf) Get ZK ACLs for a topology to have read only access.
static List<org.apache.zookeeper.data.ACL>	mkTopoReadWriteAcls(Map<String,Object> topoConf) Get ZK ACLs for a topology to have read/write access.
static String	nimbusPath(String id)
static String	profilerConfigPath(String stormId)
static String	profilerConfigPath(String stormId, String host, Long port, ProfileAction requestType)
static void	resetInstance() Resets the singleton instance to the default.
static void	setInstance(ClusterUtils u) Provide an instance of this class for delegates to use.
static String	stormPath(String id)
static String	stringifyError(Throwable error)
static String	supervisorPath(String id)
static String	workerbeatPath(String stormId, String node, Long port)
static String	workerbeatStormRoot(String stormId)

Methods inherited from class java.lang.Object

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

Field Detail

ZK_SEPERATOR

public static final String ZK_SEPERATOR

See Also:

Constant Field Values

ASSIGNMENTS_ROOT

public static final String ASSIGNMENTS_ROOT

See Also:

Constant Field Values

STORMS_ROOT

public static final String STORMS_ROOT

See Also:

Constant Field Values

SUPERVISORS_ROOT

public static final String SUPERVISORS_ROOT

See Also:

Constant Field Values

WORKERBEATS_ROOT

public static final String WORKERBEATS_ROOT

See Also:

Constant Field Values

BACKPRESSURE_ROOT

public static final String BACKPRESSURE_ROOT

See Also:

Constant Field Values

ERRORS_ROOT

public static final String ERRORS_ROOT

See Also:

Constant Field Values

BLOBSTORE_ROOT

public static final String BLOBSTORE_ROOT

See Also:

Constant Field Values

BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_ROOT

public static final String BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_ROOT

See Also:

Constant Field Values

NIMBUSES_ROOT

public static final String NIMBUSES_ROOT

See Also:

Constant Field Values

CREDENTIALS_ROOT

public static final String CREDENTIALS_ROOT

See Also:

Constant Field Values

LOGCONFIG_ROOT

public static final String LOGCONFIG_ROOT

See Also:

Constant Field Values

PROFILERCONFIG_ROOT

public static final String PROFILERCONFIG_ROOT

See Also:

Constant Field Values

ASSIGNMENTS_SUBTREE

public static final String ASSIGNMENTS_SUBTREE

See Also:

Constant Field Values

STORMS_SUBTREE

public static final String STORMS_SUBTREE

See Also:

Constant Field Values

SUPERVISORS_SUBTREE

public static final String SUPERVISORS_SUBTREE

See Also:

Constant Field Values

WORKERBEATS_SUBTREE

public static final String WORKERBEATS_SUBTREE

See Also:

Constant Field Values

BACKPRESSURE_SUBTREE

public static final String BACKPRESSURE_SUBTREE

See Also:

Constant Field Values

ERRORS_SUBTREE

public static final String ERRORS_SUBTREE

See Also:

Constant Field Values

BLOBSTORE_SUBTREE

public static final String BLOBSTORE_SUBTREE

See Also:

Constant Field Values

BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_SUBTREE

public static final String BLOBSTORE_MAX_KEY_SEQUENCE_NUMBER_SUBTREE

See Also:

Constant Field Values

NIMBUSES_SUBTREE

public static final String NIMBUSES_SUBTREE

See Also:

Constant Field Values

CREDENTIALS_SUBTREE

public static final String CREDENTIALS_SUBTREE

See Also:

Constant Field Values

LOGCONFIG_SUBTREE

public static final String LOGCONFIG_SUBTREE

See Also:

Constant Field Values

PROFILERCONFIG_SUBTREE

public static final String PROFILERCONFIG_SUBTREE

See Also:

Constant Field Values

Constructor Detail

ClusterUtils

public ClusterUtils()

Method Detail

setInstance

public static void setInstance(ClusterUtils u)

Provide an instance of this class for delegates to use. To mock out delegated methods, provide an instance of a subclass that overrides the implementation of the delegated method.

Parameters:

u - a Cluster instance

resetInstance

public static void resetInstance()

Resets the singleton instance to the default. This is helpful to reset the class to its original functionality when mocking is no longer desired.

mkTopoReadWriteAcls

public static List<org.apache.zookeeper.data.ACL> mkTopoReadWriteAcls(Map<String,Object> topoConf)

Get ZK ACLs for a topology to have read/write access.

Parameters:

topoConf - the topology config.

Returns:

the ACLs.

mkTopoReadOnlyAcls

public static List<org.apache.zookeeper.data.ACL> mkTopoReadOnlyAcls(Map<String,Object> topoConf)

Get ZK ACLs for a topology to have read only access.

Parameters:

topoConf - the topology config.

Returns:

the ACLs.

supervisorPath

public static String supervisorPath(String id)

assignmentPath

public static String assignmentPath(String id)

blobstorePath

public static String blobstorePath(String key)

blobstoreMaxKeySequenceNumberPath

public static String blobstoreMaxKeySequenceNumberPath(String key)

nimbusPath

public static String nimbusPath(String id)

stormPath

public static String stormPath(String id)

workerbeatStormRoot

public static String workerbeatStormRoot(String stormId)

workerbeatPath

public static String workerbeatPath(String stormId,
                                    String node,
                                    Long port)

backpressureStormRoot

public static String backpressureStormRoot(String stormId)

backpressurePath

public static String backpressurePath(String stormId,
                                      String node,
                                      Long port)

errorStormRoot

public static String errorStormRoot(String stormId)

errorPath

public static String errorPath(String stormId,
                               String componentId)

lastErrorPath

public static String lastErrorPath(String stormId,
                                   String componentId)

credentialsPath

public static String credentialsPath(String stormId)

logConfigPath

public static String logConfigPath(String stormId)

profilerConfigPath

public static String profilerConfigPath(String stormId)

profilerConfigPath

public static String profilerConfigPath(String stormId,
                                        String host,
                                        Long port,
                                        ProfileAction requestType)

maybeDeserialize

public static <T> T maybeDeserialize(byte[] serialized,
                                     Class<T> clazz)

convertExecutorBeats

public static Map<ExecutorInfo,ExecutorBeat> convertExecutorBeats(List<ExecutorInfo> executors,
                                                                  ClusterWorkerHeartbeat workerHeartbeat)

Ensures that we only return heartbeats for executors assigned to this worker

Parameters:

executors -

workerHeartbeat -

Returns:

mkStormClusterStateImpl

public IStormClusterState mkStormClusterStateImpl(Object stateStorage,
                                                  List<org.apache.zookeeper.data.ACL> acls,
                                                  ClusterStateContext context)
                                           throws Exception

Throws:

Exception

mkStateStorageImpl

public IStateStorage mkStateStorageImpl(Map config,
                                        Map auth_conf,
                                        List<org.apache.zookeeper.data.ACL> acls,
                                        ClusterStateContext context)
                                 throws Exception

Throws:

Exception

mkStateStorage

public static IStateStorage mkStateStorage(Map config,
                                           Map auth_conf,
                                           List<org.apache.zookeeper.data.ACL> acls,
                                           ClusterStateContext context)
                                    throws Exception

Throws:

Exception

mkStormClusterState

public static IStormClusterState mkStormClusterState(Object StateStorage,
                                                     List<org.apache.zookeeper.data.ACL> acls,
                                                     ClusterStateContext context)
                                              throws Exception

Throws:

Exception

stringifyError

public static String stringifyError(Throwable error)