Modifier and Type | Method and Description |
---|---|
org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value> |
ClientSideIteratorScanner.ScannerTranslator.deepCopy(org.apache.accumulo.core.iterators.IteratorEnvironment env)
Deprecated.
|
Iterator<Map.Entry<Key,Value>> |
IsolatedScanner.iterator() |
Iterator<Map.Entry<Key,Value>> |
IsolatedScanner.RowBuffer.iterator() |
Iterator<Map.Entry<Key,Value>> |
IsolatedScanner.MemoryRowBuffer.iterator() |
Iterator<Map.Entry<Key,Value>> |
ScannerBase.iterator()
Returns an iterator over an accumulo table.
|
Iterator<Map.Entry<Key,Value>> |
ClientSideIteratorScanner.iterator() |
Iterator<Map.Entry<Key,Value>> |
RowIterator.next()
Fetch the next row.
|
Modifier and Type | Method and Description |
---|---|
void |
IsolatedScanner.RowBuffer.add(Map.Entry<Key,Value> entry) |
void |
IsolatedScanner.MemoryRowBuffer.add(Map.Entry<Key,Value> entry) |
Constructor and Description |
---|
IteratorSetting(int priority,
Class<? extends org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value>> iteratorClass)
Constructs an iterator setting using the given class's SimpleName for the iterator name.
|
IteratorSetting(int priority,
Class<? extends org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value>> iteratorClass,
Map<String,String> properties)
Constructs an iterator setting using the given class's SimpleName for the iterator name and
configured for the specified scopes with the specified parameters.
|
IteratorSetting(int priority,
String name,
Class<? extends org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value>> iteratorClass)
Constructs an iterator setting configured for the scan scope with no parameters.
|
IteratorSetting(int priority,
String name,
Class<? extends org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value>> iteratorClass,
Map<String,String> properties)
Constructs an iterator setting using the provided name and the provided class's name for the
scan scope with the provided parameters.
|
RowIterator(Iterable<Map.Entry<Key,Value>> iterable)
Create an iterator from an Iterable.
|
RowIterator(Iterator<Map.Entry<Key,Value>> iterator)
Create an iterator from an (ordered) sequence of KeyValue pairs.
|
Modifier and Type | Field and Description |
---|---|
protected Key |
AbstractInputFormat.AbstractRecordReader.currentKey |
Modifier and Type | Field and Description |
---|---|
protected Iterator<Map.Entry<Key,Value>> |
AbstractInputFormat.AbstractRecordReader.scannerIterator |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordReader<Key,Value> |
AccumuloInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
org.apache.hadoop.mapred.RecordReader<Key,Value> |
AccumuloMultiTableInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>> |
AccumuloRowInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf job,
org.apache.hadoop.mapred.Reporter reporter) |
org.apache.hadoop.mapred.RecordWriter<Key,Value> |
AccumuloFileOutputFormat.getRecordWriter(org.apache.hadoop.fs.FileSystem ignored,
org.apache.hadoop.mapred.JobConf job,
String name,
org.apache.hadoop.util.Progressable progress) |
Modifier and Type | Field and Description |
---|---|
protected Key |
AbstractInputFormat.AbstractRecordReader.currentKey
The Key that is used to determine progress in the current InputSplit.
|
Modifier and Type | Field and Description |
---|---|
protected Iterator<Map.Entry<Key,Value>> |
AbstractInputFormat.AbstractRecordReader.scannerIterator |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<Key,Value> |
AccumuloInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
org.apache.hadoop.mapreduce.RecordReader<Key,Value> |
AccumuloMultiTableInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,org.apache.accumulo.core.util.PeekingIterator<Map.Entry<Key,Value>>> |
AccumuloRowInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
org.apache.hadoop.mapreduce.RecordWriter<Key,Value> |
AccumuloFileOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
float |
RangeInputSplit.getProgress(Key currentKey) |
Modifier and Type | Method and Description |
---|---|
int |
KeyRangePartitioner.getPartition(Key key,
org.apache.hadoop.io.Writable value,
int numPartitions) |
Modifier and Type | Method and Description |
---|---|
org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value> |
MockScannerBase.createFilter(org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value> inner)
Deprecated.
|
Iterator<Map.Entry<Key,Value>> |
MockBatchScanner.iterator()
Deprecated.
|
Iterator<Map.Entry<Key,Value>> |
MockScanner.iterator()
Deprecated.
|
Iterator<Map.Entry<Key,Value>> |
MockScannerBase.iterator()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value> |
MockScannerBase.createFilter(org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value> inner)
Deprecated.
|
Constructor and Description |
---|
IteratorAdapter(org.apache.accumulo.core.iterators.SortedKeyValueIterator<Key,Value> inner)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
RFileWriter.append(Key key,
Value val)
Append the key and value to the last locality group that was started.
|
Modifier and Type | Method and Description |
---|---|
void |
RFileWriter.append(Iterable<Map.Entry<Key,Value>> keyValues)
Append the keys and values to the last locality group that was started.
|
Modifier and Type | Method and Description |
---|---|
boolean |
AbstractHashSampler.accept(Key k) |
boolean |
Sampler.accept(Key k) |
protected abstract void |
AbstractHashSampler.hash(DataOutput hasher,
Key k)
Subclass must override this method and hash some portion of the key.
|
protected void |
RowColumnSampler.hash(DataOutput hasher,
Key k) |
protected void |
RowSampler.hash(DataOutput hasher,
Key k) |
Modifier and Type | Method and Description |
---|---|
Key |
Key.followingKey(PartialKey part)
Returns a key that will sort immediately after this key.
|
Key |
Range.getEndKey()
Gets the ending key, or null if the end is positive infinity.
|
Key |
Range.getStartKey()
Gets the start key, or null if the start is negative infinity.
|
Modifier and Type | Method and Description |
---|---|
boolean |
Range.afterEndKey(Key key)
Determines if the given key is after the ending key of this range.
|
boolean |
Range.beforeStartKey(Key key)
Determines if the given key is before the start key of this range.
|
int |
Key.compareTo(Key other) |
int |
Key.compareTo(Key other,
PartialKey part)
Compares elements of a key given by a
PartialKey . |
boolean |
Range.contains(Key key)
Determines if the given key falls within this range.
|
boolean |
Key.equals(Key other,
PartialKey part)
Compares part of a key.
|
void |
Key.set(Key k)
Sets this key's row, column family, column qualifier, column visibility, timestamp, and delete
marker to be the same as another key's.
|
Constructor and Description |
---|
Key(Key other)
Creates a key with the same row, column family, column qualifier, column visibility, timestamp,
and delete marker as the given key.
|
KeyValue(Key key,
byte[] value)
Creates a new key/value pair.
|
KeyValue(Key key,
ByteBuffer value)
Creates a new key/value pair.
|
KeyValue(Key key,
Value value)
Creates a new key/value pair.
|
Range(Key start,
boolean startKeyInclusive,
boolean infiniteStartKey,
Key stop,
boolean stopKeyInclusive,
boolean infiniteStopKey)
Creates a range from start to stop.
|
Range(Key startKey,
boolean startKeyInclusive,
Key endKey,
boolean endKeyInclusive)
Creates a range from startKey to endKey.
|
Range(Key startKey,
Key endKey)
Creates a range from startKey inclusive to endKey inclusive.
|
Range(Key start,
Key stop,
boolean startKeyInclusive,
boolean stopKeyInclusive,
boolean infiniteStartKey,
boolean infiniteStopKey)
Creates a range from start to stop.
|
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.