PlanNode¶
PlanNode is an abstraction of nodes of a query plan.
Contract (Abstract Methods)¶
Building SchemaKStream¶
SchemaKStream<?> buildStream(
PlanBuildContext buildContext)
Builds a SchemaKStream
Used when:
PhysicalPlanBuilderis requested to build a PhysicalPlan- others (less important?)
Number of Partitions¶
int getPartitions(
KafkaTopicClient kafkaTopicClient)
LogicalSchema¶
LogicalSchema getSchema()
Sources¶
List<PlanNode> getSources()
Implementations¶
Creating Instance¶
PlanNode takes the following to be created:
-
PlanNodeId - DataSourceType
- Source Name
Abstract Class
PlanNode is an abstract class and cannot be created directly. It is created indirectly for the concrete PlanNodes.
DataSourceType¶
PlanNode is given a DataSourceType when created.
| DataSourceType | ksqlType |
|---|---|
| KSTREAM | STREAM |
| KTABLE | TABLE |