Package com.linkedin.venice.admin

Class InMemoryExecutionIdAccessor

java.lang.Object

com.linkedin.venice.admin.InMemoryExecutionIdAccessor

All Implemented Interfaces:

ExecutionIdAccessor

public class InMemoryExecutionIdAccessor
extends Object
implements ExecutionIdAccessor

In memory implementation of ExecutionIdAccessor, should only be used for testing purposes.

Constructor Summary

Constructors

Constructor	Description
InMemoryExecutionIdAccessor()

Method Summary

Modifier and Type	Method	Description
Map<String,Long>	cleanExecutionIdMap(String clusterName, Set<String> allStores)
Long	getLastGeneratedExecutionId(String clusterName)	Get the last id which is generated by execution tracker in the give cluster.
Long	getLastSucceededExecutionId(String clusterName)	Get the id for the last succeed operation in the given cluster.
Map<String,Long>	getLastSucceededExecutionIdMap(String clusterName)	Get the execution id map that contains the last succeeded operation in the given cluster for each store.
Long	incrementAndGetExecutionId(String clusterName)	Read the current value from ZK and try to increment the value by 1 and write it back to ZK.
void	setExecutionId(long value)
void	updateLastGeneratedExecutionId(String clusterName, Long lastGeneratedExecutionId)	Update the last id which is generated by execution tracker in the given cluster.
void	updateLastSucceededExecutionId(String clusterName, Long lastSucceedExecutionId)	Update the id of the last succeed operation in the given cluster.
void	updateLastSucceededExecutionIdMap(String clusterName, String storeName, Long lastSucceededExecutionId)	Update the execution id map that contains the last succeeded operation in the given cluster for each store.

Methods inherited from class java.lang.Object

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

Constructor Details

InMemoryExecutionIdAccessor

public InMemoryExecutionIdAccessor()

Method Details

getLastSucceededExecutionId

public Long getLastSucceededExecutionId(String clusterName)

Description copied from interface: ExecutionIdAccessor

Get the id for the last succeed operation in the given cluster.

Specified by:

getLastSucceededExecutionId in interface ExecutionIdAccessor

updateLastSucceededExecutionId

public void updateLastSucceededExecutionId(String clusterName,
 Long lastSucceedExecutionId)

Description copied from interface: ExecutionIdAccessor

Update the id of the last succeed operation in the given cluster.

Specified by:

updateLastSucceededExecutionId in interface ExecutionIdAccessor

getLastSucceededExecutionIdMap

public Map<String,Long> getLastSucceededExecutionIdMap(String clusterName)

Description copied from interface: ExecutionIdAccessor

Get the execution id map that contains the last succeeded operation in the given cluster for each store.

Specified by:

getLastSucceededExecutionIdMap in interface ExecutionIdAccessor

updateLastSucceededExecutionIdMap

public void updateLastSucceededExecutionIdMap(String clusterName,
 String storeName,
 Long lastSucceededExecutionId)

Description copied from interface: ExecutionIdAccessor

Update the execution id map that contains the last succeeded operation in the given cluster for each store.

Specified by:

updateLastSucceededExecutionIdMap in interface ExecutionIdAccessor

getLastGeneratedExecutionId

public Long getLastGeneratedExecutionId(String clusterName)

Description copied from interface: ExecutionIdAccessor

Get the last id which is generated by execution tracker in the give cluster.

Specified by:

getLastGeneratedExecutionId in interface ExecutionIdAccessor

updateLastGeneratedExecutionId

public void updateLastGeneratedExecutionId(String clusterName,
 Long lastGeneratedExecutionId)

Description copied from interface: ExecutionIdAccessor

Update the last id which is generated by execution tracker in the given cluster.

Specified by:

updateLastGeneratedExecutionId in interface ExecutionIdAccessor

cleanExecutionIdMap

public Map<String,Long> cleanExecutionIdMap(String clusterName,
 Set<String> allStores)

Specified by:

cleanExecutionIdMap in interface ExecutionIdAccessor

incrementAndGetExecutionId

public Long incrementAndGetExecutionId(String clusterName)

Description copied from interface: ExecutionIdAccessor

Read the current value from ZK and try to increment the value by 1 and write it back to ZK.

Specified by:

incrementAndGetExecutionId in interface ExecutionIdAccessor

Returns:

updated execution id.

setExecutionId

public void setExecutionId(long value)