Package | Description |
---|---|
org.apache.hadoop.hive.contrib.genericudf.example | |
org.apache.hadoop.hive.contrib.udtf.example | |
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.vector.udf | |
org.apache.hadoop.hive.ql.optimizer | |
org.apache.hadoop.hive.ql.optimizer.listbucketingpruner | |
org.apache.hadoop.hive.ql.optimizer.ppr | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.plan | |
org.apache.hadoop.hive.ql.udf | |
org.apache.hadoop.hive.ql.udf.generic |
Standard toolkit and framework for generic User-defined functions.
|
org.apache.hadoop.hive.ql.udf.xml | |
org.apache.hive.hplsql |
Modifier and Type | Method and Description |
---|---|
ObjectInspector |
GenericUDFAdd10.initialize(ObjectInspector[] arguments) |
Modifier and Type | Method and Description |
---|---|
StructObjectInspector |
GenericUDTFExplode2.initialize(ObjectInspector[] args) |
StructObjectInspector |
GenericUDTFCount2.initialize(ObjectInspector[] argOIs) |
Modifier and Type | Class and Description |
---|---|
class |
AmbiguousMethodException
Exception thrown by the UDF and UDAF method resolvers in case a unique method
is not found.
|
class |
NoMatchingMethodException
Exception thrown by the UDF and UDAF method resolvers in case no matching method
is found.
|
class |
UDFArgumentLengthException
exception class, thrown when udf arguments have wrong length.
|
class |
UDFArgumentTypeException
exception class, thrown when udf arguments have wrong types.
|
Modifier and Type | Method and Description |
---|---|
Method |
UDFMethodResolver.getEvalMethod(List<TypeInfo> argClasses)
Gets the evaluate method for the UDF given the parameter types.
|
Method |
NumericOpMethodResolver.getEvalMethod(List<TypeInfo> argTypeInfos) |
Method |
DefaultUDFMethodResolver.getEvalMethod(List<TypeInfo> argClasses)
Gets the evaluate method for the UDF given the parameter types.
|
Method |
ComparisonOpMethodResolver.getEvalMethod(List<TypeInfo> argTypeInfos) |
Class<? extends UDAFEvaluator> |
UDAFEvaluatorResolver.getEvaluatorClass(List<TypeInfo> argClasses)
Gets the evaluator class corresponding to the passed parameter list.
|
Class<? extends UDAFEvaluator> |
NumericUDAFEvaluatorResolver.getEvaluatorClass(List<TypeInfo> argTypeInfos) |
Class<? extends UDAFEvaluator> |
DefaultUDAFEvaluatorResolver.getEvaluatorClass(List<TypeInfo> argClasses)
Gets the evaluator class for the UDAF given the parameter types.
|
static Method |
FunctionRegistry.getMethodInternal(Class<?> udfClass,
List<Method> mlist,
boolean exact,
List<TypeInfo> argumentsPassed)
Gets the closest matching method corresponding to the argument list from a
list of methods.
|
static <T> Method |
FunctionRegistry.getMethodInternal(Class<? extends T> udfClass,
String methodName,
boolean exact,
List<TypeInfo> argumentClasses)
This method is shared between UDFRegistry and UDAFRegistry.
|
Modifier and Type | Method and Description |
---|---|
void |
VectorUDFAdaptor.init() |
Modifier and Type | Method and Description |
---|---|
protected void |
PrunerOperatorFactory.FilterPruner.addPruningPred(Map<TableScanOperator,ExprNodeDesc> opToPrunner,
TableScanOperator top,
ExprNodeDesc new_pruner_pred)
Add pruning predicate.
|
protected void |
PrunerOperatorFactory.FilterPruner.addPruningPred(Map<TableScanOperator,Map<String,ExprNodeDesc>> opToPrunner,
TableScanOperator top,
ExprNodeDesc new_pruner_pred,
Partition part)
Add pruning predicate.
|
protected abstract void |
PrunerOperatorFactory.FilterPruner.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top)
Generate predicate.
|
protected void |
FixedBucketPruningOptimizer.FixedBucketPartitionWalker.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
protected void |
FixedBucketPruningOptimizer.BucketBitsetGenerator.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
Modifier and Type | Method and Description |
---|---|
protected void |
LBProcFactory.LBPRFilterPruner.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
protected void |
LBPartitionProcFactory.LBPRPartitionFilterPruner.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
Modifier and Type | Method and Description |
---|---|
protected void |
OpProcFactory.FilterPPR.generatePredicate(NodeProcessorCtx procCtx,
FilterOperator fop,
TableScanOperator top) |
Modifier and Type | Method and Description |
---|---|
static ExprNodeDesc |
TypeCheckProcFactory.DefaultExprProcessor.getFuncExprNodeDesc(String udfName,
ExprNodeDesc... children) |
protected ExprNodeDesc |
TypeCheckProcFactory.DefaultExprProcessor.getXpathOrFuncExprNodeDesc(ASTNode expr,
boolean isFunction,
ArrayList<ExprNodeDesc> children,
TypeCheckCtx ctx) |
Modifier and Type | Method and Description |
---|---|
static ExprNodeGenericFuncDesc |
ExprNodeGenericFuncDesc.newInstance(GenericUDF genericUDF,
List<ExprNodeDesc> children) |
static ExprNodeGenericFuncDesc |
ExprNodeGenericFuncDesc.newInstance(GenericUDF genericUDF,
String funcText,
List<ExprNodeDesc> children)
Create a ExprNodeGenericFuncDesc based on the genericUDFClass and the
children parameters.
|
Modifier and Type | Method and Description |
---|---|
void |
SettableUDF.setTypeInfo(TypeInfo typeInfo)
Add data to UDF prior to initialization.
|
Modifier and Type | Method and Description |
---|---|
void |
GenericUDFInFile.copyToNewInstance(Object newInstance) |
void |
GenericUDFCurrentUser.copyToNewInstance(Object newInstance) |
void |
GenericUDFCurrentTimestamp.copyToNewInstance(Object newInstance) |
void |
GenericUDFCurrentDate.copyToNewInstance(Object newInstance) |
void |
GenericUDFBaseNumeric.copyToNewInstance(Object newInstance) |
void |
GenericUDFBaseArithmetic.copyToNewInstance(Object newInstance) |
void |
GenericUDF.copyToNewInstance(Object newInstance)
Some information may be set during initialize() which needs to be saved when the UDF is copied.
|
static int |
GenericUDFUtils.StringHelper.getFixedStringSizeForType(PrimitiveObjectInspector poi)
Helper function to help GenericUDFs determine the return type
character length for char/varchar.
|
protected int |
GenericUDFNextDay.getIntDayOfWeek(String dayOfWeek) |
ObjectInspector |
UDFCurrentDB.initialize(ObjectInspector[] arguments) |
StructObjectInspector |
GenericUDTFStack.initialize(ObjectInspector[] args) |
StructObjectInspector |
GenericUDTFPosExplode.initialize(ObjectInspector[] args) |
StructObjectInspector |
GenericUDTFParseUrlTuple.initialize(ObjectInspector[] args) |
StructObjectInspector |
GenericUDTFJSONTuple.initialize(ObjectInspector[] args) |
StructObjectInspector |
GenericUDTFInline.initialize(ObjectInspector[] ois) |
StructObjectInspector |
GenericUDTFGetSplits.initialize(ObjectInspector[] arguments) |
StructObjectInspector |
GenericUDTFExplode.initialize(ObjectInspector[] args) |
StructObjectInspector |
GenericUDTF.initialize(ObjectInspector[] argOIs)
Deprecated.
|
ObjectInspector |
GenericUDFUpper.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFUnion.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFTrunc.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFTranslate.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFToVarchar.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFToUnixTimeStamp.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFToIntervalYearMonth.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFToIntervalDayTime.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFToDecimal.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFToDate.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFToChar.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFToBinary.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFTimestamp.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFSubstringIndex.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFStruct.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFStringToMap.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFSplit.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFSoundex.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFSortArray.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFSize.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFSha2.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFSentences.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFRound.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFRegExp.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFReflect2.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFReflect.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFQuarter.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFPrintf.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFPower.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFOPOr.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFOPNull.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFOPNotNull.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFOPNot.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFOPDTIPlus.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFOPDTIMinus.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFOPAnd.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFNvl.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFNextDay.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFNamedStruct.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFMonthsBetween.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFMapValues.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFMapKeys.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFMap.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFMacro.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFLower.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFLocate.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFLevenshtein.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFLeadLag.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFLastDay.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFInstr.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFInitCap.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFInFile.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFIndex.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFIn.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFIf.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFFromUtcTimestamp.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFFormatNumber.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFFloorCeilBase.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFField.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFFactorial.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFEWAHBitmapEmpty.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFEncode.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFElt.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFDecode.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFDateFormat.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFDateDiff.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFDateAdd.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFDate.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFCurrentUser.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFCurrentTimestamp.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFCurrentDate.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFConcatWS.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFConcat.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFCbrt.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFBridge.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFBetween.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFBaseUnary.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFBaseTrim.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFBasePad.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFBaseNwayCompare.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFBaseNumeric.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFBaseCompare.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFBaseArithmetic.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFAssertTrue.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFArrayContains.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFArray.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFAesBase.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFAddMonths.initialize(ObjectInspector[] arguments) |
ObjectInspector |
GenericUDFAbs.initialize(ObjectInspector[] arguments) |
abstract ObjectInspector |
GenericUDF.initialize(ObjectInspector[] arguments)
Initialize this GenericUDF.
|
ObjectInspector |
BaseMaskUDF.initialize(ObjectInspector[] arguments) |
ObjectInspector |
AbstractGenericUDFEWAHBitmapBop.initialize(ObjectInspector[] arguments) |
StructObjectInspector |
GenericUDTF.initialize(StructObjectInspector argOIs) |
ObjectInspector |
GenericUDF.initializeAndFoldConstants(ObjectInspector[] arguments)
Initialize this GenericUDF.
|
protected void |
GenericUDFUnixTimeStamp.initializeInput(ObjectInspector[] arguments) |
protected void |
GenericUDFToUnixTimeStamp.initializeInput(ObjectInspector[] arguments) |
void |
GenericUDTFStack.process(Object[] args) |
Object |
GenericUDFUtils.StringHelper.setReturnValue(String val) |
void |
GenericUDFToVarchar.setTypeInfo(TypeInfo typeInfo)
Provide varchar type parameters for the output object inspector.
|
void |
GenericUDFToDecimal.setTypeInfo(TypeInfo typeInfo) |
void |
GenericUDFToChar.setTypeInfo(TypeInfo typeInfo)
Provide char type parameters for the output object inspector.
|
Constructor and Description |
---|
ConversionHelper(Method m,
ObjectInspector[] parameterOIs)
Create a PrimitiveConversionHelper for Method m.
|
StringHelper(PrimitiveObjectInspector.PrimitiveCategory type) |
Modifier and Type | Method and Description |
---|---|
ObjectInspector |
GenericUDFXPath.initialize(ObjectInspector[] arguments) |
Modifier and Type | Method and Description |
---|---|
ObjectInspector |
Udf.initialize(ObjectInspector[] arguments)
Initialize UDF
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.