Package com.linkedin.venice.common

Class PushStatusStoreUtils

java.lang.Object

com.linkedin.venice.common.PushStatusStoreUtils

public class PushStatusStoreUtils
extends java.lang.Object

Helper class for PushStatusStore related logic.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PushStatusStoreUtils.PushStatusKeyType

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	CONTROLLER_HEARTBEAT_INSTANCE_NAME
static java.lang.String	ONGOING_INCREMENTAL_PUSH_STATUSES_KEY
static java.lang.String	SERVER_INCREMENTAL_PUSH_PREFIX

Constructor Summary

Constructors

Constructor	Description
PushStatusStoreUtils()

Method Summary

Modifier and Type	Method	Description
static PushStatusKey	getHeartbeatKey(java.lang.String instanceName)
static PushStatusKey	getOngoingIncrementalPushStatusesKey(int version)
static int	getPartitionIdFromServerIncrementalPushKey(PushStatusKey key)
static PushStatusKey	getPushKey(int version)
static PushStatusKey	getPushKey(int version, int partitionId, java.util.Optional<java.lang.String> incrementalPushVersion)
static PushStatusKey	getPushKey(int version, int partitionId, java.util.Optional<java.lang.String> incrementalPushVersion, java.util.Optional<java.lang.String> incrementalPushPrefix)
static PushStatusKey	getServerIncrementalPushKey(int version, int partitionId, java.lang.String incrementalPushVersion, java.lang.String incrementalPushPrefix)

Methods inherited from class java.lang.Object

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

Field Detail

SERVER_INCREMENTAL_PUSH_PREFIX

public static final java.lang.String SERVER_INCREMENTAL_PUSH_PREFIX

See Also:

Constant Field Values

ONGOING_INCREMENTAL_PUSH_STATUSES_KEY

public static final java.lang.String ONGOING_INCREMENTAL_PUSH_STATUSES_KEY

See Also:

Constant Field Values

CONTROLLER_HEARTBEAT_INSTANCE_NAME

public static final java.lang.String CONTROLLER_HEARTBEAT_INSTANCE_NAME

See Also:

Constant Field Values

Constructor Detail

PushStatusStoreUtils

public PushStatusStoreUtils()

Method Detail

getHeartbeatKey

public static PushStatusKey getHeartbeatKey(java.lang.String instanceName)

getPushKey

public static PushStatusKey getPushKey(int version)

getPushKey

public static PushStatusKey getPushKey(int version,
                                       int partitionId,
                                       java.util.Optional<java.lang.String> incrementalPushVersion)

getPushKey

public static PushStatusKey getPushKey(int version,
                                       int partitionId,
                                       java.util.Optional<java.lang.String> incrementalPushVersion,
                                       java.util.Optional<java.lang.String> incrementalPushPrefix)

getServerIncrementalPushKey

public static PushStatusKey getServerIncrementalPushKey(int version,
                                                        int partitionId,
                                                        java.lang.String incrementalPushVersion,
                                                        java.lang.String incrementalPushPrefix)

getOngoingIncrementalPushStatusesKey

public static PushStatusKey getOngoingIncrementalPushStatusesKey(int version)

getPartitionIdFromServerIncrementalPushKey

public static int getPartitionIdFromServerIncrementalPushKey(PushStatusKey key)