public class MonthlyParitionManager extends AbstractDirectorPartitionManager
Constructor and Description |
---|
MonthlyParitionManager(GatewayContext context,
java.lang.String datasource,
int driverId) |
Modifier and Type | Method and Description |
---|---|
protected Partition |
createNewPartition(long startTime,
long window)
Instantiate a new partition object.
|
protected boolean |
isValid(Partition partition)
The monthly manager expects the partition to be the appropriate name for the current block.
|
createPartitionTable, getNextPartition, getPartition, queryOrCreatePartition
deleteOldParitions, getDatasource, getDriverId, getLogger, getMostRecentPartitions, getOlderPartitions, getPartitions, getQueryCache, initialize, loadPartitionFromDS, loadPartitionsFromDS, partitionExists, runParititionQuery, shutdown
public MonthlyParitionManager(GatewayContext context, java.lang.String datasource, int driverId)
protected boolean isValid(Partition partition)
isValid
in class AbstractDirectorPartitionManager
protected Partition createNewPartition(long startTime, long window)
AbstractDirectorPartitionManager
createNewPartition
in class AbstractDirectorPartitionManager