class DataSourceNode extends PlanNode {

  @Override
  public SchemaKStream<?> buildStream(final KsqlQueryBuilder builder) {
    final Stacker contextStacker = builder.buildNodeContext(getId().toString());
    return schemaKStreamFactory.create(
        builder,
        dataSource,
        contextStacker.push(SOURCE_OP_NAME)
    );
  }

  public  DataSourceNode(
      final PlanNodeId id,
      final DataSource dataSource,
      final SourceName alias
  );
    DataSourceNode(
      final PlanNodeId id,
      final DataSource dataSource,
      final SourceName alias,
      final SchemaKStreamFactory schemaKStreamFactory
  );

}