Package com.linkedin.davinci.helix

Class LeaderFollowerPartitionStateModelDualPoolFactory

java.lang.Object

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

com.linkedin.davinci.helix.AbstractStateModelFactory

com.linkedin.davinci.helix.LeaderFollowerPartitionStateModelFactory

com.linkedin.davinci.helix.LeaderFollowerPartitionStateModelDualPoolFactory

public class LeaderFollowerPartitionStateModelDualPoolFactory
extends LeaderFollowerPartitionStateModelFactory

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.davinci.helix.LeaderFollowerPartitionStateModelFactory

LeaderFollowerPartitionStateModelFactory.LeaderFollowerThreadPoolStrategy

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

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

Field Summary

Fields inherited from class com.linkedin.davinci.helix.AbstractStateModelFactory

executorService, instanceName, logger, partitionPushStatusAccessorFuture, stateTransitionStats, storeMetadataRepo

Constructor Summary

Constructors

Constructor

Description

LeaderFollowerPartitionStateModelDualPoolFactory(IngestionBackend ingestionBackend, VeniceConfigLoader configService, ExecutorService executorService, ParticipantStateTransitionStats stateTransitionStats, ExecutorService futureVersionExecutorService, ParticipantStateTransitionStats futureVersionStateTransitionStats, ReadOnlyStoreRepository metadataRepo, CompletableFuture<HelixPartitionStatusAccessor> partitionPushStatusAccessorFuture, String instanceName, HeartbeatMonitoringService heartbeatMonitoringService)

Method Summary

Modifier and Type	Method	Description
ExecutorService	getExecutorService(String resourceName)
ParticipantStateTransitionStats	getStateTransitionStats(String resourceName)	Use the right state transition stats for the resource.
void	shutDownExecutor()
void	waitExecutorTermination(long timeout, TimeUnit unit)

Methods inherited from class com.linkedin.davinci.helix.LeaderFollowerPartitionStateModelFactory

createNewStateModel

Methods inherited from class com.linkedin.davinci.helix.AbstractStateModelFactory

getConfigService, getIngestionBackend, getStateModelID, getStoreMetadataRepo

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

Constructor Details

LeaderFollowerPartitionStateModelDualPoolFactory

public LeaderFollowerPartitionStateModelDualPoolFactory(IngestionBackend ingestionBackend,
 VeniceConfigLoader configService,
 ExecutorService executorService,
 ParticipantStateTransitionStats stateTransitionStats,
 ExecutorService futureVersionExecutorService,
 ParticipantStateTransitionStats futureVersionStateTransitionStats,
 ReadOnlyStoreRepository metadataRepo,
 CompletableFuture<HelixPartitionStatusAccessor> partitionPushStatusAccessorFuture,
 String instanceName,
 HeartbeatMonitoringService heartbeatMonitoringService)

Method Details

getExecutorService

public ExecutorService getExecutorService(String resourceName)

Overrides:

getExecutorService in class AbstractStateModelFactory

getStateTransitionStats

public ParticipantStateTransitionStats getStateTransitionStats(String resourceName)

Description copied from class: AbstractStateModelFactory

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.

Overrides:

getStateTransitionStats in class AbstractStateModelFactory

shutDownExecutor

public void shutDownExecutor()

Overrides:

shutDownExecutor in class AbstractStateModelFactory

waitExecutorTermination

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

Overrides:

waitExecutorTermination in class AbstractStateModelFactory

Throws:

InterruptedException