software.amazon.kinesis.coordinator.streamInfo

Class StreamIdCache

java.lang.Object

software.amazon.kinesis.coordinator.streamInfo.StreamIdCache

public class StreamIdCache
extends Object

Method Summary

Modifier and Type	Method and Description
static String	get() This method returns streamId for single stream KCL.
static String	get(StreamIdentifier streamIdentifier) Gets the stream ID for the given stream name.
static StreamIdCache	getInstance()
static void	initialize(StreamIdCacheManager cacheManager, StreamIdOnboardingState onboardingState)

Methods inherited from class java.lang.Object

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

Method Detail

initialize

public static void initialize(StreamIdCacheManager cacheManager,
                              StreamIdOnboardingState onboardingState)

getInstance

public static StreamIdCache getInstance()

get

public static String get()

This method returns streamId for single stream KCL. If streamId is not onboarded, it returns null. If streamId is not found, it returns null. If KCL app is multi-stream mode then there is no way to find the streamId for the given stream, so it returns exception

Returns:

streamId or exception

get

public static String get(StreamIdentifier streamIdentifier)

Gets the stream ID for the given stream name. Returns null if: - Mode is DISABLED - Stream ID is not found

Parameters:

streamIdentifier -

Returns:

the stream Id or null