com.cloudera.impala.planner.HBaseTableSink Class Reference

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

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

Public Member Functions
	HBaseTableSink (Table targetTable)
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
TDataSink	toThrift ()

Protected Attributes
final Table	targetTable_
long	perHostMemCost_ = -1
PlanFragment	fragment_

Detailed Description

Class used to represent a Sink that will transport data from a plan fragment into an HBase table using HTable.

Definition at line 30 of file HBaseTableSink.java.

Constructor & Destructor Documentation

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

inline

Definition at line 31 of file HBaseTableSink.java.

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.HBaseTableSink.getExplainString ( String  prefix, String  detailPrefix, TExplainLevel  explainLevel  )

inline

Definition at line 36 of file HBaseTableSink.java.

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

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

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

inlineprotected

Definition at line 49 of file HBaseTableSink.java.

References com.cloudera.impala.catalog.Table.getId(), and com.cloudera.impala.planner.TableSink.targetTable_.

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_

protectedinherited

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/HBaseTableSink.java