public class FlatMapDescriptor extends OperatorDescriptorSingle
keyList, keys
Constructor and Description |
---|
FlatMapDescriptor() |
Modifier and Type | Method and Description |
---|---|
GlobalProperties |
computeGlobalProperties(GlobalProperties gProps)
Returns the global properties which are present after the operator was applied on the
provided global properties.
|
LocalProperties |
computeLocalProperties(LocalProperties lProps)
Returns the local properties which are present after the operator was applied on the provided
local properties.
|
protected List<RequestedGlobalProperties> |
createPossibleGlobalProperties()
Returns a list of global properties that are required by this operator descriptor.
|
protected List<RequestedLocalProperties> |
createPossibleLocalProperties()
Returns a list of local properties that are required by this operator descriptor.
|
DriverStrategy |
getStrategy()
Gets the runtime strategy to be executed by this operator.
|
SingleInputPlanNode |
instantiate(Channel in,
SingleInputNode node) |
getPossibleGlobalProperties, getPossibleLocalProperties
public DriverStrategy getStrategy()
AbstractOperatorDescriptor
public SingleInputPlanNode instantiate(Channel in, SingleInputNode node)
instantiate
in class OperatorDescriptorSingle
protected List<RequestedGlobalProperties> createPossibleGlobalProperties()
OperatorDescriptorSingle
createPossibleGlobalProperties
in class OperatorDescriptorSingle
protected List<RequestedLocalProperties> createPossibleLocalProperties()
OperatorDescriptorSingle
createPossibleLocalProperties
in class OperatorDescriptorSingle
public GlobalProperties computeGlobalProperties(GlobalProperties gProps)
OperatorDescriptorSingle
computeGlobalProperties
in class OperatorDescriptorSingle
gProps
- The global properties on which the operator is applied.public LocalProperties computeLocalProperties(LocalProperties lProps)
OperatorDescriptorSingle
computeLocalProperties
in class OperatorDescriptorSingle
lProps
- The local properties on which the operator is applied.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.