org.apache.pig.backend.hadoop.executionengine.spark.converter

Class IndexedKey

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.spark.converter.IndexedKey

All Implemented Interfaces:

Serializable, Comparable

public class IndexedKey
extends Object
implements Serializable, Comparable

IndexedKey records the index and key info. This is used as key for JOINs. It addresses the case where key is either empty (or is a tuple with one or more empty fields). In this case, we must respect the SQL standard as documented in the equals() method.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
IndexedKey(byte index, Object key)

Method Summary

Modifier and Type	Method and Description
int	compareTo(Object o)
boolean	equals(Object o) If key is empty, we'd like compute equality based on key and index.
byte	getIndex()
Object	getKey()
int	hashCode() Calculate hashCode by index and key if key is empty, return index value if key is not empty, return the key.hashCode()
void	setSecondarySortOrder(boolean[] secondarySortOrder)
void	setUseSecondaryKey(boolean useSecondaryKey)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexedKey

public IndexedKey(byte index,
                  Object key)

Method Detail

getIndex

public byte getIndex()

getKey

public Object getKey()

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

If key is empty, we'd like compute equality based on key and index. If key is not empty, we'd like to compute equality based on just the key (like we normally do). There are two possible cases when two tuples are compared: 1) Compare tuples of same table (same index) 2) Compare tuples of different tables (different index values) In 1) key1 key2 equal? null null Y foo null N null foo N foo foo Y (1,1) (1,1) Y (1,) (1,) Y (1,2) (1,2) Y

In 2) key1 key2 equal? null null N foo null N null foo N foo foo Y (1,1) (1,1) Y (1,) (1,) N (1,2) (1,2) Y

Overrides:

equals in class Object

Parameters:

o -

Returns:

hashCode

public int hashCode()

Calculate hashCode by index and key if key is empty, return index value if key is not empty, return the key.hashCode()

Overrides:

hashCode in class Object

compareTo

public int compareTo(Object o)

Specified by:

compareTo in interface Comparable

setUseSecondaryKey

public void setUseSecondaryKey(boolean useSecondaryKey)

setSecondarySortOrder

public void setSecondarySortOrder(boolean[] secondarySortOrder)