org.apache.hadoop.hive.accumulo.columns

Class HiveAccumuloMapColumnMapping

java.lang.Object

org.apache.hadoop.hive.accumulo.columns.ColumnMapping

org.apache.hadoop.hive.accumulo.columns.HiveAccumuloMapColumnMapping

public class HiveAccumuloMapColumnMapping
extends ColumnMapping

ColumnMapping for combining Accumulo columns into a single Hive Map. Expects ColumnEncoding values for both the Key and Value of the Map.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	columnFamily
protected String	columnQualifierPrefix
protected ColumnEncoding	keyEncoding
protected ColumnEncoding	valueEncoding

Fields inherited from class org.apache.hadoop.hive.accumulo.columns.ColumnMapping

columnName, columnType, encoding, mappingSpec

Constructor Summary

Constructors

Constructor and Description
HiveAccumuloMapColumnMapping(String columnFamily, String columnQualifierPrefix, ColumnEncoding keyEncoding, ColumnEncoding valueEncoding, String columnName, String columnType)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	equals(Object o)
String	getColumnFamily()
String	getColumnQualifierPrefix()
ColumnEncoding	getKeyEncoding()
ColumnEncoding	getValueEncoding()
int	hashCode()
String	toString()

Methods inherited from class org.apache.hadoop.hive.accumulo.columns.ColumnMapping

getColumnName, getColumnType, getEncoding, getMappingSpec

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

columnFamily

protected final String columnFamily

columnQualifierPrefix

protected final String columnQualifierPrefix

keyEncoding

protected final ColumnEncoding keyEncoding

valueEncoding

protected final ColumnEncoding valueEncoding

Constructor Detail

HiveAccumuloMapColumnMapping

public HiveAccumuloMapColumnMapping(String columnFamily,
                            String columnQualifierPrefix,
                            ColumnEncoding keyEncoding,
                            ColumnEncoding valueEncoding,
                            String columnName,
                            String columnType)

Parameters:

columnFamily - The column family that all qualifiers within should be placed into the same Hive map

columnQualifierPrefix - The column qualifier prefix to include in the map, null is treated as an empty prefix

keyEncoding - The encoding scheme for keys in this column family

valueEncoding - The encoding scheme for the Accumulo values

Method Detail

getColumnFamily

public String getColumnFamily()

getColumnQualifierPrefix

public String getColumnQualifierPrefix()

getKeyEncoding

public ColumnEncoding getKeyEncoding()

getValueEncoding

public ColumnEncoding getValueEncoding()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object