Interface | Description |
---|---|
Command |
Class | Description |
---|---|
Aggregate |
:: DeveloperApi ::
Groups input data by
groupingExpressions and computes the aggregateExpressions for each
group. |
BroadcastNestedLoopJoin |
:: DeveloperApi ::
|
BuildLeft | |
BuildRight | |
BuildSide | |
CacheCommand |
:: DeveloperApi ::
|
CartesianProduct |
:: DeveloperApi ::
|
DescribeCommand |
:: DeveloperApi ::
|
Distinct |
:: DeveloperApi ::
Computes the set of distinct input rows using a HashSet.
|
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. |
HashJoin |
:: DeveloperApi ::
|
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.
|
Project |
:: DeveloperApi ::
|
Sample |
:: DeveloperApi ::
|
SetCommand |
:: DeveloperApi ::
|
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 |