Remove zstream command

aklivity · Jan 23, 2025 · 500477c · 500477c
1 parent e8fdf42
commit 500477c
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/...a/io/aklivity/zilla/runtime/binding/risingwave/internal/config/RisingwaveCommandType.java b/...a/io/aklivity/zilla/runtime/binding/risingwave/internal/config/RisingwaveCommandType.java
@@ -30,7 +30,6 @@ public enum RisingwaveCommandType
     DROP_ZVIEW_COMMAND("DROP ZVIEW".getBytes()),
     DROP_ZFUNCTION_COMMAND("DROP ZFUNCTION".getBytes()),
     SHOW_ZTABLES_COMMAND("SHOW ZTABLES".getBytes()),
-    SHOW_ZSTREAMS_COMMAND("SHOW ZSTREAMS".getBytes()),
     SHOW_ZVIEWS_COMMAND("SHOW ZVIEWS".getBytes()),
     SHOW_ZFUNCTIONS_COMMAND("SHOW ZFUNCTIONS".getBytes()),
     UNKNOWN_COMMAND("UNKNOWN".getBytes());

diff --git a/.../io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java b/.../io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java
@@ -168,7 +168,6 @@ public final class RisingwaveProxyFactory implements RisingwaveStreamFactory
         clientTransforms.put(RisingwaveCommandType.DROP_ZTABLE_COMMAND, this::decodeDropZtableCommand);
         clientTransforms.put(RisingwaveCommandType.DROP_ZVIEW_COMMAND, this::decodeDropZviewCommand);
         clientTransforms.put(RisingwaveCommandType.DROP_ZFUNCTION_COMMAND, this::decodeDropZfunctionCommand);
-        clientTransforms.put(RisingwaveCommandType.SHOW_ZSTREAMS_COMMAND, this::decodeShowCommand);
         clientTransforms.put(RisingwaveCommandType.SHOW_ZTABLES_COMMAND, this::decodeShowCommand);
         clientTransforms.put(RisingwaveCommandType.SHOW_ZVIEWS_COMMAND, this::decodeShowCommand);
         clientTransforms.put(RisingwaveCommandType.SHOW_ZFUNCTIONS_COMMAND, this::decodeShowZfunctionCommand);