Package | Description |
---|---|
org.apache.accumulo.core.client | |
org.apache.accumulo.core.client.admin | |
org.apache.accumulo.core.client.mapred | |
org.apache.accumulo.core.client.mapreduce | |
org.apache.accumulo.core.client.mapreduce.lib.util |
This package exists to store common helpers for configuring MapReduce jobs in a single location.
|
org.apache.accumulo.core.client.mock | |
org.apache.accumulo.core.data |
Modifier and Type | Method and Description |
---|---|
Range |
IsolatedScanner.getRange() |
Range |
ClientSideIteratorScanner.getRange() |
Range |
Scanner.getRange()
Returns the range of keys to scan over.
|
Modifier and Type | Method and Description |
---|---|
void |
ClientSideIteratorScanner.ScannerTranslator.seek(Range range,
Collection<ByteSequence> columnFamilies,
boolean inclusive) |
void |
IsolatedScanner.setRange(Range range) |
void |
ClientSideIteratorScanner.setRange(Range range) |
void |
Scanner.setRange(Range range)
Sets the range of keys to scan over.
|
Modifier and Type | Method and Description |
---|---|
void |
BatchDeleter.setRanges(Collection<Range> ranges)
Allows deleting multiple ranges efficiently.
|
void |
BatchScanner.setRanges(Collection<Range> ranges)
Allows scanning over multiple ranges efficiently.
|
Modifier and Type | Method and Description |
---|---|
Set<Range> |
TableOperationsImpl.splitRangeByTablets(String tableName,
Range range,
int maxSplits) |
Set<Range> |
TableOperations.splitRangeByTablets(String tableName,
Range range,
int maxSplits) |
Modifier and Type | Method and Description |
---|---|
Set<Range> |
TableOperationsImpl.splitRangeByTablets(String tableName,
Range range,
int maxSplits) |
Set<Range> |
TableOperations.splitRangeByTablets(String tableName,
Range range,
int maxSplits) |
Modifier and Type | Method and Description |
---|---|
protected static List<Range> |
InputFormatBase.getRanges(org.apache.hadoop.mapred.JobConf job)
Gets the ranges to scan over from a job.
|
Modifier and Type | Method and Description |
---|---|
static void |
InputFormatBase.setRanges(org.apache.hadoop.mapred.JobConf job,
Collection<Range> ranges)
Sets the input ranges to scan for this job.
|
Constructor and Description |
---|
InputFormatBase.RangeInputSplit(String table,
Range range,
String[] locations)
Deprecated.
|
RangeInputSplit(Range range,
String[] locations) |
Modifier and Type | Method and Description |
---|---|
Range |
RangeInputSplit.getRange() |
Modifier and Type | Method and Description |
---|---|
protected static List<Range> |
InputFormatBase.getRanges(org.apache.hadoop.conf.Configuration conf)
Deprecated.
since 1.5.0; Use
InputFormatBase.getRanges(JobContext) instead. |
protected static List<Range> |
InputFormatBase.getRanges(org.apache.hadoop.mapreduce.JobContext context)
Gets the ranges to scan over from a job.
|
Modifier and Type | Method and Description |
---|---|
void |
RangeInputSplit.setRange(Range range) |
Modifier and Type | Method and Description |
---|---|
static void |
InputFormatBase.setRanges(org.apache.hadoop.conf.Configuration conf,
Collection<Range> ranges)
Deprecated.
since 1.5.0; Use
InputFormatBase.setRanges(Job, Collection) instead. |
static void |
InputFormatBase.setRanges(org.apache.hadoop.mapreduce.Job job,
Collection<Range> ranges)
Sets the input ranges to scan for this job.
|
Constructor and Description |
---|
InputFormatBase.RangeInputSplit(String table,
Range range,
String[] locations)
Deprecated.
|
RangeInputSplit(Range range,
String[] locations) |
Modifier and Type | Method and Description |
---|---|
static List<Range> |
InputConfigurator.getRanges(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf)
Gets the ranges to scan over from a job.
|
Modifier and Type | Method and Description |
---|---|
static void |
InputConfigurator.setRanges(Class<?> implementingClass,
org.apache.hadoop.conf.Configuration conf,
Collection<Range> ranges)
Sets the input ranges to scan for this job.
|
Modifier and Type | Method and Description |
---|---|
Range |
MockScanner.getRange() |
Modifier and Type | Method and Description |
---|---|
List<Range> |
MockTabletLocator.binRanges(List<Range> ranges,
Map<String,Map<KeyExtent,List<Range>>> binnedRanges,
org.apache.accumulo.core.security.thrift.TCredentials credentials) |
Set<Range> |
MockTableOperations.splitRangeByTablets(String tableName,
Range range,
int maxSplits) |
Modifier and Type | Method and Description |
---|---|
void |
MockScanner.setRange(Range range) |
Set<Range> |
MockTableOperations.splitRangeByTablets(String tableName,
Range range,
int maxSplits) |
Modifier and Type | Method and Description |
---|---|
List<Range> |
MockTabletLocator.binRanges(List<Range> ranges,
Map<String,Map<KeyExtent,List<Range>>> binnedRanges,
org.apache.accumulo.core.security.thrift.TCredentials credentials) |
List<Range> |
MockTabletLocator.binRanges(List<Range> ranges,
Map<String,Map<KeyExtent,List<Range>>> binnedRanges,
org.apache.accumulo.core.security.thrift.TCredentials credentials) |
void |
MockBatchScanner.setRanges(Collection<Range> ranges) |
Modifier and Type | Method and Description |
---|---|
Range |
Range.bound(Column min,
Column max)
Creates a new range that is bounded by the columns passed in.
|
Range |
Range.clip(Range range)
Creates a range which represents the intersection of this range and the passed in range.
|
Range |
Range.clip(Range range,
boolean returnNullIfDisjoint)
Same as other clip function except if gives the option to return null of the ranges do not overlap instead of throwing an exception.
|
static Range |
Range.exact(CharSequence row)
Creates a range that covers an exact row
|
static Range |
Range.exact(CharSequence row,
CharSequence cf)
Creates a range that covers an exact row and column family
|
static Range |
Range.exact(CharSequence row,
CharSequence cf,
CharSequence cq)
Creates a range that covers an exact row, column family, and column qualifier
|
static Range |
Range.exact(CharSequence row,
CharSequence cf,
CharSequence cq,
CharSequence cv)
Creates a range that covers an exact row, column family, column qualifier, and visibility
|
static Range |
Range.exact(CharSequence row,
CharSequence cf,
CharSequence cq,
CharSequence cv,
long ts)
Creates a range that covers an exact row, column family, column qualifier, visibility, and timestamp
|
static Range |
Range.exact(org.apache.hadoop.io.Text row)
Creates a range that covers an exact row Returns the same Range as new Range(row)
|
static Range |
Range.exact(org.apache.hadoop.io.Text row,
org.apache.hadoop.io.Text cf)
Creates a range that covers an exact row and column family
|
static Range |
Range.exact(org.apache.hadoop.io.Text row,
org.apache.hadoop.io.Text cf,
org.apache.hadoop.io.Text cq)
Creates a range that covers an exact row, column family, and column qualifier
|
static Range |
Range.exact(org.apache.hadoop.io.Text row,
org.apache.hadoop.io.Text cf,
org.apache.hadoop.io.Text cq,
org.apache.hadoop.io.Text cv)
Creates a range that covers an exact row, column family, column qualifier, and visibility
|
static Range |
Range.exact(org.apache.hadoop.io.Text row,
org.apache.hadoop.io.Text cf,
org.apache.hadoop.io.Text cq,
org.apache.hadoop.io.Text cv,
long ts)
Creates a range that covers an exact row, column family, column qualifier, visibility, and timestamp
|
static Range |
Range.prefix(CharSequence rowPrefix)
Returns a Range that covers all rows beginning with a prefix
|
static Range |
Range.prefix(CharSequence row,
CharSequence cfPrefix)
Returns a Range that covers all column families beginning with a prefix within a given row
|
static Range |
Range.prefix(CharSequence row,
CharSequence cf,
CharSequence cqPrefix)
Returns a Range that covers all column qualifiers beginning with a prefix within a given row and column family
|
static Range |
Range.prefix(CharSequence row,
CharSequence cf,
CharSequence cq,
CharSequence cvPrefix)
Returns a Range that covers all column visibilities beginning with a prefix within a given row, column family, and column qualifier
|
static Range |
Range.prefix(org.apache.hadoop.io.Text rowPrefix)
Returns a Range that covers all rows beginning with a prefix
|
static Range |
Range.prefix(org.apache.hadoop.io.Text row,
org.apache.hadoop.io.Text cfPrefix)
Returns a Range that covers all column families beginning with a prefix within a given row
|
static Range |
Range.prefix(org.apache.hadoop.io.Text row,
org.apache.hadoop.io.Text cf,
org.apache.hadoop.io.Text cqPrefix)
Returns a Range that covers all column qualifiers beginning with a prefix within a given row and column family
|
static Range |
Range.prefix(org.apache.hadoop.io.Text row,
org.apache.hadoop.io.Text cf,
org.apache.hadoop.io.Text cq,
org.apache.hadoop.io.Text cvPrefix)
Returns a Range that covers all column visibilities beginning with a prefix within a given row, column family, and column qualifier
|
Range |
KeyExtent.toDataRange() |
Range |
KeyExtent.toMetadataRange() |
Modifier and Type | Method and Description |
---|---|
static List<Range> |
Range.mergeOverlapping(Collection<Range> ranges)
Takes a collection on range and merges overlapping and adjacent ranges.
|
Modifier and Type | Method and Description |
---|---|
Range |
Range.clip(Range range)
Creates a range which represents the intersection of this range and the passed in range.
|
Range |
Range.clip(Range range,
boolean returnNullIfDisjoint)
Same as other clip function except if gives the option to return null of the ranges do not overlap instead of throwing an exception.
|
int |
Range.compareTo(Range o)
Compares this range to another range.
|
boolean |
Range.equals(Range otherRange) |
Modifier and Type | Method and Description |
---|---|
static List<Range> |
Range.mergeOverlapping(Collection<Range> ranges)
Takes a collection on range and merges overlapping and adjacent ranges.
|
Constructor and Description |
---|
Range(Range range)
Copies a range
|
Copyright © 2011-2016 The Apache Software Foundation. All Rights Reserved.