Package uk.gov.gchq.gaffer.accumulostore.key.impl

Class RowIDAggregator

  • All Implemented Interfaces:
    org.apache.accumulo.core.iterators.OptionDescriber, 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 RowIDAggregator
extends org.apache.accumulo.core.iterators.WrappingIterator
implements org.apache.accumulo.core.iterators.OptionDescriber

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      static class  RowIDAggregator.PropertiesIterator  

      • Nested classes/interfaces inherited from interface org.apache.accumulo.core.iterators.OptionDescriber

        org.apache.accumulo.core.iterators.OptionDescriber.IteratorOptions

    • Constructor Summary

      Constructors 
      Constructor Description
      RowIDAggregator()  

    • 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.iterators.OptionDescriber.IteratorOptions describeOptions()  
      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)  
      boolean validateOptions​(Map<String,​String> options)  

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

        enableYielding

    • Constructor Detail

      • RowIDAggregator

        public RowIDAggregator()

    • Method Detail

      • describeOptions

        public org.apache.accumulo.core.iterators.OptionDescriber.IteratorOptions describeOptions()
        Specified by:
        describeOptions in interface org.apache.accumulo.core.iterators.OptionDescriber

      • validateOptions

        public boolean validateOptions​(Map<String,​String> options)
        Specified by:
        validateOptions in interface org.apache.accumulo.core.iterators.OptionDescriber

      • 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

      • 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

      • 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

      • 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

      • 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

      • 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

      • 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