org.locationtech.geowave.datastore.accumulo

Class MergingVisibilityCombiner

java.lang.Object

org.apache.accumulo.core.iterators.WrappingIterator

org.apache.accumulo.core.iterators.user.TransformingIterator

org.locationtech.geowave.datastore.accumulo.iterators.ExceptionHandlingTransformingIterator

org.locationtech.geowave.datastore.accumulo.MergingVisibilityCombiner

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>

Direct Known Subclasses:

RowMergingVisibilityCombiner

public class MergingVisibilityCombiner
extends ExceptionHandlingTransformingIterator

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.accumulo.core.iterators.user.TransformingIterator

org.apache.accumulo.core.iterators.user.TransformingIterator.KVBuffer

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

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

Field Summary

Fields inherited from class org.apache.accumulo.core.iterators.user.TransformingIterator

AUTH_OPT, keyPos, keys, log, MAX_BUFFER_SIZE_OPT, scanning, seekColumnFamilies, seekColumnFamiliesInclusive, seekRange

Constructor Summary

Constructors

Constructor and Description
MergingVisibilityCombiner()

Method Summary

Modifier and Type	Method and 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)
protected byte[]	getBinary(Mergeable mergeable)
protected String	getColumnOptionValue(Map<String,String> options)
protected org.apache.accumulo.core.data.PartialKey	getKeyPrefix()
protected Mergeable	getMergeable(org.apache.accumulo.core.data.Key key, byte[] binary)
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)
protected void	transformRangeInternal(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> input, org.apache.accumulo.core.iterators.user.TransformingIterator.KVBuffer output)

Methods inherited from class org.locationtech.geowave.datastore.accumulo.iterators.ExceptionHandlingTransformingIterator

transformRange

Methods inherited from class org.apache.accumulo.core.iterators.user.TransformingIterator

canSee, canSeeColumnFamily, computeReseekRange, copyPartialKey, describeOptions, getTopKey, getTopValue, hasTop, includeTransformedKey, isSetAfterPart, next, replaceColumnFamily, replaceColumnQualifier, replaceColumnVisibility, replaceKeyParts, replaceKeyParts, seek, setAuthorizations, setMaxBufferSize, transformKeys, untransformColumnFamilies, validateOptions

Methods inherited from class org.apache.accumulo.core.iterators.WrappingIterator

getSource, setSource

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

enableYielding

Constructor Detail

MergingVisibilityCombiner

public MergingVisibilityCombiner()

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.user.TransformingIterator

Throws:

IOException

getColumnOptionValue

protected String getColumnOptionValue(Map<String,String> options)

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.user.TransformingIterator

getKeyPrefix

protected org.apache.accumulo.core.data.PartialKey getKeyPrefix()

Specified by:

getKeyPrefix in class org.apache.accumulo.core.iterators.user.TransformingIterator

transformRangeInternal

protected void transformRangeInternal(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> input,
                                      org.apache.accumulo.core.iterators.user.TransformingIterator.KVBuffer output)
                               throws IOException

Specified by:

transformRangeInternal in class ExceptionHandlingTransformingIterator

Throws:

IOException

getMergeable

protected Mergeable getMergeable(org.apache.accumulo.core.data.Key key,
                                 byte[] binary)

getBinary

protected byte[] getBinary(Mergeable mergeable)