org.apache.hadoop.hive.accumulo

Class AccumuloHiveRow

java.lang.Object

org.apache.hadoop.hive.accumulo.AccumuloHiveRow

All Implemented Interfaces:

org.apache.hadoop.io.Writable

public class AccumuloHiveRow
extends Object
implements org.apache.hadoop.io.Writable

Holds column tuples for rowID. Each tuple contains column family label, qualifier label, and byte array value.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AccumuloHiveRow.ColumnTuple

Constructor Summary

Constructors

Constructor and Description
AccumuloHiveRow()
AccumuloHiveRow(String rowId)

Method Summary

Methods

Modifier and Type	Method and Description
void	add(String cf, String qual, byte[] val)
void	add(org.apache.hadoop.io.Text cf, org.apache.hadoop.io.Text qual, byte[] val)
void	clear()
boolean	equals(Object o)
String	getRowId()
List<AccumuloHiveRow.ColumnTuple>	getTuples()
byte[]	getValue(org.apache.hadoop.io.Text fam, org.apache.hadoop.io.Text qual)
boolean	hasFamAndQual(org.apache.hadoop.io.Text fam, org.apache.hadoop.io.Text qual)
void	readFields(DataInput dataInput)
void	setRowId(String rowId)
String	toString()
void	write(DataOutput dataOutput)

Methods inherited from class java.lang.Object

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

Constructor Detail

AccumuloHiveRow

public AccumuloHiveRow()

AccumuloHiveRow

public AccumuloHiveRow(String rowId)

Method Detail

setRowId

public void setRowId(String rowId)

getTuples

public List<AccumuloHiveRow.ColumnTuple> getTuples()

hasFamAndQual

public boolean hasFamAndQual(org.apache.hadoop.io.Text fam,
                    org.apache.hadoop.io.Text qual)

Returns:

true if this instance has a tuple containing fam and qual, false otherwise.

getValue

public byte[] getValue(org.apache.hadoop.io.Text fam,
              org.apache.hadoop.io.Text qual)

Returns:

byte [] value for first tuple containing fam and qual or null if no match.

getRowId

public String getRowId()

clear

public void clear()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

write

public void write(DataOutput dataOutput)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

readFields

public void readFields(DataInput dataInput)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

add

public void add(String cf,
       String qual,
       byte[] val)

add

public void add(org.apache.hadoop.io.Text cf,
       org.apache.hadoop.io.Text qual,
       byte[] val)