Package com.linkedin.venice.controller.kafka.consumer

Class AdminExecutionTask

java.lang.Object

com.linkedin.venice.controller.kafka.consumer.AdminExecutionTask

All Implemented Interfaces:

Callable<Void>

public class AdminExecutionTask
extends Object
implements Callable<Void>

This class is used to create Callable that execute AdminOperations for a given store.

Method Summary

Modifier and Type	Method	Description
Void	call()
void	taskOnFinish(String storeName)	Decrement the number of threads processing admin messages for the same store in parallel.
void	taskOnStart(String storeName)	Record the number of threads processing admin messages for the same store in parallel.

Methods inherited from class java.lang.Object

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

Method Details

call

public Void call()

Specified by:

call in interface Callable<Void>

taskOnStart

public void taskOnStart(String storeName)

Record the number of threads processing admin messages for the same store in parallel. If there is more than 1 thread processing admin messages for the same store in parallel, record a violation.

Parameters:

storeName - the name of the store being processed

taskOnFinish

public void taskOnFinish(String storeName)

Decrement the number of threads processing admin messages for the same store in parallel. If the number of threads processing admin messages for the same store reduce to 1, decrease the violation count.

Parameters:

storeName - the name of the store being processed