org.apache.hadoop.hive.accumulo.columns

Class ColumnMapper

java.lang.Object

org.apache.hadoop.hive.accumulo.columns.ColumnMapper

public class ColumnMapper
extends Object

Constructor Summary

Constructors

Constructor and Description
ColumnMapper(String serializedColumnMappings, String defaultStorageType, List<String> columnNames, List<TypeInfo> columnTypes) Create a mapping from Hive columns (rowID and column) to Accumulo columns (column family and qualifier).

Method Summary

Methods

Modifier and Type	Method and Description
ColumnMapping	get(int i)
ColumnMapping	getColumnMappingForHiveColumn(List<String> hiveColumns, String hiveColumnName)
List<ColumnMapping>	getColumnMappings()
HiveAccumuloRowIdColumnMapping	getRowIdMapping()
int	getRowIdOffset()
String	getTypesString()
boolean	hasRowIdMapping()
int	size()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ColumnMapper

public ColumnMapper(String serializedColumnMappings,
            String defaultStorageType,
            List<String> columnNames,
            List<TypeInfo> columnTypes)
             throws TooManyAccumuloColumnsException

Create a mapping from Hive columns (rowID and column) to Accumulo columns (column family and qualifier). The ordering of the ColumnMappings is important as it aligns with the ordering of the columns for the Hive table schema.

Parameters:

serializedColumnMappings - Comma-separated list of designators that map to Accumulo columns whose offsets correspond to the Hive table schema

Throws:

TooManyAccumuloColumnsException

Method Detail

size

public int size()

get

public ColumnMapping get(int i)

getColumnMappings

public List<ColumnMapping> getColumnMappings()

hasRowIdMapping

public boolean hasRowIdMapping()

getRowIdMapping

public HiveAccumuloRowIdColumnMapping getRowIdMapping()

getRowIdOffset

public int getRowIdOffset()

getTypesString

public String getTypesString()

getColumnMappingForHiveColumn

public ColumnMapping getColumnMappingForHiveColumn(List<String> hiveColumns,
                                          String hiveColumnName)

toString

public String toString()

Overrides:

toString in class Object