io.druid.metadata

Class SQLMetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

java.lang.Object

io.druid.metadata.SQLMetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

All Implemented Interfaces:

MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

public class SQLMetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>
extends Object
implements MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addLock(String entryId, LockType lock) Add a lock to the given entry
boolean	addLog(String entryId, LogType log) Add a log to the entry with the given id.
List<com.metamx.common.Pair<EntryType,StatusType>>	getActiveEntriesWithStatus() Return all active entries with their respective status
com.google.common.base.Optional<EntryType>	getEntry(String entryId) Retrieves the entry with the given id.
List<StatusType>	getInactiveStatusesSince(org.joda.time.DateTime timestamp) Return all statuses for inactive entries created on or later than the given timestamp
Map<Long,LockType>	getLocks(String entryId) Returns the locks for the given entry
List<LogType>	getLogs(String entryId) Returns the logs for the entry with the given id.
com.google.common.base.Optional<StatusType>	getStatus(String entryId) Retrieve the status for the entry with the given id.
void	insert(String id, org.joda.time.DateTime timestamp, String dataSource, EntryType entry, boolean active, StatusType status) Creates a new entry.
boolean	removeLock(long lockId) Remove the lock with the given lock id.
boolean	setStatus(String entryId, boolean active, StatusType status) Sets or updates the status for any active entry with the given id.
protected boolean	shouldRetryException(Throwable e)

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,
                               MetadataStorageActionHandlerTypes<EntryType,StatusType,LogType,LockType> types,
                               String entryTypeName,
                               String entryTable,
                               String logTable,
                               String lockTable)

Method Detail

insert

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

Description copied from interface: MetadataStorageActionHandler

Creates a new entry.

Specified by:

insert in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

id - entry id

timestamp - timestamp this entry was created

dataSource - datasource associated with this entry

entry - object representing this entry

active - active or inactive flag

status - status object associated wit this object, can be null

Throws:

EntryExistsException

setStatus

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

Description copied from interface: MetadataStorageActionHandler

Sets or updates the status for any active entry with the given id. Once an entry has been set inactive, its status cannot be updated anymore.

Specified by:

setStatus in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

entryId - entry id

active - active

status - status

Returns:

true if the status was updated, false if the entry did not exist of if the entry was inactive

getEntry

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

Description copied from interface: MetadataStorageActionHandler

Retrieves the entry with the given id.

Specified by:

getEntry in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

entryId - entry id

Returns:

optional entry, absent if the given id does not exist

getStatus

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

Description copied from interface: MetadataStorageActionHandler

Retrieve the status for the entry with the given id.

Specified by:

getStatus in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

entryId - entry id

Returns:

optional status, absent if entry does not exist or status is not set

getActiveEntriesWithStatus

public List<com.metamx.common.Pair<EntryType,StatusType>> getActiveEntriesWithStatus()

Description copied from interface: MetadataStorageActionHandler

Return all active entries with their respective status

Specified by:

getActiveEntriesWithStatus in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Returns:

list of (entry, status) pairs

getInactiveStatusesSince

public List<StatusType> getInactiveStatusesSince(org.joda.time.DateTime timestamp)

Description copied from interface: MetadataStorageActionHandler

Return all statuses for inactive entries created on or later than the given timestamp

Specified by:

getInactiveStatusesSince in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

timestamp - timestamp

Returns:

list of statuses

addLock

public boolean addLock(String entryId,
              LockType lock)

Description copied from interface: MetadataStorageActionHandler

Add a lock to the given entry

Specified by:

addLock in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

entryId - entry id

lock - lock to add

Returns:

true if the lock was added

removeLock

public boolean removeLock(long lockId)

Description copied from interface: MetadataStorageActionHandler

Remove the lock with the given lock id.

Specified by:

removeLock in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

lockId - lock id

Returns:

true if the lock was removed, false if the given lock id did not exist

addLog

public boolean addLog(String entryId,
             LogType log)

Description copied from interface: MetadataStorageActionHandler

Add a log to the entry with the given id.

Specified by:

addLog in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

entryId - entry id

log - log to add

Returns:

true if the log was added

getLogs

public List<LogType> getLogs(String entryId)

Description copied from interface: MetadataStorageActionHandler

Returns the logs for the entry with the given id.

Specified by:

getLogs in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

entryId - entry id

Returns:

list of logs

getLocks

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

Description copied from interface: MetadataStorageActionHandler

Returns the locks for the given entry

Specified by:

getLocks in interface MetadataStorageActionHandler<EntryType,StatusType,LogType,LockType>

Parameters:

entryId - entry id

Returns:

map of lockId to lock

shouldRetryException

protected boolean shouldRetryException(Throwable e)