Package org.apache.druid.indexing.overlord.supervisor

Class NoopSupervisorSpec

java.lang.Object

org.apache.druid.indexing.overlord.supervisor.NoopSupervisorSpec

All Implemented Interfaces:

SupervisorSpec

public class NoopSupervisorSpec
extends Object
implements SupervisorSpec

Used as a tombstone marker in the supervisors metadata table to indicate that the supervisor has been removed.

Constructor Summary

Constructors

Constructor	Description
NoopSupervisorSpec(String id, List<String> datasources)
NoopSupervisorSpec(String id, List<String> datasources, Boolean suspended, String type, String source)

Method Summary

Modifier and Type	Method	Description
SupervisorSpec	createRunningSpec()
Supervisor	createSupervisor()	Create a new Supervisor instance.
SupervisorSpec	createSuspendedSpec()
boolean	equals(Object o)
List<String>	getDataSources()
String	getId()	Return a unique id of Supervisor.
Set<ResourceAction>	getInputSourceResources()
String	getSource()	Return source (like stream or topic name) for the supervisor This API is currently used for spec validation in org.apache.druid.indexing.seekablestream.supervisor.SeekableStreamSupervisorSpec and for returning the spec with source in org.apache.druid.indexing.overlord.supervisor.SupervisorResource when the spec is requested with system flag.
String	getType()	This API is only used for informational purposes in org.apache.druid.sql.calcite.schema.SystemSchema.SupervisorsTable
int	hashCode()
boolean	isSuspended()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.indexing.overlord.supervisor.SupervisorSpec

createAutoscaler, merge, validateSpec, validateSpecUpdateTo

Constructor Details

NoopSupervisorSpec

public NoopSupervisorSpec(String id,
 List<String> datasources)

NoopSupervisorSpec

public NoopSupervisorSpec(@Nullable
 String id,
 @Nullable
 List<String> datasources,
 @Nullable
 Boolean suspended,
 @Nullable
 String type,
 @Nullable
 String source)

Method Details

getId

public String getId()

Description copied from interface: SupervisorSpec

Return a unique id of Supervisor.

Specified by:

getId in interface SupervisorSpec

getDataSources

@Nullable
public List<String> getDataSources()

Specified by:

getDataSources in interface SupervisorSpec

isSuspended

public boolean isSuspended()

Specified by:

isSuspended in interface SupervisorSpec

getType

public String getType()

Description copied from interface: SupervisorSpec

This API is only used for informational purposes in org.apache.druid.sql.calcite.schema.SystemSchema.SupervisorsTable

Specified by:

getType in interface SupervisorSpec

Returns:

supervisor type

getInputSourceResources

@Nonnull
public Set<ResourceAction> getInputSourceResources()

Specified by:

getInputSourceResources in interface SupervisorSpec

Returns:

The types of InputSource that the task uses. Empty set is returned if the task does not use any. Users can be given permission to access particular types of input sources but not others, using the AuthConfig.enableInputSourceSecurity config.

getSource

public String getSource()

Description copied from interface: SupervisorSpec

Return source (like stream or topic name) for the supervisor This API is currently used for spec validation in org.apache.druid.indexing.seekablestream.supervisor.SeekableStreamSupervisorSpec and for returning the spec with source in org.apache.druid.indexing.overlord.supervisor.SupervisorResource when the spec is requested with system flag.

Specified by:

getSource in interface SupervisorSpec

Returns:

source

createSupervisor

public Supervisor createSupervisor()

Description copied from interface: SupervisorSpec

Create a new Supervisor instance.

Specified by:

createSupervisor in interface SupervisorSpec

createRunningSpec

public SupervisorSpec createRunningSpec()

Specified by:

createRunningSpec in interface SupervisorSpec

createSuspendedSpec

public SupervisorSpec createSuspendedSpec()

Specified by:

createSuspendedSpec in interface SupervisorSpec

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object