Package com.linkedin.venice.common

Class PushStatusStoreUtils

java.lang.Object

com.linkedin.venice.common.PushStatusStoreUtils

public class PushStatusStoreUtils
extends Object

Helper class for PushStatusStore related logic.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	PushStatusStoreUtils.PushStatusKeyType

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONTROLLER_HEARTBEAT_INSTANCE_NAME
static final String	ONGOING_INCREMENTAL_PUSH_STATUSES_KEY
static final String	SERVER_INCREMENTAL_PUSH_PREFIX

Constructor Summary

Constructors

Constructor	Description
PushStatusStoreUtils()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Details

SERVER_INCREMENTAL_PUSH_PREFIX

public static final String SERVER_INCREMENTAL_PUSH_PREFIX

See Also:

• Constant Field Values

ONGOING_INCREMENTAL_PUSH_STATUSES_KEY

public static final String ONGOING_INCREMENTAL_PUSH_STATUSES_KEY

See Also:

• Constant Field Values

CONTROLLER_HEARTBEAT_INSTANCE_NAME

public static final String CONTROLLER_HEARTBEAT_INSTANCE_NAME

See Also:

• Constant Field Values

Constructor Details

PushStatusStoreUtils

public PushStatusStoreUtils()

Method Details

getHeartbeatKey

public static PushStatusKey getHeartbeatKey(String instanceName)

getPushKey

public static PushStatusKey getPushKey(int version)

getPushKey

public static PushStatusKey getPushKey(int version,
 Optional<String> incrementalPushVersion)

getPushKey

public static PushStatusKey getPushKey(int version,
 int partitionId,
 Optional<String> incrementalPushVersion)

getPushKey

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

getServerIncrementalPushKey

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

getOngoingIncrementalPushStatusesKey

public static PushStatusKey getOngoingIncrementalPushStatusesKey(int version)

getPartitionIdFromServerIncrementalPushKey

public static int getPartitionIdFromServerIncrementalPushKey(PushStatusKey key)