public class ErroredPartitionManager extends java.lang.Object implements PartitionManager
Constructor and Description |
---|
ErroredPartitionManager() |
Modifier and Type | Method and Description |
---|---|
void |
deleteOldParitions(long ageMS)
Deletes any partitions whose end is older than the given age.
|
java.util.List<Partition> |
getMostRecentPartitions(int count,
long windowSize)
Retrieves partitions order by start time desc.
|
java.util.List<Partition> |
getOlderPartitions(long time,
long windowSize,
int limit)
Retrieves the partitions with data equal to or older than the specified time, sorted DESC (most recent first).
|
Partition |
getPartition(long time,
long windowSize)
Retrieves the partition that contains the given time, as close to the resolution as possible
|
java.util.List<Partition> |
getPartitions(long start,
long end,
long windowSize)
Returns the partitions that span the given time range, order by start ASC.
|
void |
initialize() |
void |
shutdown() |
public void initialize() throws java.lang.Exception
initialize
in interface PartitionManager
java.lang.Exception
public void shutdown()
shutdown
in interface PartitionManager
public Partition getPartition(long time, long windowSize) throws java.lang.Exception
PartitionManager
getPartition
in interface PartitionManager
java.lang.Exception
public java.util.List<Partition> getPartitions(long start, long end, long windowSize) throws java.lang.Exception
PartitionManager
getPartitions
in interface PartitionManager
java.lang.Exception
public java.util.List<Partition> getOlderPartitions(long time, long windowSize, int limit) throws java.lang.Exception
PartitionManager
getOlderPartitions
in interface PartitionManager
limit
- if 0, no limit, otherwise only returns up to that many partitions.java.lang.Exception
public java.util.List<Partition> getMostRecentPartitions(int count, long windowSize) throws java.lang.Exception
PartitionManager
getMostRecentPartitions
in interface PartitionManager
java.lang.Exception
public void deleteOldParitions(long ageMS) throws java.lang.Exception
PartitionManager
deleteOldParitions
in interface PartitionManager
java.lang.Exception