{
  "plan" : [ {
    "@type" : "ksqlPlanV1",
    "statementText" : "CREATE STREAM TEST (ROWKEY BIGINT KEY, ID BIGINT, NAME STRING, VALUE BIGINT) WITH (KAFKA_TOPIC='left_topic', KEY='ID', VALUE_FORMAT='AVRO');",
    "ddlCommand" : {
      "@type" : "createStreamV1",
      "sourceName" : "TEST",
      "schema" : "`ROWKEY` BIGINT KEY, `ID` BIGINT, `NAME` STRING, `VALUE` BIGINT",
      "keyField" : "ID",
      "timestampColumn" : null,
      "topicName" : "left_topic",
      "formats" : {
        "keyFormat" : {
          "format" : "KAFKA",
          "properties" : { }
        },
        "valueFormat" : {
          "format" : "AVRO",
          "properties" : { }
        },
        "options" : [ ]
      },
      "windowInfo" : null
    },
    "queryPlan" : null
  }, {
    "@type" : "ksqlPlanV1",
    "statementText" : "CREATE STREAM TEST_STREAM (ROWKEY BIGINT KEY, ID BIGINT, F1 STRING, F2 BIGINT) WITH (KAFKA_TOPIC='right_topic', KEY='ID', VALUE_FORMAT='AVRO');",
    "ddlCommand" : {
      "@type" : "createStreamV1",
      "sourceName" : "TEST_STREAM",
      "schema" : "`ROWKEY` BIGINT KEY, `ID` BIGINT, `F1` STRING, `F2` BIGINT",
      "keyField" : "ID",
      "timestampColumn" : null,
      "topicName" : "right_topic",
      "formats" : {
        "keyFormat" : {
          "format" : "KAFKA",
          "properties" : { }
        },
        "valueFormat" : {
          "format" : "AVRO",
          "properties" : { }
        },
        "options" : [ ]
      },
      "windowInfo" : null
    },
    "queryPlan" : null
  }, {
    "@type" : "ksqlPlanV1",
    "statementText" : "CREATE STREAM INNER_JOIN AS SELECT\n  T.*,\n  TT.NAME NAME\nFROM TEST TT\nINNER JOIN TEST_STREAM T WITHIN 11 SECONDS ON ((T.ID = TT.ID))\nEMIT CHANGES",
    "ddlCommand" : {
      "@type" : "createStreamV1",
      "sourceName" : "INNER_JOIN",
      "schema" : "`ROWKEY` BIGINT KEY, `T_ROWTIME` BIGINT, `T_ROWKEY` BIGINT, `T_ID` BIGINT, `T_F1` STRING, `T_F2` BIGINT, `NAME` STRING",
      "keyField" : null,
      "timestampColumn" : null,
      "topicName" : "INNER_JOIN",
      "formats" : {
        "keyFormat" : {
          "format" : "KAFKA",
          "properties" : { }
        },
        "valueFormat" : {
          "format" : "AVRO",
          "properties" : { }
        },
        "options" : [ ]
      },
      "windowInfo" : null
    },
    "queryPlan" : {
      "sources" : [ "TEST", "TEST_STREAM" ],
      "sink" : "INNER_JOIN",
      "physicalPlan" : {
        "@type" : "streamSinkV1",
        "properties" : {
          "queryContext" : "INNER_JOIN"
        },
        "source" : {
          "@type" : "streamSelectV1",
          "properties" : {
            "queryContext" : "Project"
          },
          "source" : {
            "@type" : "streamStreamJoinV1",
            "properties" : {
              "queryContext" : "Join"
            },
            "joinType" : "INNER",
            "leftInternalFormats" : {
              "keyFormat" : {
                "format" : "KAFKA",
                "properties" : { }
              },
              "valueFormat" : {
                "format" : "AVRO",
                "properties" : { }
              },
              "options" : [ ]
            },
            "rightInternalFormats" : {
              "keyFormat" : {
                "format" : "KAFKA",
                "properties" : { }
              },
              "valueFormat" : {
                "format" : "AVRO",
                "properties" : { }
              },
              "options" : [ ]
            },
            "leftSource" : {
              "@type" : "streamSelectV1",
              "properties" : {
                "queryContext" : "PrependAliasLeft"
              },
              "source" : {
                "@type" : "streamSourceV1",
                "properties" : {
                  "queryContext" : "KafkaTopic_Left/Source"
                },
                "topicName" : "left_topic",
                "formats" : {
                  "keyFormat" : {
                    "format" : "KAFKA",
                    "properties" : { }
                  },
                  "valueFormat" : {
                    "format" : "AVRO",
                    "properties" : { }
                  },
                  "options" : [ ]
                },
                "timestampColumn" : null,
                "sourceSchema" : "`ROWKEY` BIGINT KEY, `ID` BIGINT, `NAME` STRING, `VALUE` BIGINT"
              },
              "selectExpressions" : [ "ID AS TT_ID", "NAME AS TT_NAME", "VALUE AS TT_VALUE", "ROWTIME AS TT_ROWTIME", "ROWKEY AS TT_ROWKEY" ]
            },
            "rightSource" : {
              "@type" : "streamSelectV1",
              "properties" : {
                "queryContext" : "PrependAliasRight"
              },
              "source" : {
                "@type" : "streamSourceV1",
                "properties" : {
                  "queryContext" : "KafkaTopic_Right/Source"
                },
                "topicName" : "right_topic",
                "formats" : {
                  "keyFormat" : {
                    "format" : "KAFKA",
                    "properties" : { }
                  },
                  "valueFormat" : {
                    "format" : "AVRO",
                    "properties" : { }
                  },
                  "options" : [ ]
                },
                "timestampColumn" : null,
                "sourceSchema" : "`ROWKEY` BIGINT KEY, `ID` BIGINT, `F1` STRING, `F2` BIGINT"
              },
              "selectExpressions" : [ "ID AS T_ID", "F1 AS T_F1", "F2 AS T_F2", "ROWTIME AS T_ROWTIME", "ROWKEY AS T_ROWKEY" ]
            },
            "beforeMillis" : 11.000000000,
            "afterMillis" : 11.000000000
          },
          "selectExpressions" : [ "T_ROWTIME AS T_ROWTIME", "T_ROWKEY AS T_ROWKEY", "T_ID AS T_ID", "T_F1 AS T_F1", "T_F2 AS T_F2", "TT_NAME AS NAME" ]
        },
        "formats" : {
          "keyFormat" : {
            "format" : "KAFKA",
            "properties" : { }
          },
          "valueFormat" : {
            "format" : "AVRO",
            "properties" : { }
          },
          "options" : [ ]
        },
        "topicName" : "INNER_JOIN"
      },
      "queryId" : "CSAS_INNER_JOIN_0"
    }
  } ],
  "configs" : {
    "ksql.extension.dir" : "ext",
    "ksql.streams.cache.max.bytes.buffering" : "0",
    "ksql.security.extension.class" : null,
    "ksql.transient.prefix" : "transient_",
    "ksql.persistence.wrap.single.values" : "true",
    "ksql.authorization.cache.expiry.time.secs" : "30",
    "ksql.schema.registry.url" : "",
    "ksql.streams.default.deserialization.exception.handler" : "io.confluent.ksql.errors.LogMetricAndContinueExceptionHandler",
    "ksql.output.topic.name.prefix" : "",
    "ksql.streams.auto.offset.reset" : "earliest",
    "ksql.query.pull.enable.standby.reads" : "false",
    "ksql.connect.url" : "http://localhost:8083",
    "ksql.service.id" : "some.ksql.service.id",
    "ksql.internal.topic.min.insync.replicas" : "1",
    "ksql.streams.shutdown.timeout.ms" : "300000",
    "ksql.new.api.enabled" : "false",
    "ksql.streams.state.dir" : "/var/folders/p9/bk8xks6s2lndncftdbq36xh80000gp/T/confluent8393051053551629823",
    "ksql.internal.topic.replicas" : "1",
    "ksql.insert.into.values.enabled" : "true",
    "ksql.query.pull.max.allowed.offset.lag" : "9223372036854775807",
    "ksql.streams.default.production.exception.handler" : "io.confluent.ksql.errors.ProductionExceptionHandlerUtil$LogAndFailProductionExceptionHandler",
    "ksql.access.validator.enable" : "auto",
    "ksql.streams.bootstrap.servers" : "localhost:0",
    "ksql.streams.commit.interval.ms" : "2000",
    "ksql.metric.reporters" : "",
    "ksql.streams.auto.commit.interval.ms" : "0",
    "ksql.metrics.extension" : null,
    "ksql.streams.topology.optimization" : "all",
    "ksql.query.pull.streamsstore.rebalancing.timeout.ms" : "10000",
    "ksql.hidden.topics" : "_confluent.*,__confluent.*,_schemas,__consumer_offsets,__transaction_state,connect-configs,connect-offsets,connect-status,connect-statuses",
    "ksql.streams.num.stream.threads" : "4",
    "ksql.authorization.cache.max.entries" : "10000",
    "ksql.metrics.tags.custom" : "",
    "ksql.pull.queries.enable" : "true",
    "ksql.udfs.enabled" : "true",
    "ksql.udf.enable.security.manager" : "true",
    "ksql.connect.worker.config" : "",
    "ksql.sink.window.change.log.additional.retention" : "1000000",
    "ksql.readonly.topics" : "_confluent.*,__confluent.*,_schemas,__consumer_offsets,__transaction_state,connect-configs,connect-offsets,connect-status,connect-statuses",
    "ksql.udf.collect.metrics" : "false",
    "ksql.persistent.prefix" : "query_",
    "ksql.query.persistent.active.limit" : "2147483647"
  }
}