public abstract class AbstractDirectorPartitionManager extends BasicDatasourcePartitionManager
TODO (1) Finish the idea of the "next" partition being created ahead of time asynchronously, so that we don't have to wait
Constructor and Description |
---|
AbstractDirectorPartitionManager(GatewayContext context,
java.lang.String dsName,
int driverId) |
Modifier and Type | Method and Description |
---|---|
protected abstract Partition |
createNewPartition(long startTime,
long windowSize)
Instantiate a new partition object.
|
protected void |
createPartitionTable(java.lang.String name,
SRConnection conn,
boolean includeVType) |
protected Partition |
getNextPartition(SRConnection conn,
long time,
long windowSize) |
Partition |
getPartition(long time,
long windowSize)
Gets the name of the partition (and creates the partition, if necessary).
|
protected abstract boolean |
isValid(Partition parition)
Returns whether the given partition, which is the one loaded from the db, fits our expectations.
|
protected Partition |
queryOrCreatePartition(long time,
long windowSize) |
deleteOldParitions, getDatasource, getDriverId, getLogger, getMostRecentPartitions, getOlderPartitions, getPartitions, getQueryCache, initialize, loadPartitionFromDS, loadPartitionsFromDS, partitionExists, runParititionQuery, shutdown
public AbstractDirectorPartitionManager(GatewayContext context, java.lang.String dsName, int driverId)
protected abstract boolean isValid(Partition parition)
protected abstract Partition createNewPartition(long startTime, long windowSize)
public Partition getPartition(long time, long windowSize) throws java.lang.Exception
getPartition
in interface PartitionManager
getPartition
in class BasicDatasourcePartitionManager
java.lang.Exception
protected Partition queryOrCreatePartition(long time, long windowSize) throws java.lang.Exception
java.lang.Exception
protected Partition getNextPartition(SRConnection conn, long time, long windowSize) throws java.lang.Exception
java.lang.Exception
protected void createPartitionTable(java.lang.String name, SRConnection conn, boolean includeVType) throws java.lang.Exception
java.lang.Exception