org.apache.drill.exec.physical.base

Class PhysicalOperatorUtil

java.lang.Object

org.apache.drill.exec.physical.base.PhysicalOperatorUtil

public class PhysicalOperatorUtil
extends Object

Method Summary

Modifier and Type	Method and Description
static List<MinorFragmentEndpoint>	getIndexOrderedEndpoints(List<CoordinationProtos.DrillbitEndpoint> endpoints) Helper method to create a list of MinorFragmentEndpoint 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 the ExpressionTreeMaterializer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getSubTypes

public static Set<Class<? extends PhysicalOperator>> getSubTypes(ScanResult classpathScan)

getIndexOrderedEndpoints

public static List<MinorFragmentEndpoint> getIndexOrderedEndpoints(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Helper method to create a list of MinorFragmentEndpoint 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 the ExpressionTreeMaterializer.

Parameters:

expr - Logical expression to materialize

incoming - Incoming record batch

context - Fragment context