Package | Description |
---|---|
org.apache.hadoop.hive.accumulo.mr | |
org.apache.hadoop.hive.accumulo.predicate |
Predicate pushdown to Accumulo filter iterators.
|
org.apache.hadoop.hive.accumulo.serde |
Modifier and Type | Method and Description |
---|---|
protected ColumnMapper |
HiveAccumuloTableInputFormat.getColumnMapper(org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
protected void |
HiveAccumuloTableInputFormat.configure(org.apache.hadoop.mapred.JobConf conf,
org.apache.accumulo.core.client.Instance instance,
org.apache.accumulo.core.client.Connector connector,
AccumuloConnectionParameters accumuloParams,
ColumnMapper columnMapper,
List<org.apache.accumulo.core.client.IteratorSetting> iterators,
Collection<org.apache.accumulo.core.data.Range> ranges)
Configure the underlying AccumuloInputFormat
|
Modifier and Type | Method and Description |
---|---|
protected Object |
AccumuloPredicateHandler.generateRanges(ColumnMapper columnMapper,
String hiveRowIdColumnName,
ExprNodeDesc root)
Encapsulates the traversal over some
ExprNodeDesc tree for the generation of Accumuluo
Ranges using expressions involving the Accumulo rowid-mapped Hive column |
List<org.apache.accumulo.core.client.IteratorSetting> |
AccumuloPredicateHandler.getIterators(org.apache.hadoop.conf.Configuration conf,
ColumnMapper columnMapper)
Loop through search conditions and build iterator settings for predicates involving columns
other than rowID, if any.
|
List<org.apache.accumulo.core.data.Range> |
AccumuloPredicateHandler.getRanges(org.apache.hadoop.conf.Configuration conf,
ColumnMapper columnMapper)
Loop through search conditions and build ranges for predicates involving rowID column, if any.
|
Modifier and Type | Field and Description |
---|---|
protected ColumnMapper |
AccumuloSerDeParameters.columnMapper |
Modifier and Type | Method and Description |
---|---|
ColumnMapper |
AccumuloSerDeParameters.getColumnMapper() |
Copyright © 2016 The Apache Software Foundation. All rights reserved.