Modifier and Type | Class and Description |
---|---|
static class |
SingleInputSemanticProperties.AllFieldsForwardedProperties |
Modifier and Type | Method and Description |
---|---|
SingleInputSemanticProperties |
SingleInputOperator.getSemanticProperties() |
Modifier and Type | Method and Description |
---|---|
void |
SingleInputOperator.setSemanticProperties(SingleInputSemanticProperties semanticProperties) |
Modifier and Type | Method and Description |
---|---|
SingleInputSemanticProperties |
PartitionOperatorBase.getSemanticProperties() |
SingleInputSemanticProperties |
SortPartitionOperatorBase.getSemanticProperties() |
Modifier and Type | Method and Description |
---|---|
static SingleInputSemanticProperties |
SemanticPropUtil.addSourceFieldOffset(SingleInputSemanticProperties props,
int numInputFields,
int offset)
Creates SemanticProperties by adding an offset to each input field index of the given
SemanticProperties.
|
static SingleInputSemanticProperties |
SemanticPropUtil.createProjectionPropertiesSingle(int[] fields,
CompositeType<?> inType) |
static SingleInputSemanticProperties |
SemanticPropUtil.getSemanticPropsSingle(Set<Annotation> set,
TypeInformation<?> inType,
TypeInformation<?> outType) |
Modifier and Type | Method and Description |
---|---|
static SingleInputSemanticProperties |
SemanticPropUtil.addSourceFieldOffset(SingleInputSemanticProperties props,
int numInputFields,
int offset)
Creates SemanticProperties by adding an offset to each input field index of the given
SemanticProperties.
|
static void |
SemanticPropUtil.getSemanticPropsSingleFromString(SingleInputSemanticProperties result,
String[] forwarded,
String[] nonForwarded,
String[] readSet,
TypeInformation<?> inType,
TypeInformation<?> outType) |
static void |
SemanticPropUtil.getSemanticPropsSingleFromString(SingleInputSemanticProperties result,
String[] forwarded,
String[] nonForwarded,
String[] readSet,
TypeInformation<?> inType,
TypeInformation<?> outType,
boolean skipIncompatibleTypes) |
Modifier and Type | Method and Description |
---|---|
protected SingleInputSemanticProperties |
SingleInputUdfOperator.extractSemanticAnnotations(Class<?> udfClass) |
SingleInputSemanticProperties |
GroupCombineOperator.getSemanticProperties() |
SingleInputSemanticProperties |
SingleInputUdfOperator.getSemanticProperties() |
SingleInputSemanticProperties |
GroupReduceOperator.getSemanticProperties() |
SingleInputSemanticProperties |
ReduceOperator.getSemanticProperties() |
Modifier and Type | Method and Description |
---|---|
void |
SingleInputUdfOperator.setSemanticProperties(SingleInputSemanticProperties properties)
Sets the semantic properties for the user-defined function (UDF).
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.