org.apache.hadoop.hive.ql.io

Class RecordIdentifier

java.lang.Object

org.apache.hadoop.hive.ql.io.RecordIdentifier

All Implemented Interfaces:

Comparable<RecordIdentifier>, org.apache.hadoop.io.Writable, org.apache.hadoop.io.WritableComparable<RecordIdentifier>

public class RecordIdentifier
extends Object
implements org.apache.hadoop.io.WritableComparable<RecordIdentifier>

Gives the Record identifier information for the current record.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RecordIdentifier.Field This is in support of VirtualColumn.ROWID Contains metadata about each field in RecordIdentifier that needs to be part of ROWID which is represented as a struct RecordIdentifier.StructInfo.
static class	RecordIdentifier.StructInfo RecordIdentifier is passed along the operator tree as a struct.

Constructor Summary

Constructors

Constructor and Description
RecordIdentifier()
RecordIdentifier(long transactionId, int bucket, long rowId)

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(RecordIdentifier other)
protected int	compareToInternal(RecordIdentifier other)
boolean	equals(Object other)
int	getBucketId() What was the original bucket id for the last row?
long	getRowId() What was the original row id for the last row?
long	getTransactionId() What was the original transaction id for the last row?
void	readFields(DataInput dataInput)
void	set(RecordIdentifier other) Set this object to match the given object.
void	setRowId(long rowId)
void	setValues(long transactionId, int bucketId, long rowId) Set the identifier.
String	toString()
void	write(DataOutput dataOutput)

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordIdentifier

public RecordIdentifier()

RecordIdentifier

public RecordIdentifier(long transactionId,
                int bucket,
                long rowId)

Method Detail

setValues

public void setValues(long transactionId,
             int bucketId,
             long rowId)

Set the identifier.

Parameters:

transactionId - the transaction id

bucketId - the bucket id

rowId - the row id

set

public void set(RecordIdentifier other)

Set this object to match the given object.

Parameters:

other - the object to copy from

setRowId

public void setRowId(long rowId)

getTransactionId

public long getTransactionId()

What was the original transaction id for the last row?

Returns:

the transaction id

getBucketId

public int getBucketId()

What was the original bucket id for the last row?

Returns:

the bucket id

getRowId

public long getRowId()

What was the original row id for the last row?

Returns:

the row id

compareToInternal

protected int compareToInternal(RecordIdentifier other)

compareTo

public int compareTo(RecordIdentifier other)

Specified by:

compareTo in interface Comparable<RecordIdentifier>

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

equals

public boolean equals(Object other)

Overrides:

equals in class Object

toString

public String toString()

Overrides:

toString in class Object