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 (
ColumnDefinitions) - Partitioning Transforms
-
TableSpecBase -
ifNotExistsflag
CreateStreamingTable is created when:
SparkSqlAstBuilderis requested to parse CREATE STREAMING TABLE SQL statement