Package io.split.engine.common

Class ConsumerSynchronizer

java.lang.Object

io.split.engine.common.ConsumerSynchronizer

All Implemented Interfaces:

Synchronizer

public class ConsumerSynchronizer
extends Object
implements Synchronizer

Constructor Summary

Constructors

Constructor	Description
ConsumerSynchronizer(SplitTasks splitTasks)

Method Summary

Modifier and Type	Method	Description
void	forceRefreshSegment(String segmentName)
void	localKillSplit(SplitKillNotification splitKillNotification)
void	refreshSegment(String segmentName, Long targetChangeNumber)
void	refreshSplits(Long targetChangeNumber, Long ruleBasedSegmentChangeNumber)
void	startPeriodicDataRecording()
void	startPeriodicFetching()
void	stopPeriodicDataRecording()
void	stopPeriodicFetching()
boolean	syncAll()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerSynchronizer

public ConsumerSynchronizer(SplitTasks splitTasks)

Method Detail

syncAll

public boolean syncAll()

Specified by:

syncAll in interface Synchronizer

startPeriodicFetching

public void startPeriodicFetching()

Specified by:

startPeriodicFetching in interface Synchronizer

stopPeriodicFetching

public void stopPeriodicFetching()

Specified by:

stopPeriodicFetching in interface Synchronizer

refreshSplits

public void refreshSplits(Long targetChangeNumber,
                          Long ruleBasedSegmentChangeNumber)

Specified by:

refreshSplits in interface Synchronizer

localKillSplit

public void localKillSplit(SplitKillNotification splitKillNotification)

Specified by:

localKillSplit in interface Synchronizer

refreshSegment

public void refreshSegment(String segmentName,
                           Long targetChangeNumber)

Specified by:

refreshSegment in interface Synchronizer

startPeriodicDataRecording

public void startPeriodicDataRecording()

Specified by:

startPeriodicDataRecording in interface Synchronizer

stopPeriodicDataRecording

public void stopPeriodicDataRecording()

Specified by:

stopPeriodicDataRecording in interface Synchronizer

forceRefreshSegment

public void forceRefreshSegment(String segmentName)

Specified by:

forceRefreshSegment in interface Synchronizer