Package com.linkedin.venice.controller

Class ZkExecutionIdAccessor

java.lang.Object

com.linkedin.venice.controller.ZkExecutionIdAccessor

All Implemented Interfaces:

ExecutionIdAccessor

public class ZkExecutionIdAccessor
extends Object
implements ExecutionIdAccessor

Constructor Summary

Constructors

Constructor	Description
ZkExecutionIdAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient, HelixAdapterSerializer adapterSerializer)

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)	Using AtomicLong here only as a workaround to get next execution id from HelixUtils.compareAndUpdate(ZkBaseDataAccessor, String, int, DataUpdater)
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

ZkExecutionIdAccessor

public ZkExecutionIdAccessor(org.apache.helix.zookeeper.impl.client.ZkClient zkClient,
 HelixAdapterSerializer adapterSerializer)

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

See Also:

• ExecutionIdAccessor.getLastSucceededExecutionId(String)

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

See Also:

• ExecutionIdAccessor.updateLastSucceededExecutionId(String, Long)

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

See Also:

• ExecutionIdAccessor.getLastSucceededExecutionIdMap(String)

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

See Also:

• ExecutionIdAccessor.updateLastSucceededExecutionIdMap(String, String, Long)

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

See Also:

• ExecutionIdAccessor.getLastGeneratedExecutionId(String)

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

See Also:

• ExecutionIdAccessor.updateLastGeneratedExecutionId(String, Long)

incrementAndGetExecutionId

public Long incrementAndGetExecutionId(String clusterName)

Using AtomicLong here only as a workaround to get next execution id from HelixUtils.compareAndUpdate(ZkBaseDataAccessor, String, int, DataUpdater)

Specified by:

incrementAndGetExecutionId in interface ExecutionIdAccessor

Returns:

updated execution id.

Throws:

ZkDataAccessException - will be thrown if it fails to update the data

cleanExecutionIdMap

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

Specified by:

cleanExecutionIdMap in interface ExecutionIdAccessor