Class ErroredPartitionManager

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void deleteOldPartitions​(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()  
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • ErroredPartitionManager

        public ErroredPartitionManager()
    • Method Detail

      • initialize

        public void initialize()
                        throws java.lang.Exception
        Specified by:
        initialize in interface PartitionManager
        Throws:
        java.lang.Exception
      • getPartition

        public Partition getPartition​(long time,
                                      long windowSize)
                               throws java.lang.Exception
        Description copied from interface: PartitionManager
        Retrieves the partition that contains the given time, as close to the resolution as possible
        Specified by:
        getPartition in interface PartitionManager
        Throws:
        java.lang.Exception
      • getPartitions

        public java.util.List<Partition> getPartitions​(long start,
                                                       long end,
                                                       long windowSize)
                                                throws java.lang.Exception
        Description copied from interface: PartitionManager
        Returns the partitions that span the given time range, order by start ASC.
        Specified by:
        getPartitions in interface PartitionManager
        Throws:
        java.lang.Exception
      • getOlderPartitions

        public java.util.List<Partition> getOlderPartitions​(long time,
                                                            long windowSize,
                                                            int limit)
                                                     throws java.lang.Exception
        Description copied from interface: PartitionManager
        Retrieves the partitions with data equal to or older than the specified time, sorted DESC (most recent first).
        Specified by:
        getOlderPartitions in interface PartitionManager
        limit - if 0, no limit, otherwise only returns up to that many partitions.
        Throws:
        java.lang.Exception
      • getMostRecentPartitions

        public java.util.List<Partition> getMostRecentPartitions​(int count,
                                                                 long windowSize)
                                                          throws java.lang.Exception
        Description copied from interface: PartitionManager
        Retrieves partitions order by start time desc. Only returns up to the number specified by count.
        Specified by:
        getMostRecentPartitions in interface PartitionManager
        Throws:
        java.lang.Exception
      • deleteOldPartitions

        public void deleteOldPartitions​(long ageMS)
                                 throws java.lang.Exception
        Description copied from interface: PartitionManager
        Deletes any partitions whose end is older than the given age.
        Specified by:
        deleteOldPartitions in interface PartitionManager
        Throws:
        java.lang.Exception