Package | Description |
---|---|
org.apache.hadoop.hive.accumulo |
Serde and InputFormat support for connecting Hive to Accumulo tables.
|
org.apache.hadoop.hive.accumulo.columns | |
org.apache.hadoop.hive.accumulo.mr | |
org.apache.hadoop.hive.accumulo.serde |
Modifier and Type | Method and Description |
---|---|
void |
LazyAccumuloRow.init(AccumuloHiveRow hiveRow,
List<ColumnMapping> columnMappings,
AccumuloRowIdFactory rowIdFactory) |
Modifier and Type | Class and Description |
---|---|
class |
HiveAccumuloColumnMapping
A Hive column which maps to a column family and column qualifier pair in Accumulo
|
class |
HiveAccumuloMapColumnMapping
ColumnMapping for combining Accumulo columns into a single Hive Map.
|
class |
HiveAccumuloRowIdColumnMapping
ColumnMapping which corresponds to the Hive column which should be used as the rowID in a
Mutation |
Modifier and Type | Method and Description |
---|---|
ColumnMapping |
ColumnMapper.get(int i) |
static ColumnMapping |
ColumnMappingFactory.get(String columnSpec,
ColumnEncoding defaultEncoding,
String columnName,
TypeInfo columnType)
Generate the proper instance of a ColumnMapping
|
ColumnMapping |
ColumnMapper.getColumnMappingForHiveColumn(List<String> hiveColumns,
String hiveColumnName) |
static ColumnMapping |
ColumnMappingFactory.getMap(String columnSpec,
ColumnEncoding keyEncoding,
ColumnEncoding valueEncoding,
String columnName,
TypeInfo columnType) |
Modifier and Type | Method and Description |
---|---|
List<ColumnMapping> |
ColumnMapper.getColumnMappings() |
Modifier and Type | Method and Description |
---|---|
protected HashSet<org.apache.accumulo.core.util.Pair<org.apache.hadoop.io.Text,org.apache.hadoop.io.Text>> |
HiveAccumuloTableInputFormat.getPairCollection(List<ColumnMapping> columnMappings)
Create col fam/qual pairs from pipe separated values, usually from config object.
|
Modifier and Type | Method and Description |
---|---|
ColumnMapping |
AccumuloSerDeParameters.getColumnMappingForHiveColumn(String hiveColumn) |
Modifier and Type | Method and Description |
---|---|
List<ColumnMapping> |
AccumuloSerDeParameters.getColumnMappings() |
Modifier and Type | Method and Description |
---|---|
protected byte[] |
AccumuloRowSerializer.getSerializedValue(ObjectInspector fieldObjectInspector,
Object value,
ByteStream.Output output,
ColumnMapping mapping)
Compute the serialized value from the given element and object inspectors.
|
protected byte[] |
AccumuloRowSerializer.serializeRowId(Object rowId,
StructField rowIdField,
ColumnMapping rowIdMapping)
Serialize an Accumulo rowid
|
protected void |
AccumuloRowSerializer.writeWithLevel(ObjectInspector oi,
Object value,
ByteStream.Output output,
ColumnMapping mapping,
int level)
Recursively serialize an Object using its
ObjectInspector , respecting the
separators defined by the LazySerDeParameters . |
Modifier and Type | Method and Description |
---|---|
protected ArrayList<ObjectInspector> |
AccumuloSerDe.getColumnObjectInspectors(List<TypeInfo> columnTypes,
LazySerDeParameters serDeParams,
List<ColumnMapping> mappings,
AccumuloRowIdFactory factory) |
Constructor and Description |
---|
AccumuloRowSerializer(int primaryKeyOffset,
LazySerDeParameters serDeParams,
List<ColumnMapping> mappings,
org.apache.accumulo.core.security.ColumnVisibility visibility,
AccumuloRowIdFactory rowIdFactory) |
Copyright © 2016 The Apache Software Foundation. All rights reserved.