public class JoinUtil
extends java.lang.Object
Constructor and Description |
---|
JoinUtil() |
Modifier and Type | Method and Description |
---|---|
static java.util.ArrayList<java.lang.Object> |
computeKeys(java.lang.Object row,
java.util.List<ExprNodeEvaluator> keyFields,
java.util.List<ObjectInspector> keyFieldsOI)
Return the key as a standard object.
|
static MapJoinKey |
computeMapJoinKeys(MapJoinKey key,
java.lang.Object row,
java.util.List<ExprNodeEvaluator> keyFields,
java.util.List<ObjectInspector> keyFieldsOI)
Return the key as a standard object.
|
static java.lang.Object[] |
computeMapJoinValues(java.lang.Object row,
java.util.List<ExprNodeEvaluator> valueFields,
java.util.List<ObjectInspector> valueFieldsOI,
java.util.List<ExprNodeEvaluator> filters,
java.util.List<ObjectInspector> filtersOI,
int[] filterMap)
Return the value as a standard object.
|
static java.util.ArrayList<java.lang.Object> |
computeValues(java.lang.Object row,
java.util.List<ExprNodeEvaluator> valueFields,
java.util.List<ObjectInspector> valueFieldsOI,
boolean hasFilter)
Return the value as a standard object.
|
static java.util.List<ObjectInspector>[] |
getObjectInspectorsFromEvaluators(java.util.List<ExprNodeEvaluator>[] exprEntries,
ObjectInspector[] inputObjInspector,
int posBigTableAlias,
int tagLen) |
static RowContainer<java.util.List<java.lang.Object>> |
getRowContainer(Configuration hconf,
java.util.List<ObjectInspector> structFieldObjectInspectors,
java.lang.Byte alias,
int containerSize,
TableDesc[] spillTableDesc,
JoinDesc conf,
boolean noFilter,
Reporter reporter) |
static SerDe |
getSpillSerDe(byte alias,
TableDesc[] spillTableDesc,
JoinDesc conf,
boolean noFilter) |
static TableDesc |
getSpillTableDesc(java.lang.Byte alias,
TableDesc[] spillTableDesc,
JoinDesc conf,
boolean noFilter) |
static java.util.List<ObjectInspector>[] |
getStandardObjectInspectors(java.util.List<ObjectInspector>[] aliasToObjectInspectors,
int posBigTableAlias,
int tagLen) |
protected static boolean |
hasAnyFiltered(short tag) |
static TableDesc[] |
initSpillTables(JoinDesc conf,
boolean noFilter) |
protected static short |
isFiltered(java.lang.Object row,
java.util.List<ExprNodeEvaluator> filters,
java.util.List<ObjectInspector> ois,
int[] filterMap)
Returns true if the row does not pass through filters.
|
protected static boolean |
isFiltered(short filter,
int tag) |
static int |
populateJoinKeyValue(java.util.List<ExprNodeEvaluator>[] outMap,
java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> inputMap,
java.lang.Byte[] order,
int posBigTableAlias) |
static int |
populateJoinKeyValue(java.util.List<ExprNodeEvaluator>[] outMap,
java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> inputMap,
int posBigTableAlias) |
public static java.util.List<ObjectInspector>[] getObjectInspectorsFromEvaluators(java.util.List<ExprNodeEvaluator>[] exprEntries, ObjectInspector[] inputObjInspector, int posBigTableAlias, int tagLen) throws HiveException
HiveException
public static java.util.List<ObjectInspector>[] getStandardObjectInspectors(java.util.List<ObjectInspector>[] aliasToObjectInspectors, int posBigTableAlias, int tagLen)
public static int populateJoinKeyValue(java.util.List<ExprNodeEvaluator>[] outMap, java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> inputMap, int posBigTableAlias) throws HiveException
HiveException
public static int populateJoinKeyValue(java.util.List<ExprNodeEvaluator>[] outMap, java.util.Map<java.lang.Byte,java.util.List<ExprNodeDesc>> inputMap, java.lang.Byte[] order, int posBigTableAlias) throws HiveException
HiveException
public static java.util.ArrayList<java.lang.Object> computeKeys(java.lang.Object row, java.util.List<ExprNodeEvaluator> keyFields, java.util.List<ObjectInspector> keyFieldsOI) throws HiveException
HiveException
public static MapJoinKey computeMapJoinKeys(MapJoinKey key, java.lang.Object row, java.util.List<ExprNodeEvaluator> keyFields, java.util.List<ObjectInspector> keyFieldsOI) throws HiveException
HiveException
public static java.lang.Object[] computeMapJoinValues(java.lang.Object row, java.util.List<ExprNodeEvaluator> valueFields, java.util.List<ObjectInspector> valueFieldsOI, java.util.List<ExprNodeEvaluator> filters, java.util.List<ObjectInspector> filtersOI, int[] filterMap) throws HiveException
HiveException
public static java.util.ArrayList<java.lang.Object> computeValues(java.lang.Object row, java.util.List<ExprNodeEvaluator> valueFields, java.util.List<ObjectInspector> valueFieldsOI, boolean hasFilter) throws HiveException
HiveException
protected static short isFiltered(java.lang.Object row, java.util.List<ExprNodeEvaluator> filters, java.util.List<ObjectInspector> ois, int[] filterMap) throws HiveException
HiveException
protected static boolean isFiltered(short filter, int tag)
protected static boolean hasAnyFiltered(short tag)
public static TableDesc getSpillTableDesc(java.lang.Byte alias, TableDesc[] spillTableDesc, JoinDesc conf, boolean noFilter)
public static SerDe getSpillSerDe(byte alias, TableDesc[] spillTableDesc, JoinDesc conf, boolean noFilter)
public static RowContainer<java.util.List<java.lang.Object>> getRowContainer(Configuration hconf, java.util.List<ObjectInspector> structFieldObjectInspectors, java.lang.Byte alias, int containerSize, TableDesc[] spillTableDesc, JoinDesc conf, boolean noFilter, Reporter reporter) throws HiveException
HiveException
Copyright © 2012 The Apache Software Foundation