public class FixedSpanPartitionManager extends AbstractDirectorPartitionManager
Constructor and Description |
---|
FixedSpanPartitionManager(GatewayContext context,
java.lang.String datasource,
int driverId) |
FixedSpanPartitionManager(GatewayContext context,
java.lang.String datasource,
int driverId,
long partitionWidth) |
Modifier and Type | Method and Description |
---|---|
protected Partition |
createNewPartition(long startTime,
long window)
Instantiate a new partition object.
|
protected java.lang.String |
getNameFor(Partition p) |
protected boolean |
isValid(Partition partition)
For the fixed span manager, the partition is valid if the name is what we think it should be, based on start
time.
|
createPartitionTable, getNextPartition, getPartition, queryOrCreatePartition
deleteOldParitions, getDatasource, getDriverId, getLogger, getMostRecentPartitions, getOlderPartitions, getPartitions, getQueryCache, initialize, loadPartitionFromDS, loadPartitionsFromDS, partitionExists, runParititionQuery, shutdown
public FixedSpanPartitionManager(GatewayContext context, java.lang.String datasource, int driverId, long partitionWidth)
public FixedSpanPartitionManager(GatewayContext context, java.lang.String datasource, int driverId)
protected java.lang.String getNameFor(Partition p)
protected boolean isValid(Partition partition)
isValid
in class AbstractDirectorPartitionManager
protected Partition createNewPartition(long startTime, long window)
AbstractDirectorPartitionManager
createNewPartition
in class AbstractDirectorPartitionManager