io.druid.db

Class DatabaseSegmentManager

java.lang.Object

io.druid.db.DatabaseSegmentManager

public class DatabaseSegmentManager
extends Object

Constructor Summary

Constructors

Constructor and Description
DatabaseSegmentManager(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, com.google.common.base.Supplier<DatabaseSegmentManagerConfig> config, com.google.common.base.Supplier<DbTablesConfig> dbTables, org.skife.jdbi.v2.IDBI dbi)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	enableDatasource(String ds)
boolean	enableSegment(String segmentId)
Collection<String>	getAllDatasourceNames()
Collection<DruidDataSource>	getInventory()
DruidDataSource	getInventoryValue(String key)
boolean	isStarted()
void	poll()
boolean	removeDatasource(String ds)
boolean	removeSegment(String ds, String segmentID)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseSegmentManager

@Inject
public DatabaseSegmentManager(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                             com.google.common.base.Supplier<DatabaseSegmentManagerConfig> config,
                             com.google.common.base.Supplier<DbTablesConfig> dbTables,
                             org.skife.jdbi.v2.IDBI dbi)

Method Detail

start

public void start()

stop

public void stop()

enableDatasource

public boolean enableDatasource(String ds)

enableSegment

public boolean enableSegment(String segmentId)

removeDatasource

public boolean removeDatasource(String ds)

removeSegment

public boolean removeSegment(String ds,
                    String segmentID)

isStarted

public boolean isStarted()

getInventoryValue

public DruidDataSource getInventoryValue(String key)

getInventory

public Collection<DruidDataSource> getInventory()

getAllDatasourceNames

public Collection<String> getAllDatasourceNames()

poll

public void poll()