From c145fc251daf48084ae957c1add6763ede82c4fe Mon Sep 17 00:00:00 2001 From: Robert Yokota Date: Mon, 1 Jul 2024 22:39:31 -0700 Subject: [PATCH] Checkpoint --- src/main/java/io/kcache/kwack/KwackMain.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/src/main/java/io/kcache/kwack/KwackMain.java b/src/main/java/io/kcache/kwack/KwackMain.java index c3cd673..e4ca102 100644 --- a/src/main/java/io/kcache/kwack/KwackMain.java +++ b/src/main/java/io/kcache/kwack/KwackMain.java @@ -108,12 +108,17 @@ public class KwackMain implements Callable { + " Default: rowkey,keysch,valsch,part,off,ts,hdrs", paramLabel = "") private EnumSet rowAttrs; + @Option(names = {"-q", "--query"}, + description = "SQL query to execute. If none is specified, interactive sqlline mode is used", + paramLabel = "") + private String query; + @Option(names = {"-d", "--db"}, description = "DuckDB db, appended to 'jdbc:duckdb:' Default: :memory:", paramLabel = "") private String db; @Option(names = {"-X", "--property"}, - description = "Set kwack configuration property.", paramLabel = "") + description = "Set configuration property.", paramLabel = "") private Map properties; public KwackMain() { @@ -257,7 +262,7 @@ public String[] getVersion() throws Exception { private boolean isApplicableManifest(Manifest manifest) { Attributes attributes = manifest.getMainAttributes(); - return "kwack-server".equals(get(attributes, "Implementation-Title")); + return "kwack".equals(get(attributes, "Implementation-Title")); } private static Object get(Attributes attributes, String key) {