This is an automated email from the ASF dual-hosted git repository.
lidavidm pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git
The following commit(s) were added to refs/heads/master by this push:
new 305b697d87 ARROW-16393: [JAVA] Update option spec to accept value for
query, catalog, schema and table
305b697d87 is described below
commit 305b697d87eac7c0b26ede6e2a6acdb002361960
Author: Tim Van Wassenhove <[email protected]>
AuthorDate: Thu Apr 28 14:56:41 2022 -0400
ARROW-16393: [JAVA] Update option spec to accept value for query, catalog,
schema and table
Fixes the issue reported in
https://issues.apache.org/jira/browse/ARROW-16393
mvn compile exec:java -Dcheckstyle.skip -Drat.skip=true
-Dexec.mainClass="org.apache.arrow.flight.sql.example.FlightSqlClientDemoApp"
-Dexec.args='-host localhost -port 52358 -command Execute -query "select * from
APP.INTTABLE"'
ID KEYNAME VALUE FOREIGNID
1 one 1 1
2 zero 0 1
3 negative one -1 1
ID KEYNAME VALUE FOREIGNID
Closes #13022 from timvw/ARROW-16393
Authored-by: Tim Van Wassenhove <[email protected]>
Signed-off-by: David Li <[email protected]>
---
.../apache/arrow/flight/sql/example/FlightSqlClientDemoApp.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git
a/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/example/FlightSqlClientDemoApp.java
b/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/example/FlightSqlClientDemoApp.java
index f3774a8a50..4d3241c7c3 100644
---
a/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/example/FlightSqlClientDemoApp.java
+++
b/java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/example/FlightSqlClientDemoApp.java
@@ -56,10 +56,10 @@ public class FlightSqlClientDemoApp implements
AutoCloseable {
options.addRequiredOption("port", "port", true, "Port to connect to");
options.addRequiredOption("command", "command", true, "Method to run");
- options.addOption("query", "query", false, "Query");
- options.addOption("catalog", "catalog", false, "Catalog");
- options.addOption("schema", "schema", false, "Schema");
- options.addOption("table", "table", false, "Table");
+ options.addOption("query", "query", true, "Query");
+ options.addOption("catalog", "catalog", true, "Catalog");
+ options.addOption("schema", "schema", true, "Schema");
+ options.addOption("table", "table", true, "Table");
CommandLineParser parser = new DefaultParser();
HelpFormatter formatter = new HelpFormatter();