SparkSql

class SparkSql

Specifies a transform where you enter a SQL query using Spark SQL syntax to transform the data. The output is a single DynamicFrame.

Types

Link copied to clipboard
class Builder
Link copied to clipboard
object Companion

Properties

Link copied to clipboard

The data inputs identified by their node names. You can associate a table name with each input node to use in the SQL query. The name you choose must meet the Spark SQL naming restrictions.

Link copied to clipboard

The name of the transform node.

Link copied to clipboard

Specifies the data schema for the SparkSQL transform.

Link copied to clipboard

A list of aliases. An alias allows you to specify what name to use in the SQL for a given input. For example, you have a datasource named "MyDataSource". If you specify From as MyDataSource, and Alias as SqlName, then in your SQL you can do:

Link copied to clipboard

A SQL query that must use Spark SQL syntax and return a single data set.

Functions

Link copied to clipboard
inline fun copy(block: SparkSql.Builder.() -> Unit = {}): SparkSql
Link copied to clipboard
open operator override fun equals(other: Any?): Boolean
Link copied to clipboard
open override fun hashCode(): Int
Link copied to clipboard
open override fun toString(): String