Package com.linkedin.venice.controller.logcompaction

Class LogCompactionService

java.lang.Object

com.linkedin.venice.service.AbstractVeniceService

com.linkedin.venice.controller.logcompaction.LogCompactionService

All Implemented Interfaces:

Closeable, AutoCloseable

public class LogCompactionService
extends AbstractVeniceService

This service is in charge of scheduling periodic log compaction & utilising VeniceHelixAdmin to trigger log compaction. The service runs in child controllers & initialised in VeniceController. Workflow: 1. schedules LogCompactionService.LogCompactionTask periodically to perform log compaction for all stores in the cluster controlled by the VeniceController instance that runs this LogCompactionService instance 2. checks for stores that are ready for log compaction with function VeniceHelixAdmin.getStoresForCompaction(String) 3. triggers compaction for each store with function VeniceHelixAdmin.repushStore(RepushJobRequest) See CompactionManager for the logic to determine if a store is ready for compaction

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	PRE_EXECUTION_DELAY_MS

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

logger, serviceState

Constructor Summary

Constructors

Constructor	Description
LogCompactionService(Admin admin, String clusterName, VeniceControllerClusterConfig clusterConfigs)

Method Summary

Modifier and Type	Method	Description
boolean	startInner()
void	stopInner()

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

PRE_EXECUTION_DELAY_MS

public static final int PRE_EXECUTION_DELAY_MS

See Also:

• Constant Field Values

Constructor Details

LogCompactionService

public LogCompactionService(Admin admin,
 String clusterName,
 VeniceControllerClusterConfig clusterConfigs)

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