| Interface | Description |
|---|---|
| BinaryNode | |
| Command | |
| LeafNode | |
| RunnableCommand | |
| UnaryNode |
| Class | Description |
|---|---|
| AddExchange |
Ensures that the
Partitioning
of input data meets the
Distribution requirements for
each operator by inserting Exchange Operators where required. |
| 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. |
| BigDecimalSerializer | |
| CacheTableCommand |
:: 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 ::
|
| ExecutedCommand | |
| ExistingRdd | |
| ExplainCommand |
An explain command for users to see how a command will be executed.
|
| ExternalSort |
:: DeveloperApi ::
Performs a sort, spilling to disk as needed.
|
| ExtractPythonUdfs |
Extracts PythonUDFs from operators, rewriting the query plan so that the UDF can be evaluated
alone in a batch.
|
| 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.
|
| HyperLogLogSerializer | |
| IntegerHashSetSerializer | |
| Intersect |
:: DeveloperApi ::
Returns the rows in left that also appear in right using the built in spark
intersection function.
|
| KryoResourcePool | |
| Limit |
:: DeveloperApi ::
Take the first limit elements.
|
| LogicalRDD | |
| LongHashSetSerializer | |
| OpenHashSetSerializer | |
| OutputFaker |
:: DeveloperApi ::
A plan node that does nothing but lie about the output of its child.
|
| PhysicalRDD | |
| Project |
:: DeveloperApi ::
|
| PythonUDF |
A serialized version of a Python lambda function.
|
| RDDConversions |
:: DeveloperApi ::
|
| Sample |
:: DeveloperApi ::
|
| SetCommand |
:: DeveloperApi ::
|
| Sort |
:: DeveloperApi ::
Performs a sort on-heap.
|
| SparkLogicalPlan | |
| SparkPlan |
:: DeveloperApi ::
|
| SparkSqlSerializer | |
| SparkStrategies | |
| TakeOrdered |
:: DeveloperApi ::
Take the first limit elements as defined by the sortOrder.
|
| UncacheTableCommand |
:: DeveloperApi ::
|
| Union |
:: DeveloperApi ::
|
| Exception | Description |
|---|---|
| QueryExecutionException |