Package org.apache.druid.metadata

Class SQLMetadataSupervisorManager

java.lang.Object

org.apache.druid.metadata.SQLMetadataSupervisorManager

All Implemented Interfaces:

MetadataSupervisorManager

public class SQLMetadataSupervisorManager
extends Object
implements MetadataSupervisorManager

Constructor Summary

Constructors

Constructor	Description
SQLMetadataSupervisorManager(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, SQLMetadataConnector connector, com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables)

Method Summary

Modifier and Type	Method	Description
Map<String,List<VersionedSupervisorSpec>>	getAll()
List<VersionedSupervisorSpec>	getAllForId(String id, Integer limit)	Get supervisor history for a given supervisor ID with an optional limit
Map<String,SupervisorSpec>	getLatest()	Return latest supervisors (both active and terminated)
Map<String,SupervisorSpec>	getLatestActiveOnly()	Only return the latest active supervisors
Map<String,SupervisorSpec>	getLatestTerminatedOnly()	Only return the latest terminated supervisors
void	insert(String id, SupervisorSpec spec)
int	removeTerminatedSupervisorsOlderThan(long timestamp)	Remove terminated supervisors created before the given timestamp.
void	start()

Methods inherited from class java.lang.Object

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

Constructor Details

SQLMetadataSupervisorManager

@Inject
public SQLMetadataSupervisorManager(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
 SQLMetadataConnector connector,
 com.google.common.base.Supplier<MetadataStorageTablesConfig> dbTables)

Method Details

start

public void start()

Specified by:

start in interface MetadataSupervisorManager

insert

public void insert(String id,
 SupervisorSpec spec)

Specified by:

insert in interface MetadataSupervisorManager

getAll

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

Specified by:

getAll in interface MetadataSupervisorManager

getAllForId

public List<VersionedSupervisorSpec> getAllForId(String id,
 @Nullable
 Integer limit)
                                          throws IllegalArgumentException

Description copied from interface: MetadataSupervisorManager

Get supervisor history for a given supervisor ID with an optional limit

Specified by:

getAllForId in interface MetadataSupervisorManager

Parameters:

id - the supervisor ID

limit - maximum number of history entries to return (null for all entries)

Returns:

list of versioned supervisor specs for the given ID

Throws:

IllegalArgumentException

getLatest

public Map<String,SupervisorSpec> getLatest()

Description copied from interface: MetadataSupervisorManager

Return latest supervisors (both active and terminated)

Specified by:

getLatest in interface MetadataSupervisorManager

Returns:

latest terminated supervisors

getLatestActiveOnly

public Map<String,SupervisorSpec> getLatestActiveOnly()

Description copied from interface: MetadataSupervisorManager

Only return the latest active supervisors

Specified by:

getLatestActiveOnly in interface MetadataSupervisorManager

Returns:

latest active supervisors

getLatestTerminatedOnly

public Map<String,SupervisorSpec> getLatestTerminatedOnly()

Description copied from interface: MetadataSupervisorManager

Only return the latest terminated supervisors

Specified by:

getLatestTerminatedOnly in interface MetadataSupervisorManager

Returns:

latest terminated supervisors

removeTerminatedSupervisorsOlderThan

public int removeTerminatedSupervisorsOlderThan(long timestamp)

Description copied from interface: MetadataSupervisorManager

Remove terminated supervisors created before the given timestamp.

Specified by:

removeTerminatedSupervisorsOlderThan in interface MetadataSupervisorManager

Parameters:

timestamp - timestamp in milliseconds

Returns:

number of supervisor removed