Package com.linkedin.davinci.helix

Class AbstractStateModelFactory

java.lang.Object

org.apache.helix.participant.statemachine.StateModelFactory<org.apache.helix.participant.statemachine.StateModel>

com.linkedin.davinci.helix.AbstractStateModelFactory

Direct Known Subclasses:

LeaderFollowerPartitionStateModelFactory

public abstract class AbstractStateModelFactory
extends org.apache.helix.participant.statemachine.StateModelFactory<org.apache.helix.participant.statemachine.StateModel>

ModelFactory manages Helix state model creation. createNewStateModel(String, String) is called every time a new resource is created. Since Helix internal maintains a map between model definition and model factory, each factory could only create 1 type of model.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.helix.participant.statemachine.StateModelFactory

org.apache.helix.participant.statemachine.StateModelFactory.CustomizedExecutorService

Field Summary

Fields

Modifier and Type	Field	Description
protected final ExecutorService	executorService
protected final String	instanceName
protected final org.apache.logging.log4j.Logger	logger
protected CompletableFuture<HelixPartitionStatusAccessor>	partitionPushStatusAccessorFuture
protected final ParticipantStateTransitionStats	stateTransitionStats
protected final ReadOnlyStoreRepository	storeMetadataRepo

Constructor Summary

Constructors

Constructor	Description
AbstractStateModelFactory(IngestionBackend ingestionBackend, VeniceConfigLoader configService, ExecutorService executorService, ParticipantStateTransitionStats stateTransitionStats, ReadOnlyStoreRepository storeMetadataRepo, CompletableFuture<HelixPartitionStatusAccessor> partitionPushStatusAccessorFuture, String instanceName)

Method Summary

Modifier and Type	Method	Description
abstract org.apache.helix.participant.statemachine.StateModel	createNewStateModel(String resourceName, String partitionName)	This method will be invoked only once per partition per session
VeniceConfigLoader	getConfigService()
ExecutorService	getExecutorService(String resourceName)
IngestionBackend	getIngestionBackend()
static String	getStateModelID(String resourceName, int partitionId)
ParticipantStateTransitionStats	getStateTransitionStats(String resourceName)	Use the right state transition stats for the resource.
ReadOnlyStoreRepository	getStoreMetadataRepo()
void	shutDownExecutor()
void	waitExecutorTermination(long timeout, TimeUnit unit)

Methods inherited from class org.apache.helix.participant.statemachine.StateModelFactory

createAndAddBatchMessageWrapper, createAndAddStateModel, createAndAddStateModel, createBatchMessageWrapper, createNewStateModel, getBatchMessageWrapper, getExecutorService, getExecutorService, getPartitionSet, getPartitionSet, getResourceSet, getStateModel, getStateModel, removeStateModel, removeStateModel

Methods inherited from class java.lang.Object

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

Field Details

logger

protected final org.apache.logging.log4j.Logger logger

storeMetadataRepo

protected final ReadOnlyStoreRepository storeMetadataRepo

executorService

protected final ExecutorService executorService

stateTransitionStats

protected final ParticipantStateTransitionStats stateTransitionStats

partitionPushStatusAccessorFuture

protected CompletableFuture<HelixPartitionStatusAccessor> partitionPushStatusAccessorFuture

instanceName

protected final String instanceName

Constructor Details

AbstractStateModelFactory

public AbstractStateModelFactory(IngestionBackend ingestionBackend,
 VeniceConfigLoader configService,
 ExecutorService executorService,
 ParticipantStateTransitionStats stateTransitionStats,
 ReadOnlyStoreRepository storeMetadataRepo,
 CompletableFuture<HelixPartitionStatusAccessor> partitionPushStatusAccessorFuture,
 String instanceName)

Method Details

getExecutorService

public ExecutorService getExecutorService(String resourceName)

Overrides:

getExecutorService in class org.apache.helix.participant.statemachine.StateModelFactory<org.apache.helix.participant.statemachine.StateModel>

getStateTransitionStats

public ParticipantStateTransitionStats getStateTransitionStats(String resourceName)

Use the right state transition stats for the resource. By default, use the regular one; when dual state transition thread pool is enabled, use the future version stats for future version resource.

createNewStateModel

public abstract org.apache.helix.participant.statemachine.StateModel createNewStateModel(String resourceName,
 String partitionName)

This method will be invoked only once per partition per session

Overrides:

createNewStateModel in class org.apache.helix.participant.statemachine.StateModelFactory<org.apache.helix.participant.statemachine.StateModel>

Parameters:

resourceName - $(topic_name) where state transition is happening

partitionName - $(topic_name)_$(partition) for which the State Transition Handler is required

Returns:

VenicePartitionStateModel for the partition.

getConfigService

public VeniceConfigLoader getConfigService()

getStoreMetadataRepo

public ReadOnlyStoreRepository getStoreMetadataRepo()

getIngestionBackend

public IngestionBackend getIngestionBackend()

getStateModelID

public static String getStateModelID(String resourceName,
 int partitionId)

shutDownExecutor

public void shutDownExecutor()

waitExecutorTermination

public void waitExecutorTermination(long timeout,
 TimeUnit unit)
                             throws InterruptedException

Throws:

InterruptedException