public abstract class MapJoinKey extends Object
Constructor and Description |
---|
MapJoinKey() |
Modifier and Type | Method and Description |
---|---|
abstract boolean |
hasAnyNulls(int fieldCount,
boolean[] nullsafes) |
static boolean |
isSupportedField(ObjectInspector foi) |
static boolean |
isSupportedField(String typeName) |
static boolean |
isSupportedField(TypeInfo typeInfo) |
static MapJoinKey |
read(ByteStream.Output output,
MapJoinObjectSerDeContext context,
org.apache.hadoop.io.Writable writable) |
static MapJoinKey |
readFromRow(ByteStream.Output output,
MapJoinKey key,
Object[] keyObject,
List<ObjectInspector> keyFieldsOI,
boolean mayReuseKey) |
static MapJoinKey |
readFromVector(ByteStream.Output output,
MapJoinKey key,
Object[] keyObject,
List<ObjectInspector> keyOIs,
boolean mayReuseKey) |
static ByteStream.Output |
serializeRow(ByteStream.Output byteStream,
Object[] fieldData,
List<ObjectInspector> fieldOis,
boolean[] sortableSortOrders,
byte[] nullMarkers,
byte[] notNullMarkers)
Serializes row to output.
|
static ByteStream.Output |
serializeVector(ByteStream.Output byteStream,
VectorHashKeyWrapper kw,
VectorExpressionWriter[] keyOutputWriters,
VectorHashKeyWrapperBatch keyWrapperBatch,
boolean[] nulls,
boolean[] sortableSortOrders,
byte[] nullMarkers,
byte[] notNullMarkers)
Serializes row to output for vectorized path.
|
abstract void |
write(MapJoinObjectSerDeContext context,
ObjectOutputStream out) |
public abstract void write(MapJoinObjectSerDeContext context, ObjectOutputStream out) throws IOException, SerDeException
IOException
SerDeException
public abstract boolean hasAnyNulls(int fieldCount, boolean[] nullsafes)
public static MapJoinKey read(ByteStream.Output output, MapJoinObjectSerDeContext context, org.apache.hadoop.io.Writable writable) throws SerDeException, HiveException
SerDeException
HiveException
public static boolean isSupportedField(ObjectInspector foi)
public static boolean isSupportedField(TypeInfo typeInfo)
public static boolean isSupportedField(String typeName)
public static MapJoinKey readFromVector(ByteStream.Output output, MapJoinKey key, Object[] keyObject, List<ObjectInspector> keyOIs, boolean mayReuseKey) throws HiveException
HiveException
public static ByteStream.Output serializeVector(ByteStream.Output byteStream, VectorHashKeyWrapper kw, VectorExpressionWriter[] keyOutputWriters, VectorHashKeyWrapperBatch keyWrapperBatch, boolean[] nulls, boolean[] sortableSortOrders, byte[] nullMarkers, byte[] notNullMarkers) throws HiveException, SerDeException
byteStream
- Output to reuse. Can be null, in that case a new one would be created.HiveException
SerDeException
public static MapJoinKey readFromRow(ByteStream.Output output, MapJoinKey key, Object[] keyObject, List<ObjectInspector> keyFieldsOI, boolean mayReuseKey) throws HiveException
HiveException
public static ByteStream.Output serializeRow(ByteStream.Output byteStream, Object[] fieldData, List<ObjectInspector> fieldOis, boolean[] sortableSortOrders, byte[] nullMarkers, byte[] notNullMarkers) throws HiveException
byteStream
- Output to reuse. Can be null, in that case a new one would be created.HiveException
Copyright © 2019 The Apache Software Foundation. All rights reserved.