CreateStreamingTableAsSelect Binary Logical Command¶
CreateStreamingTableAsSelect is a CreatePipelineDatasetAsSelect binary logical command that represents CREATE STREAMING TABLE ... AS SQL statement in Spark Declarative Pipelines framework.
CreateStreamingTableAsSelect is handled by SqlGraphRegistrationContext.
CreateStreamingTable for CREATE STREAMING TABLE SQL Statement
CREATE STREAMING TABLE SQL statement (with no AS clause) gives a CreateStreamingTable unary logical command.
Creating Instance¶
CreateStreamingTableAsSelect takes the following to be created:
- Name (LogicalPlan)
- Colums (
ColumnDefinitions) - Partitioning Transforms
-
TableSpecBase -
CREATEquery (LogicalPlan) - Original SQL Text
-
ifNotExistsflag
CreateStreamingTableAsSelect is created when:
SparkSqlAstBuilderis requested to parse CREATE STREAMING TABLE ... AS SQL statement