org.apache.hadoop.hive.ql.exec.persistence

Class FlatRowContainer

java.lang.Object

java.util.AbstractCollection<Object>

org.apache.hadoop.hive.ql.exec.persistence.FlatRowContainer

All Implemented Interfaces:

Iterable<Object>, Collection<Object>, List<Object>, AbstractRowContainer<List<Object>>, AbstractRowContainer.RowIterator<List<Object>>, MapJoinRowContainer

public class FlatRowContainer
extends AbstractCollection<Object>
implements MapJoinRowContainer, AbstractRowContainer.RowIterator<List<Object>>, List<Object>

Constructor Summary

Constructors

Constructor and Description
FlatRowContainer()

Method Summary

Methods

Modifier and Type	Method and Description
void	add(int index, Object element)
void	add(MapJoinObjectSerDeContext context, org.apache.hadoop.io.BytesWritable value) Called when loading the hashtable.
boolean	addAll(int index, Collection<? extends Object> c)
void	addRow(List<Object> t) add a row into the RowContainer
void	addRow(Object[] value)
void	clearRows() Remove all elements in the RowContainer.
MapJoinRowContainer	copy()
List<Object>	first()
Object	get(int index)
byte	getAliasFilter()
boolean	hasRows()
int	indexOf(Object o)
boolean	isSingleRow()
Iterator<Object>	iterator()
int	lastIndexOf(Object o)
ListIterator<Object>	listIterator()
ListIterator<Object>	listIterator(int index)
List<Object>	next()
Object	remove(int index)
int	rowCount()
AbstractRowContainer.RowIterator<List<Object>>	rowIter()
Object	set(int index, Object element)
int	size()
List<Object>	subList(int fromIndex, int toIndex)
Object[]	toArray()
void	write(MapJoinObjectSerDeContext valueContext, ObjectOutputStream out)

Methods inherited from class java.util.AbstractCollection

add, addAll, clear, contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.List

add, addAll, clear, contains, containsAll, equals, hashCode, isEmpty, remove, removeAll, retainAll, toArray

Constructor Detail

FlatRowContainer

public FlatRowContainer()

Method Detail

add

public void add(MapJoinObjectSerDeContext context,
       org.apache.hadoop.io.BytesWritable value)
         throws HiveException

Called when loading the hashtable.

Throws:

HiveException

addRow

public void addRow(List<Object> t)
            throws HiveException

Description copied from interface: AbstractRowContainer

add a row into the RowContainer

Specified by:

addRow in interface AbstractRowContainer<List<Object>>

Parameters:

t - row

Throws:

HiveException

addRow

public void addRow(Object[] value)
            throws HiveException

Specified by:

addRow in interface MapJoinRowContainer

Throws:

HiveException

write

public void write(MapJoinObjectSerDeContext valueContext,
         ObjectOutputStream out)

Specified by:

write in interface MapJoinRowContainer

rowIter

public AbstractRowContainer.RowIterator<List<Object>> rowIter()
                                                       throws HiveException

Specified by:

rowIter in interface AbstractRowContainer<List<Object>>

Throws:

HiveException

first

public List<Object> first()
                   throws HiveException

Specified by:

first in interface AbstractRowContainer.RowIterator<List<Object>>

Throws:

HiveException

next

public List<Object> next()

Specified by:

next in interface AbstractRowContainer.RowIterator<List<Object>>

hasRows

public boolean hasRows()
                throws HiveException

Specified by:

hasRows in interface AbstractRowContainer<List<Object>>

Returns:

whether the row container has at least 1 row. NOTE: Originally we named this isEmpty, but that name conflicted with another interface.

Throws:

HiveException

isSingleRow

public boolean isSingleRow()
                    throws HiveException

Specified by:

isSingleRow in interface AbstractRowContainer<List<Object>>

Returns:

whether the row container has 1 row.

Throws:

HiveException

rowCount

public int rowCount()
             throws HiveException

Specified by:

rowCount in interface AbstractRowContainer<List<Object>>

Returns:

number of elements in the RowContainer

Throws:

HiveException

clearRows

public void clearRows()

Description copied from interface: AbstractRowContainer

Remove all elements in the RowContainer.

Specified by:

clearRows in interface AbstractRowContainer<List<Object>>

getAliasFilter

public byte getAliasFilter()
                    throws HiveException

Specified by:

getAliasFilter in interface MapJoinRowContainer

Throws:

HiveException

copy

public MapJoinRowContainer copy()
                         throws HiveException

Specified by:

copy in interface MapJoinRowContainer

Throws:

HiveException

size

public int size()

Specified by:

size in interface Collection<Object>

Specified by:

size in interface List<Object>

Specified by:

size in class AbstractCollection<Object>

get

public Object get(int index)

Specified by:

get in interface List<Object>

toArray

public Object[] toArray()

Specified by:

toArray in interface Collection<Object>

Specified by:

toArray in interface List<Object>

Overrides:

toArray in class AbstractCollection<Object>

iterator

public Iterator<Object> iterator()

Specified by:

iterator in interface Iterable<Object>

Specified by:

iterator in interface Collection<Object>

Specified by:

iterator in interface List<Object>

Specified by:

iterator in class AbstractCollection<Object>

listIterator

public ListIterator<Object> listIterator()

Specified by:

listIterator in interface List<Object>

listIterator

public ListIterator<Object> listIterator(int index)

Specified by:

listIterator in interface List<Object>

indexOf

public int indexOf(Object o)

Specified by:

indexOf in interface List<Object>

lastIndexOf

public int lastIndexOf(Object o)

Specified by:

lastIndexOf in interface List<Object>

subList

public List<Object> subList(int fromIndex,
                   int toIndex)

Specified by:

subList in interface List<Object>

addAll

public boolean addAll(int index,
             Collection<? extends Object> c)

Specified by:

addAll in interface List<Object>

set

public Object set(int index,
         Object element)

Specified by:

set in interface List<Object>

add

public void add(int index,
       Object element)

Specified by:

add in interface List<Object>

remove

public Object remove(int index)

Specified by:

remove in interface List<Object>