Interface | Description |
---|---|
Command | |
HashJoin |
Class | Description |
---|---|
Aggregate |
:: DeveloperApi ::
Groups input data by
groupingExpressions and computes the aggregateExpressions for each
group. |
AggregateEvaluation | |
BatchPythonEvaluation |
:: DeveloperApi ::
Uses PythonRDD to evaluate a
PythonUDF , one partition of tuples at a time. |
BroadcastHashJoin |
:: DeveloperApi ::
Performs an inner hash join of two child relations.
|
BroadcastNestedLoopJoin |
:: DeveloperApi ::
|
BuildLeft | |
BuildRight | |
BuildSide | |
CacheCommand |
:: DeveloperApi ::
|
CartesianProduct |
:: DeveloperApi ::
|
DescribeCommand |
:: DeveloperApi ::
|
Distinct |
:: DeveloperApi ::
Computes the set of distinct input rows using a HashSet.
|
EvaluatePython |
:: DeveloperApi ::
Evaluates a
PythonUDF , appending the result to the end of the input tuple. |
Except |
:: DeveloperApi ::
Returns a table with the elements from left that are not in right using
the built-in spark subtract function.
|
Exchange |
:: DeveloperApi ::
|
ExistingRdd |
:: DeveloperApi ::
|
ExplainCommand |
An explain command for users to see how a command will be executed.
|
Filter |
:: DeveloperApi ::
|
Generate |
:: DeveloperApi ::
Applies a
Generator to a stream of input rows, combining the
output of each into a new stream of rows. |
GeneratedAggregate |
:: DeveloperApi ::
Alternate version of aggregation that leverages projection and thus code generation.
|
HashOuterJoin |
:: DeveloperApi ::
Performs a hash based outer join for two child relations by shuffling the data using
the join keys.
|
Intersect |
:: DeveloperApi ::
Returns the rows in left that also appear in right using the built in spark
intersection function.
|
LeftSemiJoinBNL |
:: DeveloperApi ::
Using BroadcastNestedLoopJoin to calculate left semi join result when there's no join keys
for hash join.
|
LeftSemiJoinHash |
:: DeveloperApi ::
Build the right table's join keys into a HashSet, and iteratively go through the left
table, to find the if join keys are in the Hash set.
|
Limit |
:: DeveloperApi ::
Take the first limit elements.
|
OutputFaker |
:: DeveloperApi ::
A plan node that does nothing but lie about the output of its child.
|
Project |
:: DeveloperApi ::
|
Sample |
:: DeveloperApi ::
|
SetCommand |
:: DeveloperApi ::
|
ShuffledHashJoin |
:: DeveloperApi ::
Performs an inner hash join of two child relations by first shuffling the data using the join
keys.
|
Sort |
:: DeveloperApi ::
|
SparkLogicalPlan |
:: DeveloperApi ::
Allows already planned SparkQueries to be linked into logical query plans.
|
SparkPlan |
:: DeveloperApi ::
|
TakeOrdered |
:: DeveloperApi ::
Take the first limit elements as defined by the sortOrder.
|
Union |
:: DeveloperApi ::
|
Exception | Description |
---|---|
QueryExecutionException |