com.cloudera.impala.planner.TableSink Class Reference

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

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

Public Member Functions
	TableSink (Table targetTable)
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
final Table	targetTable_
long	perHostMemCost_ = -1
PlanFragment	fragment_

Detailed Description

A DataSink that writes into a table.

Definition at line 23 of file TableSink.java.

Constructor & Destructor Documentation

com.cloudera.impala.planner.TableSink.TableSink ( Table  targetTable )

inline

Definition at line 27 of file TableSink.java.

References com.cloudera.impala.planner.TableSink.targetTable_.

Member Function Documentation

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

inlineinherited

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  )

inlinestaticinherited

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  )

abstractinherited

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

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

inlineinherited

Definition at line 53 of file DataSink.java.

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

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

inlineinherited

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 )

inlineinherited

Definition at line 52 of file DataSink.java.

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

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

abstractprotectedinherited

Member Data Documentation

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

protectedinherited

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

protectedinherited

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().

final Table com.cloudera.impala.planner.TableSink.targetTable_

protected

Definition at line 25 of file TableSink.java.

Referenced by com.cloudera.impala.planner.HdfsTableSink.computeCosts(), com.cloudera.impala.planner.TableSink.TableSink(), com.cloudera.impala.planner.HBaseTableSink.toThrift(), and com.cloudera.impala.planner.HdfsTableSink.toThrift().

---

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

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