com.cloudera.impala.planner.DataPartition Class Reference

Collaboration diagram for com.cloudera.impala.planner.DataPartition:

Public Member Functions
	DataPartition (TPartitionType type, List< Expr > exprs)
	DataPartition (TPartitionType type)
boolean	isPartitioned ()
boolean	isHashPartitioned ()
TPartitionType	getType ()
List< Expr >	getPartitionExprs ()
void	substitute (ExprSubstitutionMap smap, Analyzer analyzer)
TDataPartition	toThrift ()
boolean	equals (Object obj)
String	debugString ()
String	getExplainString ()

Static Public Attributes
static final DataPartition	UNPARTITIONED
static final DataPartition	RANDOM

Private Member Functions
String	getPartitionShortName (TPartitionType partition)

Private Attributes
final TPartitionType	type_
List< Expr >	partitionExprs_

Static Private Attributes
static final Logger	LOG = LoggerFactory.getLogger(DataPartition.class)

Detailed Description

Specification of the partition of a single stream of data. Examples of those streams of data are: the scan of a table; the output of a plan fragment; etc. (ie, this is not restricted to direct exchanges between two fragments, which in the backend is facilitated by the classes DataStreamSender/DataStreamMgr/DataStreamRecvr).

Definition at line 39 of file DataPartition.java.

Constructor & Destructor Documentation

com.cloudera.impala.planner.DataPartition.DataPartition ( TPartitionType  type, List< Expr >  exprs  )

inline

Definition at line 47 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.partitionExprs_, and com.cloudera.impala.planner.DataPartition.type_.

Referenced by com.cloudera.impala.planner.DataPartition.equals().

com.cloudera.impala.planner.DataPartition.DataPartition ( TPartitionType  type )

inline

Definition at line 56 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.partitionExprs_, and com.cloudera.impala.planner.DataPartition.type_.

Member Function Documentation

String com.cloudera.impala.planner.DataPartition.debugString ( )

inline

Definition at line 95 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.partitionExprs_, and com.cloudera.impala.planner.DataPartition.type_.

boolean com.cloudera.impala.planner.DataPartition.equals ( Object  obj )

inline

Definition at line 87 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.DataPartition(), com.cloudera.impala.planner.DataPartition.partitionExprs_, and com.cloudera.impala.planner.DataPartition.type_.

String com.cloudera.impala.planner.DataPartition.getExplainString ( )

inline

Definition at line 102 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.getPartitionShortName(), com.cloudera.impala.planner.DataPartition.partitionExprs_, and com.cloudera.impala.planner.DataPartition.type_.

Referenced by com.cloudera.impala.planner.PlanFragment.getExplainString().

List<Expr> com.cloudera.impala.planner.DataPartition.getPartitionExprs ( )

inline

Definition at line 72 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.partitionExprs_.

Referenced by com.cloudera.impala.planner.PlanFragment.finalize(), and com.cloudera.impala.planner.PlanFragment.getNumDistinctValues().

String com.cloudera.impala.planner.DataPartition.getPartitionShortName ( TPartitionType  partition )

inlineprivate

Definition at line 115 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.RANDOM, and com.cloudera.impala.planner.DataPartition.UNPARTITIONED.

Referenced by com.cloudera.impala.planner.DataPartition.getExplainString().

TPartitionType com.cloudera.impala.planner.DataPartition.getType ( )

inline

Definition at line 71 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.type_.

Referenced by com.cloudera.impala.planner.PlanFragment.isPartitioned().

boolean com.cloudera.impala.planner.DataPartition.isHashPartitioned ( )

inline

Definition at line 70 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.type_.

Referenced by com.cloudera.impala.planner.PlanFragment.finalize().

boolean com.cloudera.impala.planner.DataPartition.isPartitioned ( )

inline

Definition at line 69 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.type_.

void com.cloudera.impala.planner.DataPartition.substitute ( ExprSubstitutionMap  smap, Analyzer  analyzer  )

inline

Definition at line 74 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.partitionExprs_.

TDataPartition com.cloudera.impala.planner.DataPartition.toThrift ( )

inline

Definition at line 78 of file DataPartition.java.

References com.cloudera.impala.planner.DataPartition.partitionExprs_, and com.cloudera.impala.planner.DataPartition.type_.

Referenced by com.cloudera.impala.planner.DataStreamSink.toThrift().

Member Data Documentation

final Logger com.cloudera.impala.planner.DataPartition.LOG = LoggerFactory.getLogger(DataPartition.class)

staticprivate

Definition at line 40 of file DataPartition.java.

List<Expr> com.cloudera.impala.planner.DataPartition.partitionExprs_

private

Definition at line 45 of file DataPartition.java.

Referenced by com.cloudera.impala.planner.DataPartition.DataPartition(), com.cloudera.impala.planner.DataPartition.debugString(), com.cloudera.impala.planner.DataPartition.equals(), com.cloudera.impala.planner.DataPartition.getExplainString(), com.cloudera.impala.planner.DataPartition.getPartitionExprs(), com.cloudera.impala.planner.DataPartition.substitute(), and com.cloudera.impala.planner.DataPartition.toThrift().

final DataPartition com.cloudera.impala.planner.DataPartition.RANDOM

static

Initial value:

=
      new DataPartition(TPartitionType.RANDOM)

Definition at line 66 of file DataPartition.java.

Referenced by com.cloudera.impala.planner.DistributedPlanner.createScanFragment(), com.cloudera.impala.planner.DistributedPlanner.createUnionNodeFragment(), and com.cloudera.impala.planner.DataPartition.getPartitionShortName().

final TPartitionType com.cloudera.impala.planner.DataPartition.type_

private

Definition at line 42 of file DataPartition.java.

Referenced by com.cloudera.impala.planner.DataPartition.DataPartition(), com.cloudera.impala.planner.DataPartition.debugString(), com.cloudera.impala.planner.DataPartition.equals(), com.cloudera.impala.planner.DataPartition.getExplainString(), com.cloudera.impala.planner.DataPartition.getType(), com.cloudera.impala.planner.DataPartition.isHashPartitioned(), com.cloudera.impala.planner.DataPartition.isPartitioned(), and com.cloudera.impala.planner.DataPartition.toThrift().

final DataPartition com.cloudera.impala.planner.DataPartition.UNPARTITIONED

static

Initial value:

=
      new DataPartition(TPartitionType.UNPARTITIONED)

Definition at line 63 of file DataPartition.java.

Referenced by com.cloudera.impala.planner.DistributedPlanner.createAggregationFragment(), com.cloudera.impala.planner.DistributedPlanner.createAnalyticFragment(), com.cloudera.impala.planner.DistributedPlanner.createMergeFragment(), com.cloudera.impala.planner.DistributedPlanner.createOrderByFragment(), com.cloudera.impala.planner.Planner.createPlan(), com.cloudera.impala.planner.DistributedPlanner.createPlanFragments(), com.cloudera.impala.planner.AnalyticPlanner.createSortGroupPlan(), com.cloudera.impala.planner.DistributedPlanner.createUnionNodeFragment(), com.cloudera.impala.analysis.AggregateInfo.getPartition(), com.cloudera.impala.planner.DataPartition.getPartitionShortName(), and com.cloudera.impala.planner.PlanFragment.PlanFragment().

---

The documentation for this class was generated from the following file:

• fe/src/main/java/com/cloudera/impala/planner/DataPartition.java