Modifier and Type | Method and Description |
---|---|
static <T1,T2> ObjectPair<T1,T2> |
ObjectPair.create(T1 f,
T2 s)
Creates a pair.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ObjectPair.equals(ObjectPair<F,S> that) |
Modifier and Type | Method and Description |
---|---|
ObjectPair<HiveKey,org.apache.hadoop.io.BytesWritable> |
KeyValueContainer.next() |
Modifier and Type | Method and Description |
---|---|
ObjectPair<Long,Integer> |
SparkSession.getMemoryAndCores()
Get Spark shuffle memory per task, and total number of cores.
|
ObjectPair<Long,Integer> |
SparkSessionImpl.getMemoryAndCores() |
Modifier and Type | Method and Description |
---|---|
static ObjectPair<List<ReduceSinkOperator>,Map<Byte,List<ExprNodeDesc>>> |
MapJoinProcessor.getKeys(boolean leftInputJoin,
String[] baseSrc,
JoinOperator op) |
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,ObjectPair<SelectOperator,Table>> |
LineageCtx.Index.getFinalSelectOps() |
Modifier and Type | Method and Description |
---|---|
static ObjectPair<PrimitiveObjectInspector,ExprNodeEvaluator> |
PartExprEvalUtils.prepareExpr(ExprNodeGenericFuncDesc expr,
List<String> partColumnNames,
List<PrimitiveTypeInfo> partColumnTypeInfos) |
Modifier and Type | Method and Description |
---|---|
static Object |
PartExprEvalUtils.evaluateExprOnPart(ObjectPair<PrimitiveObjectInspector,ExprNodeEvaluator> pair,
Object partColValues) |
Modifier and Type | Field and Description |
---|---|
Map<ReduceSinkOperator,ObjectPair<SparkEdgeProperty,ReduceWork>> |
GenSparkProcContext.leafOpToFollowingWorkInfo |
Copyright © 2022 The Apache Software Foundation. All rights reserved.