{
  "version" : "6.0.0",
  "timestamp" : 1589910849869,
  "path" : "query-validation-tests/collect-list.json",
  "schemas" : {
    "CTAS_S2_0.Aggregate.Aggregate.Materialize" : {
      "schema" : "`ID` BIGINT KEY, `ID` BIGINT, `VALUE` INTEGER, `KSQL_AGG_VARIABLE_0` ARRAY<INTEGER>",
      "serdeOptions" : [ ]
    },
    "CTAS_S2_0.KsqlTopic.Source" : {
      "schema" : "`ID` BIGINT KEY, `VALUE` INTEGER",
      "serdeOptions" : [ ]
    },
    "CTAS_S2_0.S2" : {
      "schema" : "`ID` BIGINT KEY, `COLLECTED` ARRAY<INTEGER>",
      "serdeOptions" : [ ]
    },
    "CTAS_S2_0.Aggregate.GroupBy" : {
      "schema" : "`ID` BIGINT KEY, `ID` BIGINT, `VALUE` INTEGER",
      "serdeOptions" : [ ]
    }
  },
  "testCase" : {
    "name" : "collect_list int - PROTOBUF",
    "inputs" : [ {
      "topic" : "test_topic",
      "key" : 0,
      "value" : {
        "VALUE" : 0
      }
    }, {
      "topic" : "test_topic",
      "key" : 0,
      "value" : {
        "VALUE" : 100
      }
    }, {
      "topic" : "test_topic",
      "key" : 100,
      "value" : {
        "VALUE" : 500
      }
    }, {
      "topic" : "test_topic",
      "key" : 100,
      "value" : {
        "VALUE" : 100
      }
    } ],
    "outputs" : [ {
      "topic" : "S2",
      "key" : 0,
      "value" : {
        "COLLECTED" : [ 0 ]
      }
    }, {
      "topic" : "S2",
      "key" : 0,
      "value" : {
        "COLLECTED" : [ 0, 100 ]
      }
    }, {
      "topic" : "S2",
      "key" : 100,
      "value" : {
        "COLLECTED" : [ 500 ]
      }
    }, {
      "topic" : "S2",
      "key" : 100,
      "value" : {
        "COLLECTED" : [ 500, 100 ]
      }
    } ],
    "topics" : [ {
      "name" : "test_topic",
      "schema" : "syntax = \"proto3\";\n\nmessage ConnectDefault1 {\n  int32 VALUE = 1;\n}\n",
      "format" : "PROTOBUF",
      "replicas" : 1,
      "numPartitions" : 4
    }, {
      "name" : "S2",
      "replicas" : 1,
      "numPartitions" : 4
    } ],
    "statements" : [ "CREATE STREAM TEST (ID BIGINT KEY, VALUE integer) WITH (kafka_topic='test_topic',value_format='PROTOBUF');", "CREATE TABLE S2 as SELECT ID, collect_list(value) as collected FROM test group by id;" ],
    "post" : {
      "sources" : [ {
        "name" : "TEST",
        "type" : "STREAM",
        "schema" : "`ID` BIGINT KEY, `VALUE` INTEGER",
        "keyFormat" : {
          "format" : "KAFKA"
        },
        "serdeOptions" : [ ]
      }, {
        "name" : "S2",
        "type" : "TABLE",
        "schema" : "`ID` BIGINT KEY, `COLLECTED` ARRAY<INTEGER>",
        "keyFormat" : {
          "format" : "KAFKA"
        },
        "serdeOptions" : [ ]
      } ],
      "topics" : {
        "topics" : [ {
          "name" : "_confluent-ksql-some.ksql.service.idquery_CTAS_S2_0-Aggregate-Aggregate-Materialize-changelog",
          "keyFormat" : {
            "formatInfo" : {
              "format" : "KAFKA"
            }
          },
          "valueFormat" : {
            "format" : "PROTOBUF"
          }
        }, {
          "name" : "test_topic",
          "keyFormat" : {
            "formatInfo" : {
              "format" : "KAFKA"
            }
          },
          "valueFormat" : {
            "format" : "PROTOBUF"
          },
          "partitions" : 4
        }, {
          "name" : "S2",
          "keyFormat" : {
            "formatInfo" : {
              "format" : "KAFKA"
            }
          },
          "valueFormat" : {
            "format" : "PROTOBUF"
          },
          "partitions" : 4
        } ]
      }
    }
  }
}