Package | Description |
---|---|
org.apache.hadoop.hive.accumulo |
Serde and InputFormat support for connecting Hive to Accumulo tables.
|
org.apache.hadoop.hive.accumulo.mr |
Modifier and Type | Field and Description |
---|---|
protected AccumuloHiveRow |
LazyAccumuloMap.sourceRow |
Modifier and Type | Method and Description |
---|---|
void |
LazyAccumuloMap.init(AccumuloHiveRow row,
HiveAccumuloMapColumnMapping columnMapping) |
void |
LazyAccumuloRow.init(AccumuloHiveRow hiveRow,
List<ColumnMapping> columnMappings,
AccumuloRowIdFactory rowIdFactory) |
Modifier and Type | Method and Description |
---|---|
AccumuloHiveRow |
HiveAccumuloRecordReader.createValue() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,AccumuloHiveRow> |
HiveAccumuloTableInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit inputSplit,
org.apache.hadoop.mapred.JobConf jobConf,
org.apache.hadoop.mapred.Reporter reporter)
Setup accumulo input format from conf properties.
|
Modifier and Type | Method and Description |
---|---|
boolean |
HiveAccumuloRecordReader.next(org.apache.hadoop.io.Text rowKey,
AccumuloHiveRow row) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.