ds.granules.streaming.core

Class StreamUtil

java.lang.Object

ds.granules.streaming.core.StreamUtil

public class StreamUtil
extends Object

Utility methods used in the streaming package.

Author:

: Thilina Buddhika

Constructor Summary

Constructors

Constructor and Description
StreamUtil()

Method Summary

Methods

Modifier and Type	Method and Description
static String	getInstanceIdentifier(String groupName) Returns an instance identifier when creating a group of objects of the same type but used as a cluster E.g.: Multiple instances of a Stream Processor can be named as processor-1, processor-2, etc.
static String	getStreamIdFromFullQualifiedId(String id) Returns the stream id from the full qualified identifier by removing the instance identifier and dataset identifier

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamUtil

public StreamUtil()

Method Detail

getInstanceIdentifier

public static String getInstanceIdentifier(String groupName)

Returns an instance identifier when creating a group of objects of the same type but used as a cluster E.g.: Multiple instances of a Stream Processor can be named as processor-1, processor-2, etc.

Parameters:

groupName - Group Name

Returns:

Instance Identifier generated by groupName + "-" + numeric identifier

getStreamIdFromFullQualifiedId

public static String getStreamIdFromFullQualifiedId(String id)

Returns the stream id from the full qualified identifier by removing the instance identifier and dataset identifier

Parameters:

id - Full Qualified Stream Identifier

Returns:

Stream Identifier