org.apache.druid.indexing.overlord.supervisor

Interface Supervisor

public interface Supervisor

Method Summary

Modifier and Type	Method and Description
void	checkpoint(Integer taskGroupId, String baseSequenceName, DataSourceMetadata previousCheckPoint, DataSourceMetadata currentCheckPoint) The definition of checkpoint is not very strict as currently it does not affect data or control path.
default Map<String,Map<String,Object>>	getStats()
SupervisorReport	getStatus()
void	reset(DataSourceMetadata dataSourceMetadata)
void	start()
void	stop(boolean stopGracefully)

Method Detail

start

void start()

stop

void stop(boolean stopGracefully)

Parameters:

stopGracefully - If true, supervisor will cleanly shutdown managed tasks if possible (for example signalling them to publish their segments and exit). The implementation may block until the tasks have either acknowledged or completed. If false, supervisor will stop immediately and leave any running tasks as they are.

getStatus

SupervisorReport getStatus()

getStats

default Map<String,Map<String,Object>> getStats()

reset

void reset(DataSourceMetadata dataSourceMetadata)

checkpoint

void checkpoint(@Nullable
                Integer taskGroupId,
                @Deprecated
                String baseSequenceName,
                DataSourceMetadata previousCheckPoint,
                DataSourceMetadata currentCheckPoint)

The definition of checkpoint is not very strict as currently it does not affect data or control path. On this call Supervisor can potentially checkpoint data processed so far to some durable storage for example - Kafka Supervisor uses this to merge and handoff segments containing at least the data represented by DataSourceMetadata

Parameters:

taskGroupId - unique Identifier to figure out for which sequence to do checkpointing

baseSequenceName - baseSequenceName

previousCheckPoint - DataSourceMetadata checkpointed in previous call

currentCheckPoint - current DataSourceMetadata to be checkpointed