false true false srv 127.0.0.1 = rest_port 9081 = k_home ${__property(base,,)} = continue false 1 1 1 false ${srv} ${rest_port} /streams GET true false true false $ [] false false false true true false { "sql" : "create stream my_stream (USERID BIGINT, FIRST_NAME STRING, LAST_NAME STRING, NICKNAMES ARRAY(STRING), Gender BOOLEAN, ADDRESS STRUCT(STREET_NAME STRING, NUMBER BIGINT),) WITH ( datasource = \"topic/test\", FORMAT = \"json\", KEY = \"id\")" } = ${srv} ${rest_port} /streams POST true false true false Stream my_stream is created. Assertion.response_data false 16 true false { "sql" : "create stream my_stream (USERID BIGINT, FIRST_NAME STRING, LAST_NAME STRING, NICKNAMES ARRAY(STRING), Gender BOOLEAN, ADDRESS STRUCT(STREET_NAME STRING, NUMBER BIGINT),) WITH ( datasource = \"topic/test\", FORMAT = \"json\", KEY = \"id\")" } = ${srv} ${rest_port} /streams POST true false true false 400 Assertion.response_code true 16 ${srv} ${rest_port} /streams GET true false true false my_stream Assertion.response_data false 16 ${srv} ${rest_port} /streams/my_stream GET true false true false my_stream Assertion.response_data false 16 FIRST_NAME Assertion.response_data false 16 true false = ${srv} ${rest_port} /streams/my_stream DELETE true false true false Stream my_stream is dropped. Assertion.response_data false 16 ${srv} ${rest_port} /streams GET true false true false $ [] false false false true 500 false saveConfig true true true true true true true false true true false false false true false false false true 0 true true true true true continue false 1 1 1 false false 0 bin/kuiper show = streams = ${k_home} No stream definitions are found Assertion.response_data false 16 false 0 bin/kuiper create = stream = demo = (temperature float, humidity bigint) WITH (FORMAT="JSON", DATASOURCE="devices/+/messages") = ${k_home} Stream demo is created. Assertion.response_data false 16 false 0 bin/kuiper create = stream = demo = (temperature float, humidity bigint) WITH (FORMAT="JSON", DATASOURCE="devices/+/messages") = ${k_home} Item demo already exists Assertion.response_data false 16 false 0 bin/kuiper show = streams = ${k_home} demo Assertion.response_data false 16 false 0 bin/kuiper describe = stream = demo = ${k_home} devices/+/messages Assertion.response_data false 16 false 0 bin/kuiper drop = stream = demo = ${k_home} Stream demo is dropped. Assertion.response_data false 16 false 0 bin/kuiper show = streams = ${k_home} No stream definitions are found Assertion.response_data false 16 false saveConfig true true true true true true true false true true false false false true false false false true 0 true true true true true 500