Class PhysicalOperatorUtil
java.lang.Object
org.apache.drill.exec.physical.base.PhysicalOperatorUtil
-
Method Summary
Modifier and TypeMethodDescriptionstatic List<MinorFragmentEndpoint>
Helper method to create a list ofMinorFragmentEndpoint
instances from a given endpoint assignment list.static Set<Class<? extends PhysicalOperator>>
getSubTypes
(ScanResult classpathScan) static LogicalExpression
materializeExpression
(LogicalExpression expr, VectorAccessible incoming, FragmentContext context) Helper method to materialize the given logical expression using theExpressionTreeMaterializer
.
-
Method Details
-
getSubTypes
-
getIndexOrderedEndpoints
public static List<MinorFragmentEndpoint> getIndexOrderedEndpoints(List<CoordinationProtos.DrillbitEndpoint> endpoints) Helper method to create a list ofMinorFragmentEndpoint
instances from a given endpoint assignment list.- Parameters:
endpoints
- Assigned endpoint list. Index of each endpoint in list indicates the MinorFragmentId of the fragment that is assigned to the endpoint.- Returns:
- a list of (minor fragment id, endpoint) pairs in which the minor fragment ID is reified as a member. Items are indexed by minor fragment ID.
-
materializeExpression
public static LogicalExpression materializeExpression(LogicalExpression expr, VectorAccessible incoming, FragmentContext context) Helper method to materialize the given logical expression using theExpressionTreeMaterializer
.- Parameters:
expr
- Logical expression to materializeincoming
- Incoming record batchcontext
- Fragment context
-