WIP

aklivity · Oct 22, 2024 · fcae8fc · fcae8fc
1 parent de756c4
commit fcae8fc
Show file tree

Hide file tree

Showing 8 changed files with 11 additions and 11 deletions.
diff --git a/...livity/zilla/specs/binding/risingwave/streams/effective/drop.materialized.view/client.rpt b/...livity/zilla/specs/binding/risingwave/streams/effective/drop.materialized.view/client.rpt
@@ -32,7 +32,7 @@ write zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-write "DROP MATERIALIZED VIEW weather";
+write "DROP MATERIALIZED VIEW weather;"
       [0x00]
 write flush
 
@@ -55,7 +55,7 @@ write zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-write "DROP SINK weather_sink";
+write "DROP SINK weather_sink;"
       [0x00]
 write flush
 

diff --git a/...livity/zilla/specs/binding/risingwave/streams/effective/drop.materialized.view/server.rpt b/...livity/zilla/specs/binding/risingwave/streams/effective/drop.materialized.view/server.rpt
@@ -36,7 +36,7 @@ read zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-read "DROP MATERIALIZED VIEW weather";
+read "DROP MATERIALIZED VIEW weather;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()
@@ -58,7 +58,7 @@ read zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-read "DROP SINK weather_sink";
+read "DROP SINK weather_sink;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

diff --git a/...y/zilla/specs/binding/risingwave/streams/effective/drop.table.with.primary.key/client.rpt b/...y/zilla/specs/binding/risingwave/streams/effective/drop.table.with.primary.key/client.rpt
@@ -139,7 +139,7 @@ write zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-write "DROP TABLE weather";
+write "DROP TABLE weather;"
       [0x00]
 write flush
 

diff --git a/...y/zilla/specs/binding/risingwave/streams/effective/drop.table.with.primary.key/server.rpt b/...y/zilla/specs/binding/risingwave/streams/effective/drop.table.with.primary.key/server.rpt
@@ -149,7 +149,7 @@ read zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-read "DROP TABLE weather";
+read "DROP TABLE weather;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

diff --git a/...cripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.table/client.rpt b/...cripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.table/client.rpt
@@ -153,7 +153,7 @@ write zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-write "DROP SOURCE weather";
+write "DROP SOURCE weather;"
       [0x00]
 write flush
 

diff --git a/...cripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.table/server.rpt b/...cripts/io/aklivity/zilla/specs/binding/risingwave/streams/effective/drop.table/server.rpt
@@ -164,7 +164,7 @@ read zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-read "DROP SOURCE weather";
+read "DROP SOURCE weather;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()

diff --git a/...in/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/drop.table/client.rpt b/...in/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/drop.table/client.rpt
@@ -32,7 +32,7 @@ write zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-write "DROP STREAM weather;"
+write "DROP TABLE weather;"
       [0x00]
 
 write flush

diff --git a/...in/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/drop.table/server.rpt b/...in/scripts/io/aklivity/zilla/specs/binding/risingwave/streams/pgsql/drop.table/server.rpt
@@ -36,13 +36,13 @@ read zilla:data.ext ${pgsql:dataEx()
                               .query()
                                 .build()
                               .build()}
-read "DROP STREAM weather;"
+read "DROP TABLE weather;"
      [0x00]
 
 write advise zilla:flush ${pgsql:flushEx()
                               .typeId(zilla:id("pgsql"))
                               .completion()
-                                .tag("DROP_STREAM")
+                                .tag("DROP_TABLE")
                                 .build()
                               .build()}