com.cloudera.impala.planner.DataStreamSink Class Reference

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

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

Public Member Functions
	DataStreamSink (ExchangeNode exchNode, DataPartition partition)
String	getExplainString (String prefix, String detailPrefix, TExplainLevel detailLevel)
DataPartition	getOutputPartition ()
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
TDataSink	toThrift ()

Protected Attributes
long	perHostMemCost_ = -1
PlanFragment	fragment_

Private Attributes
final ExchangeNode	exchNode_
final DataPartition	outputPartition_

Detailed Description

Data sink that forwards data to an exchange node.

Definition at line 26 of file DataStreamSink.java.

Constructor & Destructor Documentation

com.cloudera.impala.planner.DataStreamSink.DataStreamSink ( ExchangeNode  exchNode, DataPartition  partition  )

inline

Definition at line 30 of file DataStreamSink.java.

References com.cloudera.impala.planner.DataStreamSink.exchNode_, and com.cloudera.impala.planner.DataStreamSink.outputPartition_.

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.

String com.cloudera.impala.planner.DataStreamSink.getExplainString ( String  prefix, String  detailPrefix, TExplainLevel  detailLevel  )

inline

Definition at line 38 of file DataStreamSink.java.

References com.cloudera.impala.planner.DataStreamSink.exchNode_, com.cloudera.impala.planner.ExchangeNode.getDisplayLabelDetail(), and com.cloudera.impala.planner.PlanNode.getId().

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

inlineinherited

Definition at line 53 of file DataSink.java.

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

DataPartition com.cloudera.impala.planner.DataStreamSink.getOutputPartition ( )

inline

Definition at line 57 of file DataStreamSink.java.

References com.cloudera.impala.planner.DataStreamSink.outputPartition_.

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_.

TDataSink com.cloudera.impala.planner.DataStreamSink.toThrift ( )

inlineprotected

Definition at line 49 of file DataStreamSink.java.

References com.cloudera.impala.planner.DataStreamSink.exchNode_, com.cloudera.impala.planner.PlanNode.getId(), com.cloudera.impala.planner.DataStreamSink.outputPartition_, and com.cloudera.impala.planner.DataPartition.toThrift().

Member Data Documentation

final ExchangeNode com.cloudera.impala.planner.DataStreamSink.exchNode_

private

Definition at line 27 of file DataStreamSink.java.

Referenced by com.cloudera.impala.planner.DataStreamSink.DataStreamSink(), com.cloudera.impala.planner.DataStreamSink.getExplainString(), and com.cloudera.impala.planner.DataStreamSink.toThrift().

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

final DataPartition com.cloudera.impala.planner.DataStreamSink.outputPartition_

private

Definition at line 28 of file DataStreamSink.java.

Referenced by com.cloudera.impala.planner.DataStreamSink.DataStreamSink(), com.cloudera.impala.planner.DataStreamSink.getOutputPartition(), and com.cloudera.impala.planner.DataStreamSink.toThrift().

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

---

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

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