org.apache.druid.metadata

Class SQLMetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

java.lang.Object

org.apache.druid.metadata.SQLMetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

All Implemented Interfaces:

org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Direct Known Subclasses:

DerbyMetadataStorageActionHandler, MySQLMetadataStorageActionHandler, PostgreSQLMetadataStorageActionHandler, SQLServerMetadataStorageActionHandler

public abstract class SQLMetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>
extends Object
implements org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Constructor Summary

Constructors

Constructor and Description
SQLMetadataStorageActionHandler(SQLMetadataConnector connector, com.fasterxml.jackson.databind.ObjectMapper jsonMapper, org.apache.druid.metadata.MetadataStorageActionHandlerTypes<EntryType,StatusType,LogType,LockType> types, String entryTypeName, String entryTable, String logTable, String lockTable)

Method Summary

Modifier and Type	Method and Description
boolean	addLock(String entryId, LockType lock)
boolean	addLog(String entryId, LogType log)
protected abstract org.skife.jdbi.v2.Query<Map<String,Object>>	createCompletedTaskInfoQuery(org.skife.jdbi.v2.Handle handle, org.joda.time.DateTime timestamp, Integer maxNumStatuses, String dataSource)
List<org.apache.druid.indexer.TaskInfo<EntryType,StatusType>>	getActiveTaskInfo(String dataSource)
List<org.apache.druid.indexer.TaskInfo<EntryType,StatusType>>	getCompletedTaskInfo(org.joda.time.DateTime timestamp, Integer maxNumStatuses, String dataSource)
protected SQLMetadataConnector	getConnector()
com.google.common.base.Optional<EntryType>	getEntry(String entryId)
protected String	getEntryTable()
com.fasterxml.jackson.core.type.TypeReference	getEntryType()
protected com.fasterxml.jackson.databind.ObjectMapper	getJsonMapper()
Long	getLockId(String entryId, LockType lock)
Map<Long,LockType>	getLocks(String entryId)
List<LogType>	getLogs(String entryId)
com.google.common.base.Optional<StatusType>	getStatus(String entryId)
protected com.fasterxml.jackson.core.type.TypeReference	getStatusType()
org.apache.druid.indexer.TaskInfo<EntryType,StatusType>	getTaskInfo(String entryId)
void	insert(String id, org.joda.time.DateTime timestamp, String dataSource, EntryType entry, boolean active, StatusType status)
protected static boolean	isStatementException(Throwable e)
void	removeLock(long lockId)
boolean	replaceLock(String entryId, long oldLockId, LockType newLock)
boolean	setStatus(String entryId, boolean active, StatusType status)

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLMetadataStorageActionHandler

public SQLMetadataStorageActionHandler(SQLMetadataConnector connector,
                                       com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                                       org.apache.druid.metadata.MetadataStorageActionHandlerTypes<EntryType,StatusType,LogType,LockType> types,
                                       String entryTypeName,
                                       String entryTable,
                                       String logTable,
                                       String lockTable)

Method Detail

getConnector

protected SQLMetadataConnector getConnector()

getJsonMapper

protected com.fasterxml.jackson.databind.ObjectMapper getJsonMapper()

getStatusType

protected com.fasterxml.jackson.core.type.TypeReference getStatusType()

getEntryTable

protected String getEntryTable()

getEntryType

public com.fasterxml.jackson.core.type.TypeReference getEntryType()

insert

public void insert(String id,
                   org.joda.time.DateTime timestamp,
                   String dataSource,
                   EntryType entry,
                   boolean active,
                   StatusType status)
            throws org.apache.druid.metadata.EntryExistsException

Specified by:

insert in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Throws:

org.apache.druid.metadata.EntryExistsException

isStatementException

protected static boolean isStatementException(Throwable e)

setStatus

public boolean setStatus(String entryId,
                         boolean active,
                         StatusType status)

Specified by:

setStatus in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

getEntry

public com.google.common.base.Optional<EntryType> getEntry(String entryId)

Specified by:

getEntry in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

getStatus

public com.google.common.base.Optional<StatusType> getStatus(String entryId)

Specified by:

getStatus in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

getTaskInfo

@Nullable
public org.apache.druid.indexer.TaskInfo<EntryType,StatusType> getTaskInfo(String entryId)

Specified by:

getTaskInfo in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

getCompletedTaskInfo

public List<org.apache.druid.indexer.TaskInfo<EntryType,StatusType>> getCompletedTaskInfo(org.joda.time.DateTime timestamp,
                                                                                          @Nullable
                                                                                          Integer maxNumStatuses,
                                                                                          @Nullable
                                                                                          String dataSource)

Specified by:

getCompletedTaskInfo in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

getActiveTaskInfo

public List<org.apache.druid.indexer.TaskInfo<EntryType,StatusType>> getActiveTaskInfo(@Nullable
                                                                                       String dataSource)

Specified by:

getActiveTaskInfo in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

createCompletedTaskInfoQuery

protected abstract org.skife.jdbi.v2.Query<Map<String,Object>> createCompletedTaskInfoQuery(org.skife.jdbi.v2.Handle handle,
                                                                                            org.joda.time.DateTime timestamp,
                                                                                            @Nullable
                                                                                            Integer maxNumStatuses,
                                                                                            @Nullable
                                                                                            String dataSource)

addLock

public boolean addLock(String entryId,
                       LockType lock)

Specified by:

addLock in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

replaceLock

public boolean replaceLock(String entryId,
                           long oldLockId,
                           LockType newLock)

Specified by:

replaceLock in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

removeLock

public void removeLock(long lockId)

Specified by:

removeLock in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

addLog

public boolean addLog(String entryId,
                      LogType log)

Specified by:

addLog in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

getLogs

public List<LogType> getLogs(String entryId)

Specified by:

getLogs in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

getLocks

public Map<Long,LockType> getLocks(String entryId)

Specified by:

getLocks in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

getLockId

@Nullable
public Long getLockId(String entryId,
                                LockType lock)

Specified by:

getLockId in interface org.apache.druid.metadata.MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>