Package | Description |
---|---|
org.apache.accumulo.core.client | |
org.apache.accumulo.core.client.mapred | |
org.apache.accumulo.core.client.mapreduce | |
org.apache.accumulo.core.client.mock |
Mock framework for Accumulo
|
org.apache.accumulo.core.client.rfile | |
org.apache.accumulo.core.data |
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 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 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 |
---|---|
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 |
---|---|
static Value |
KeyExtent.encodePrevEndRow(org.apache.hadoop.io.Text per)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.io.Text |
KeyExtent.decodePrevEndRow(Value ibw)
Deprecated.
|
void |
Mutation.put(CharSequence columnFamily,
CharSequence columnQualifier,
ColumnVisibility columnVisibility,
long timestamp,
Value value)
Puts a modification in this mutation.
|
void |
Mutation.put(CharSequence columnFamily,
CharSequence columnQualifier,
ColumnVisibility columnVisibility,
Value value)
Puts a modification in this mutation.
|
void |
Mutation.put(CharSequence columnFamily,
CharSequence columnQualifier,
long timestamp,
Value value)
Puts a modification in this mutation.
|
void |
Mutation.put(CharSequence columnFamily,
CharSequence columnQualifier,
Value value)
Puts a modification in this mutation.
|
void |
Mutation.put(org.apache.hadoop.io.Text columnFamily,
org.apache.hadoop.io.Text columnQualifier,
ColumnVisibility columnVisibility,
long timestamp,
Value value)
Puts a modification in this mutation.
|
void |
Mutation.put(org.apache.hadoop.io.Text columnFamily,
org.apache.hadoop.io.Text columnQualifier,
ColumnVisibility columnVisibility,
Value value)
Puts a modification in this mutation.
|
void |
Mutation.put(org.apache.hadoop.io.Text columnFamily,
org.apache.hadoop.io.Text columnQualifier,
long timestamp,
Value value)
Puts a modification in this mutation.
|
void |
Mutation.put(org.apache.hadoop.io.Text columnFamily,
org.apache.hadoop.io.Text columnQualifier,
Value value)
Puts a modification in this mutation.
|
Constructor and Description |
---|
KeyExtent(org.apache.hadoop.io.Text flattenedExtent,
Value prevEndRow)
Deprecated.
|
KeyValue(Key key,
Value value)
Creates a new key/value pair.
|
Value(Value ibw)
Creates a new Value based on another.
|
Copyright © 2011–2019 The Apache Software Foundation. All rights reserved.