com.cloudera.impala.planner.DataSink Class Reference

Inheritance diagram for com.cloudera.impala.planner.DataSink:

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

Public Member Functions
abstract String	getExplainString (String prefix, String detailPrefix, TExplainLevel explainLevel)
void	setFragment (PlanFragment fragment)
PlanFragment	getFragment ()
long	getPerHostMemCost ()
void	computeCosts ()

Static Public Member Functions
static DataSink	createDataSink (Table table, List< Expr > partitionKeyExprs, boolean overwrite)

Protected Member Functions
abstract TDataSink	toThrift ()

Protected Attributes
long	perHostMemCost_ = -1
PlanFragment	fragment_

Detailed Description

A DataSink describes the destination of a plan fragment's output rows. The destination could be another plan fragment on a remote machine, or a table into which the rows are to be inserted (i.e., the destination of the last fragment of an INSERT statement).

Definition at line 34 of file DataSink.java.

Member Function Documentation

void com.cloudera.impala.planner.DataSink.computeCosts ( )

inline

Estimates the cost of executing this DataSink. Currently only sets perHostMemCost.

Definition at line 79 of file DataSink.java.

References com.cloudera.impala.planner.DataSink.perHostMemCost_.

static DataSink com.cloudera.impala.planner.DataSink.createDataSink ( Table  table, List< Expr >  partitionKeyExprs, boolean  overwrite  )

inlinestatic

Returns an output sink appropriate for writing to the given table.

Definition at line 59 of file DataSink.java.

abstract String com.cloudera.impala.planner.DataSink.getExplainString ( String  prefix, String  detailPrefix, TExplainLevel  explainLevel  )

abstract

Return an explain string for the DataSink. Each line of the explain will be prefixed by "prefix".

PlanFragment com.cloudera.impala.planner.DataSink.getFragment ( )

inline

Definition at line 53 of file DataSink.java.

References com.cloudera.impala.planner.DataSink.fragment_.

long com.cloudera.impala.planner.DataSink.getPerHostMemCost ( )

inline

Definition at line 54 of file DataSink.java.

References com.cloudera.impala.planner.DataSink.perHostMemCost_.

Referenced by com.cloudera.impala.planner.PipelinedPlanNodeSet.computeResourceEstimates().

void com.cloudera.impala.planner.DataSink.setFragment ( PlanFragment  fragment )

inline

Definition at line 52 of file DataSink.java.

References com.cloudera.impala.planner.DataSink.fragment_.

abstract TDataSink com.cloudera.impala.planner.DataSink.toThrift ( )

abstractprotected

Member Data Documentation

PlanFragment com.cloudera.impala.planner.DataSink.fragment_

protected

Definition at line 41 of file DataSink.java.

Referenced by com.cloudera.impala.planner.DataSink.getFragment(), and com.cloudera.impala.planner.DataSink.setFragment().

long com.cloudera.impala.planner.DataSink.perHostMemCost_ = -1

protected

Definition at line 38 of file DataSink.java.

Referenced by com.cloudera.impala.planner.HdfsTableSink.computeCosts(), com.cloudera.impala.planner.DataSink.computeCosts(), com.cloudera.impala.planner.HBaseTableSink.getExplainString(), com.cloudera.impala.planner.HdfsTableSink.getExplainString(), and com.cloudera.impala.planner.DataSink.getPerHostMemCost().

---

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

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