You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@arrow.apache.org by li...@apache.org on 2022/09/16 15:06:29 UTC
[arrow] branch master updated (d571e93ad2 -> 3ce40143f8)
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%)