Class CountStarIterator

  • All Implemented Interfaces:
    org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>, org.apache.accumulo.core.iterators.YieldingKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>

    public class CountStarIterator
    extends org.apache.accumulo.core.iterators.WrappingIterator
    Implements aggregate function Count(*) over Accumulo
    • Field Summary

      Fields 
      Modifier and Type Field Description
      static String ALIAS  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value> deepCopy​(org.apache.accumulo.core.iterators.IteratorEnvironment env)  
      org.apache.accumulo.core.data.Key getTopKey()  
      org.apache.accumulo.core.data.Value getTopValue()  
      boolean hasTop()  
      void init​(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value> source, Map<String,​String> options, org.apache.accumulo.core.iterators.IteratorEnvironment env)  
      void next()  
      void seek​(org.apache.accumulo.core.data.Range range, Collection<org.apache.accumulo.core.data.ByteSequence> columnFamilies, boolean inclusive)  
      • Methods inherited from class org.apache.accumulo.core.iterators.WrappingIterator

        getSource, setSource
      • Methods inherited from interface org.apache.accumulo.core.iterators.YieldingKeyValueIterator

        enableYielding
    • Constructor Detail

      • CountStarIterator

        public CountStarIterator()
    • Method Detail

      • init

        public void init​(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value> source,
                         Map<String,​String> options,
                         org.apache.accumulo.core.iterators.IteratorEnvironment env)
                  throws IOException
        Specified by:
        init in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>
        Overrides:
        init in class org.apache.accumulo.core.iterators.WrappingIterator
        Throws:
        IOException
      • deepCopy

        public org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value> deepCopy​(org.apache.accumulo.core.iterators.IteratorEnvironment env)
        Specified by:
        deepCopy in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>
        Overrides:
        deepCopy in class org.apache.accumulo.core.iterators.WrappingIterator
      • seek

        public void seek​(org.apache.accumulo.core.data.Range range,
                         Collection<org.apache.accumulo.core.data.ByteSequence> columnFamilies,
                         boolean inclusive)
                  throws IOException
        Specified by:
        seek in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>
        Overrides:
        seek in class org.apache.accumulo.core.iterators.WrappingIterator
        Throws:
        IOException
      • getTopValue

        public org.apache.accumulo.core.data.Value getTopValue()
        Specified by:
        getTopValue in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>
        Overrides:
        getTopValue in class org.apache.accumulo.core.iterators.WrappingIterator
      • getTopKey

        public org.apache.accumulo.core.data.Key getTopKey()
        Specified by:
        getTopKey in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>
        Overrides:
        getTopKey in class org.apache.accumulo.core.iterators.WrappingIterator
      • hasTop

        public boolean hasTop()
        Specified by:
        hasTop in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>
        Overrides:
        hasTop in class org.apache.accumulo.core.iterators.WrappingIterator
      • next

        public void next()
                  throws IOException
        Specified by:
        next in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,​org.apache.accumulo.core.data.Value>
        Overrides:
        next in class org.apache.accumulo.core.iterators.WrappingIterator
        Throws:
        IOException