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:
PhysicalPlanBuilder
is 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 |