Package | Description |
---|---|
org.apache.flink.api.common.operators | |
org.apache.flink.api.java.operators | |
org.apache.flink.optimizer.dag | |
org.apache.flink.optimizer.dataproperties |
Modifier and Type | Class and Description |
---|---|
class |
DualInputSemanticProperties
Container for the semantic properties associated to a dual input operator.
|
static class |
SemanticProperties.EmptySemanticProperties |
class |
SingleInputSemanticProperties
Container for the semantic properties associated to a single input operator.
|
static class |
SingleInputSemanticProperties.AllFieldsForwardedProperties |
Modifier and Type | Method and Description |
---|---|
SemanticProperties |
UdfOperator.getSemanticProperties()
Gets the semantic properties that have been set for the user-defined functions (UDF).
|
Modifier and Type | Class and Description |
---|---|
static class |
BinaryUnionNode.UnionSemanticProperties |
Modifier and Type | Method and Description |
---|---|
GlobalProperties |
GlobalProperties.filterBySemanticProperties(SemanticProperties props,
int input)
Filters these GlobalProperties by the fields that are forwarded to the output as described by
the SemanticProperties.
|
LocalProperties |
LocalProperties.filterBySemanticProperties(SemanticProperties props,
int input)
Filters these LocalProperties by the fields that are forwarded to the output as described by
the SemanticProperties.
|
RequestedLocalProperties |
RequestedLocalProperties.filterBySemanticProperties(SemanticProperties props,
int input)
Filters these properties by what can be preserved by the given SemanticProperties when
propagated down to the given input.
|
RequestedGlobalProperties |
RequestedGlobalProperties.filterBySemanticProperties(SemanticProperties props,
int input)
Filters these properties by what can be preserved by the given SemanticProperties when
propagated down to the given input.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.