CreateStreamingTable Unary Logical Command¶
CreateStreamingTable
is a UnaryCommand
and a CreatePipelineDataset that represents CREATE STREAMING TABLE SQL statement (with no AS
clause) in Spark Declarative Pipelines framework.
CreateStreamingTable
is handled by SqlGraphRegistrationContext.
CreateStreamingTableAsSelect for CREATE STREAMING TABLE ... AS
SQL Statement
CREATE STREAMING TABLE ... AS SQL statement (with AS
clause) gives a CreateStreamingTableAsSelect binary logical command.
Creating Instance¶
CreateStreamingTable
takes the following to be created:
- Name (LogicalPlan)
- Columns (
ColumnDefinition
s) - Partitioning Transforms
-
TableSpecBase
-
ifNotExists
flag
CreateStreamingTable
is created when:
SparkSqlAstBuilder
is requested to parse CREATE STREAMING TABLE SQL statement