Package | Description |
---|---|
org.apache.flink.api.java.sca |
Modifier and Type | Method and Description |
---|---|
TaggedValue |
NestedMethodAnalyzer.analyze() |
static TaggedValue |
UdfAnalyzerUtils.convertTypeInfoToTaggedValue(TaggedValue.Input input,
TypeInformation<?> typeInfo,
String flatFieldExpr,
List<CompositeType.FlatFieldDescriptor> flatFieldDesc,
int[] groupedKeys) |
TaggedValue |
TaggedValue.copy() |
TaggedValue |
TaggedValue.copy(org.objectweb.asm.Type type) |
TaggedValue |
UdfAnalyzer.getInput1AsTaggedValue() |
TaggedValue |
UdfAnalyzer.getInput2AsTaggedValue() |
static TaggedValue |
UdfAnalyzerUtils.mergeContainers(List<TaggedValue> returnValues) |
static TaggedValue |
UdfAnalyzerUtils.mergeInputs(List<TaggedValue> returnValues) |
static TaggedValue |
UdfAnalyzerUtils.mergeReturnValues(List<TaggedValue> returnValues) |
static TaggedValue |
UdfAnalyzerUtils.removeUngroupedInputs(TaggedValue value) |
static TaggedValue |
UdfAnalyzerUtils.tagged(org.objectweb.asm.tree.analysis.Value value) |
Modifier and Type | Method and Description |
---|---|
List<TaggedValue> |
UdfAnalyzer.getCollectorValues() |
Map<String,TaggedValue> |
TaggedValue.getContainerMapping() |
Modifier and Type | Method and Description |
---|---|
void |
TaggedValue.addContainerMapping(String field,
TaggedValue mapping,
ModifiedASMFrame frame) |
static TaggedValue |
UdfAnalyzerUtils.removeUngroupedInputs(TaggedValue value) |
static void |
UdfAnalyzerUtils.removeUngroupedInputsFromContainer(TaggedValue value) |
Modifier and Type | Method and Description |
---|---|
static TaggedValue |
UdfAnalyzerUtils.mergeContainers(List<TaggedValue> returnValues) |
static TaggedValue |
UdfAnalyzerUtils.mergeInputs(List<TaggedValue> returnValues) |
static TaggedValue |
UdfAnalyzerUtils.mergeReturnValues(List<TaggedValue> returnValues) |
Constructor and Description |
---|
TaggedValue(org.objectweb.asm.Type type,
Map<String,TaggedValue> containerMapping) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.