io.druid.indexing.overlord.supervisor

Class SupervisorManager

java.lang.Object

io.druid.indexing.overlord.supervisor.SupervisorManager

public class SupervisorManager
extends Object

Manages the creation and lifetime of Supervisor.

Constructor Summary

Constructors

Constructor and Description
SupervisorManager(MetadataSupervisorManager metadataSupervisorManager)

Method Summary

Modifier and Type	Method and Description
boolean	checkPointDataSourceMetadata(String supervisorId, String sequenceName, DataSourceMetadata previousDataSourceMetadata, DataSourceMetadata currentDataSourceMetadata)
boolean	createOrUpdateAndStartSupervisor(SupervisorSpec spec)
Map<String,List<VersionedSupervisorSpec>>	getSupervisorHistory()
Set<String>	getSupervisorIds()
com.google.common.base.Optional<SupervisorSpec>	getSupervisorSpec(String id)
com.google.common.base.Optional<SupervisorReport>	getSupervisorStatus(String id)
boolean	resetSupervisor(String id, DataSourceMetadata dataSourceMetadata)
void	start()
void	stop()
boolean	stopAndRemoveSupervisor(String id)

Methods inherited from class java.lang.Object

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

Constructor Detail

SupervisorManager

@Inject
public SupervisorManager(MetadataSupervisorManager metadataSupervisorManager)

Method Detail

getSupervisorIds

public Set<String> getSupervisorIds()

getSupervisorSpec

public com.google.common.base.Optional<SupervisorSpec> getSupervisorSpec(String id)

createOrUpdateAndStartSupervisor

public boolean createOrUpdateAndStartSupervisor(SupervisorSpec spec)

stopAndRemoveSupervisor

public boolean stopAndRemoveSupervisor(String id)

start

public void start()

stop

public void stop()

getSupervisorHistory

public Map<String,List<VersionedSupervisorSpec>> getSupervisorHistory()

getSupervisorStatus

public com.google.common.base.Optional<SupervisorReport> getSupervisorStatus(String id)

resetSupervisor

public boolean resetSupervisor(String id,
                               @Nullable
                               DataSourceMetadata dataSourceMetadata)

checkPointDataSourceMetadata

public boolean checkPointDataSourceMetadata(String supervisorId,
                                            @Nullable
                                            String sequenceName,
                                            @Nullable
                                            DataSourceMetadata previousDataSourceMetadata,
                                            @Nullable
                                            DataSourceMetadata currentDataSourceMetadata)