This is an automated email from the ASF dual-hosted git repository.
lidavidm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/arrow.git
from d571e93ad2 ARROW-17730: [Go] Implement Take kernels for FSB and
VarBinary (#14127)
add 3ce40143f8 ARROW-17688: [C++][Java][FlightRPC] Substrait, transaction,
cancellation for Flight SQL (#13492)
No new revisions were added by this update.
Summary of changes:
.../integration_tests/flight_integration_test.cc | 4 +
.../flight/integration_tests/test_integration.cc | 656 +++++++++++++++++++--
cpp/src/arrow/flight/server.cc | 4 +-
cpp/src/arrow/flight/sql/CMakeLists.txt | 27 +-
cpp/src/arrow/flight/sql/acero_test.cc | 239 ++++++++
cpp/src/arrow/flight/sql/client.cc | 355 +++++++++--
cpp/src/arrow/flight/sql/client.h | 152 ++++-
cpp/src/arrow/flight/sql/client_test.cc | 1 +
cpp/src/arrow/flight/sql/column_metadata.cc | 8 +-
cpp/src/arrow/flight/sql/column_metadata.h | 8 +-
cpp/src/arrow/flight/sql/example/acero_main.cc | 70 +++
cpp/src/arrow/flight/sql/example/acero_server.cc | 306 ++++++++++
.../example/{sqlite_sql_info.h => acero_server.h} | 15 +-
cpp/src/arrow/flight/sql/example/sqlite_server.cc | 205 +++++--
cpp/src/arrow/flight/sql/example/sqlite_server.h | 6 +
.../arrow/flight/sql/example/sqlite_sql_info.cc | 9 +-
cpp/src/arrow/flight/sql/server.cc | 424 ++++++++++---
cpp/src/arrow/flight/sql/server.h | 171 +++++-
cpp/src/arrow/flight/sql/server_test.cc | 83 +--
cpp/src/arrow/flight/sql/types.h | 79 ++-
dev/archery/archery/integration/runner.py | 5 +
docs/source/status.rst | 14 +
format/FlightSql.proto | 298 +++++++++-
.../java/org/apache/arrow/flight/FlightClient.java | 7 +-
.../org/apache/arrow/flight/FlightService.java | 2 +-
.../tests/FlightSqlExtensionScenario.java | 217 +++++++
.../integration/tests/FlightSqlScenario.java | 52 +-
.../tests/FlightSqlScenarioProducer.java | 383 ++++++++++--
.../integration/tests/IntegrationAssertions.java | 11 +
.../arrow/flight/integration/tests/Scenarios.java | 1 +
.../flight/integration/tests/IntegrationTest.java | 5 +
.../apache/arrow/flight/sql/CancelListener.java} | 38 +-
.../org/apache/arrow/flight/sql/CancelResult.java} | 36 +-
.../apache/arrow/flight/sql/FlightSqlClient.java | 451 +++++++++++++-
.../apache/arrow/flight/sql/FlightSqlProducer.java | 198 ++++++-
.../apache/arrow/flight/sql/FlightSqlUtils.java | 35 ++
.../apache/arrow/flight/sql/NoResultListener.java} | 32 +-
.../apache/arrow/flight/sql/ProtoListener.java} | 33 +-
.../apache/arrow/flight/sql/SqlInfoBuilder.java | 41 ++
.../arrow/flight/sql/example/FlightSqlExample.java | 3 +
40 files changed, 4230 insertions(+), 454 deletions(-)
create mode 100644 cpp/src/arrow/flight/sql/acero_test.cc
create mode 100644 cpp/src/arrow/flight/sql/example/acero_main.cc
create mode 100644 cpp/src/arrow/flight/sql/example/acero_server.cc
copy cpp/src/arrow/flight/sql/example/{sqlite_sql_info.h => acero_server.h}
(74%)
create mode 100644
java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/FlightSqlExtensionScenario.java
copy java/flight/flight-integration-tests/src/{main =>
}/test/java/org/apache/arrow/flight/integration/tests/IntegrationTest.java (95%)
copy
java/flight/{flight-core/src/main/java/org/apache/arrow/flight/NoOpStreamListener.java
=> flight-sql/src/main/java/org/apache/arrow/flight/sql/CancelListener.java}
(53%)
copy
java/{compression/src/main/java/org/apache/arrow/compression/CommonsCompressionFactory.java
=>
flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/CancelResult.java}
(51%)
copy
java/flight/{flight-core/src/main/java/org/apache/arrow/flight/NoOpStreamListener.java
=> flight-sql/src/main/java/org/apache/arrow/flight/sql/NoResultListener.java}
(58%)
copy
java/flight/{flight-core/src/main/java/org/apache/arrow/flight/NoOpStreamListener.java
=> flight-sql/src/main/java/org/apache/arrow/flight/sql/ProtoListener.java}
(60%)
