Skip to content

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:

Number of Partitions

int getPartitions(
  KafkaTopicClient kafkaTopicClient)

LogicalSchema

LogicalSchema getSchema()

Sources

List<PlanNode> getSources()

Implementations

Creating Instance

PlanNode takes the following to be created:

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
Back to top