public interface PartitionManager
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() |
void initialize() throws java.lang.Exception
java.lang.Exception
void shutdown()
Partition getPartition(long time, long windowSize) throws java.lang.Exception
time
- java.lang.Exception
java.util.List<Partition> getPartitions(long start, long end, long windowSize) throws java.lang.Exception
start
- end
- java.lang.Exception
java.util.List<Partition> getOlderPartitions(long time, long windowSize, int limit) throws java.lang.Exception
time
- limit
- if 0, no limit, otherwise only returns up to that many partitions.java.lang.Exception
java.util.List<Partition> getMostRecentPartitions(int count, long windowSize) throws java.lang.Exception
count
- java.lang.Exception
void deleteOldParitions(long ageMS) throws java.lang.Exception
ageMS
- java.lang.Exception