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

java.lang.Object
  org.apache.hadoop.hive.ql.exec.persistence.MapJoinKey

Direct Known Subclasses:

MapJoinKeyBytes, MapJoinKeyObject

public abstract class MapJoinKey
extends Object

The base class for MapJoinKey; also acts as a factory for creating and reading the keys, choosing whether size-optimized byte-array based MJKBytes can be used.

Constructor Summary

MapJoinKey()

Method Summary

abstract boolean	hasAnyNulls(int fieldCount, boolean[] nullsafes)
static MapJoinKey	read(ByteStream.Output output, MapJoinKey key, MapJoinObjectSerDeContext context, org.apache.hadoop.io.Writable writable, boolean mayReuseKey)
static MapJoinKey	readFromRow(ByteStream.Output output, MapJoinKey key, Object row, List<ExprNodeEvaluator> fields, List<ObjectInspector> keyFieldsOI, boolean mayReuseKey)
static MapJoinKey	readFromVector(ByteStream.Output output, MapJoinKey key, VectorHashKeyWrapper kw, VectorExpressionWriter[] keyOutputWriters, VectorHashKeyWrapperBatch keyWrapperBatch, boolean mayReuseKey)
abstract void	write(MapJoinObjectSerDeContext context, ObjectOutputStream out)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapJoinKey

public MapJoinKey()

Method Detail

read

public static MapJoinKey read(ByteStream.Output output,
                              MapJoinKey key,
                              MapJoinObjectSerDeContext context,
                              org.apache.hadoop.io.Writable writable,
                              boolean mayReuseKey)
                       throws SerDeException

Throws:

SerDeException

readFromVector

public static MapJoinKey readFromVector(ByteStream.Output output,
                                        MapJoinKey key,
                                        VectorHashKeyWrapper kw,
                                        VectorExpressionWriter[] keyOutputWriters,
                                        VectorHashKeyWrapperBatch keyWrapperBatch,
                                        boolean mayReuseKey)
                                 throws HiveException

Throws:

HiveException

readFromRow

public static MapJoinKey readFromRow(ByteStream.Output output,
                                     MapJoinKey key,
                                     Object row,
                                     List<ExprNodeEvaluator> fields,
                                     List<ObjectInspector> keyFieldsOI,
                                     boolean mayReuseKey)
                              throws HiveException

Throws:

HiveException

write

public abstract void write(MapJoinObjectSerDeContext context,
                           ObjectOutputStream out)
                    throws IOException,
                           SerDeException

Throws:

IOException

SerDeException

hasAnyNulls

public abstract boolean hasAnyNulls(int fieldCount,
                                    boolean[] nullsafes)