Package com.linkedin.davinci.kafka.consumer

Class RemoteIngestionRepairService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.davinci.kafka.consumer.RemoteIngestionRepairService

All Implemented Interfaces:

Closeable, AutoCloseable

public class RemoteIngestionRepairService
extends AbstractVeniceService

Singleton class meant to keep track of subscription failures for ingestion tasks where the ingestion task needs to keep running despite cluster failures. TODO: This class could stand to be refactored into an Actor class, but it seems we're short on time just now, so we're going for old hat to start with AbstractVeniceService.

Nested Class Summary

Nested classes/interfaces inherited from class com.linkedin.venice.service.AbstractVeniceService

AbstractVeniceService.ServiceState

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_REPAIR_THREAD_SLEEP_INTERVAL_SECONDS

Fields inherited from class com.linkedin.venice.service.AbstractVeniceService

logger, serviceState

Constructor Summary

Constructors

Constructor	Description
RemoteIngestionRepairService(int repairThreadSleepInterval)

Method Summary

Modifier and Type	Method	Description
void	registerRepairTask(StoreIngestionTask storeIngestionTask, Runnable repairTask)
boolean	startInner()
void	stopInner()
void	unregisterRepairTasksForStoreIngestionTask(StoreIngestionTask storeIngestionTask)

Methods inherited from class com.linkedin.venice.service.AbstractVeniceService

close, getName, isRunning, start, stop

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_REPAIR_THREAD_SLEEP_INTERVAL_SECONDS

public static final int DEFAULT_REPAIR_THREAD_SLEEP_INTERVAL_SECONDS

See Also:

• Constant Field Values

Constructor Details

RemoteIngestionRepairService

public RemoteIngestionRepairService(int repairThreadSleepInterval)

Method Details

startInner

public boolean startInner()
                   throws Exception

Specified by:

startInner in class AbstractVeniceService

Returns:

true if the service is completely started, false if it is still starting asynchronously (in this case, it is the implementer's responsibility to set AbstractVeniceService.serviceState to AbstractVeniceService.ServiceState.STARTED upon completion of the async work).

Throws:

Exception

stopInner

public void stopInner()
               throws Exception

Specified by:

stopInner in class AbstractVeniceService

Throws:

Exception

registerRepairTask

public void registerRepairTask(StoreIngestionTask storeIngestionTask,
 Runnable repairTask)

unregisterRepairTasksForStoreIngestionTask

public void unregisterRepairTasksForStoreIngestionTask(StoreIngestionTask storeIngestionTask)