Package io.split.engine.segments

Class SegmentSynchronizationTaskImp

java.lang.Object

io.split.engine.segments.SegmentSynchronizationTaskImp

All Implemented Interfaces:

SyncTask, SegmentSynchronizationTask, Closeable, AutoCloseable

public class SegmentSynchronizationTaskImp
extends Object
implements SegmentSynchronizationTask, Closeable

Constructor Summary

Constructors

Constructor	Description
SegmentSynchronizationTaskImp(SegmentChangeFetcher segmentChangeFetcher, long refreshEveryNSeconds, int numThreads, SegmentCacheProducer segmentCacheProducer, TelemetryRuntimeProducer telemetryRuntimeProducer, SplitCacheConsumer splitCacheConsumer, ThreadFactory threadFactory, RuleBasedSegmentCacheConsumer ruleBasedSegmentCacheConsumer)

Method Summary

Modifier and Type	Method	Description
void	close()
void	fetchAll(boolean addCacheHeader)	fetch every Segment
boolean	fetchAllSynchronous()	fetch every Segment Synchronous
SegmentFetcher	getFetcher(String segmentName)	returns segmentFecther
void	initializeSegment(String segmentName)	initializes the segment
boolean	isRunning()
void	start()	starts the fetching
void	stop()	stops the thread

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentSynchronizationTaskImp

public SegmentSynchronizationTaskImp(SegmentChangeFetcher segmentChangeFetcher,
                                     long refreshEveryNSeconds,
                                     int numThreads,
                                     SegmentCacheProducer segmentCacheProducer,
                                     TelemetryRuntimeProducer telemetryRuntimeProducer,
                                     SplitCacheConsumer splitCacheConsumer,
                                     ThreadFactory threadFactory,
                                     RuleBasedSegmentCacheConsumer ruleBasedSegmentCacheConsumer)

Method Detail

initializeSegment

public void initializeSegment(String segmentName)

Description copied from interface: SegmentSynchronizationTask

initializes the segment

Specified by:

initializeSegment in interface SegmentSynchronizationTask

getFetcher

public SegmentFetcher getFetcher(String segmentName)

Description copied from interface: SegmentSynchronizationTask

returns segmentFecther

Specified by:

getFetcher in interface SegmentSynchronizationTask

Returns:

start

public void start()

Description copied from interface: SegmentSynchronizationTask

starts the fetching

Specified by:

start in interface SegmentSynchronizationTask

Specified by:

start in interface SyncTask

stop

public void stop()

Description copied from interface: SegmentSynchronizationTask

stops the thread

Specified by:

stop in interface SegmentSynchronizationTask

Specified by:

stop in interface SyncTask

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface SegmentSynchronizationTask

Specified by:

close in interface SyncTask

isRunning

public boolean isRunning()

Specified by:

isRunning in interface SyncTask

fetchAll

public void fetchAll(boolean addCacheHeader)

Description copied from interface: SegmentSynchronizationTask

fetch every Segment

Specified by:

fetchAll in interface SegmentSynchronizationTask

fetchAllSynchronous

public boolean fetchAllSynchronous()

Description copied from interface: SegmentSynchronizationTask

fetch every Segment Synchronous

Specified by:

fetchAllSynchronous in interface SegmentSynchronizationTask