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 2021/12/23 19:20:30 UTC
[arrow] branch master updated (e60e6b0 -> 968e6ea)
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 e60e6b0 ARROW-15165: [Python] Expose function to resolve S3 bucket region
add 968e6ea ARROW-14421: [C++] Implement Flight SQL
No new revisions were added by this update.
Summary of changes:
ci/docker/conda-cpp.dockerfile | 1 +
ci/scripts/cpp_build.sh | 1 +
cpp/CMakeLists.txt | 8 +
cpp/cmake_modules/DefineOptions.cmake | 2 +
cpp/cmake_modules/FindArrowFlightSql.cmake | 93 ++
cpp/cmake_modules/FindSQLite3Alt.cmake | 43 +
cpp/src/arrow/CMakeLists.txt | 10 +
cpp/src/arrow/flight/CMakeLists.txt | 34 +-
.../arrow/flight/integration_tests/CMakeLists.txt | 47 +
.../flight/integration_tests/test_integration.cc | 684 ++++++++
.../{ => integration_tests}/test_integration.h | 7 +
.../test_integration_client.cc | 16 +-
.../test_integration_server.cc | 12 +-
.../arrow/flight/sql/ArrowFlightSqlConfig.cmake.in | 36 +
cpp/src/arrow/flight/sql/CMakeLists.txt | 100 ++
cpp/src/arrow/flight/sql/api.h | 20 +
cpp/src/arrow/flight/sql/arrow-flight-sql.pc.in | 25 +
cpp/src/arrow/flight/sql/client.cc | 425 +++++
cpp/src/arrow/flight/sql/client.h | 247 +++
cpp/src/arrow/flight/sql/client_test.cc | 515 +++++++
cpp/src/arrow/flight/sql/example/sqlite_server.cc | 813 ++++++++++
cpp/src/arrow/flight/sql/example/sqlite_server.h | 142 ++
.../arrow/flight/sql/example/sqlite_sql_info.cc | 223 +++
.../example/sqlite_sql_info.h} | 33 +-
.../arrow/flight/sql/example/sqlite_statement.cc | 137 ++
.../arrow/flight/sql/example/sqlite_statement.h | 73 +
.../sql/example/sqlite_statement_batch_reader.cc | 189 +++
.../sql/example/sqlite_statement_batch_reader.h | 65 +
.../example/sqlite_tables_schema_batch_reader.cc | 106 ++
.../example/sqlite_tables_schema_batch_reader.h | 58 +
cpp/src/arrow/flight/sql/server.cc | 764 +++++++++
cpp/src/arrow/flight/sql/server.h | 443 ++++++
cpp/src/arrow/flight/sql/server_test.cc | 767 +++++++++
cpp/src/arrow/flight/sql/sql_info_internal.cc | 101 ++
cpp/src/arrow/flight/sql/sql_info_internal.h | 87 ++
cpp/src/arrow/flight/sql/test_app_cli.cc | 197 +++
cpp/src/arrow/flight/sql/test_server_cli.cc | 62 +
cpp/src/arrow/flight/sql/types.h | 890 +++++++++++
cpp/src/arrow/flight/test_integration.cc | 270 ----
cpp/vcpkg.json | 1 +
dev/archery/archery/integration/runner.py | 5 +
dev/archery/archery/integration/tester_java.py | 9 +-
docker-compose.yml | 3 +
format/FlightSql.proto | 1336 ++++++++++++++++
.../arrow/adapter/jdbc/JdbcToArrowConfig.java | 78 +-
.../arrow/adapter/jdbc/JdbcToArrowUtils.java | 102 ++
java/flight/flight-core/pom.xml | 11 +-
java/flight/flight-grpc/pom.xml | 6 +-
java/flight/flight-integration-tests/pom.xml | 86 ++
.../integration/tests}/AuthBasicProtoScenario.java | 2 +-
.../integration/tests/FlightSqlScenario.java | 140 ++
.../tests/FlightSqlScenarioProducer.java | 349 +++++
.../integration/tests}/IntegrationAssertions.java | 11 +-
.../integration/tests}/IntegrationTestClient.java | 14 +-
.../integration/tests}/IntegrationTestServer.java | 2 +-
.../integration/tests}/MiddlewareScenario.java | 2 +-
.../arrow/flight/integration/tests}/Scenario.java | 2 +-
.../arrow/flight/integration/tests}/Scenarios.java | 3 +-
java/flight/flight-sql/pom.xml | 151 ++
.../apache/arrow/flight/sql/FlightSqlClient.java | 632 ++++++++
.../apache/arrow/flight/sql/FlightSqlProducer.java | 668 ++++++++
.../apache/arrow/flight/sql/FlightSqlUtils.java | 96 ++
.../apache/arrow/flight/sql/SqlInfoBuilder.java | 1024 ++++++++++++
.../flight/sql/example/FlightSqlClientDemoApp.java | 244 +++
.../arrow/flight/sql/util/SqlInfoOptionsUtils.java | 71 +
.../org/apache/arrow/flight/sql/util/TableRef.java | 76 +
.../org/apache/arrow/flight/TestFlightSql.java | 706 +++++++++
.../arrow/flight/sql/example/FlightSqlExample.java | 1625 ++++++++++++++++++++
.../arrow/flight/sql/example/StatementContext.java | 82 +
.../arrow/flight/sql/util/AdhocTestOption.java} | 44 +-
.../SqlInfoOptionsUtilsBitmaskCreationTest.java | 66 +
.../SqlInfoOptionsUtilsBitmaskParsingTest.java | 74 +
java/flight/pom.xml | 58 +
java/pom.xml | 16 +-
.../org/apache/arrow/vector/types/pojo/Field.java | 4 +
.../apache/arrow/vector/types/pojo/FieldType.java | 4 +
76 files changed, 15104 insertions(+), 445 deletions(-)
create mode 100644 cpp/cmake_modules/FindArrowFlightSql.cmake
create mode 100644 cpp/cmake_modules/FindSQLite3Alt.cmake
create mode 100644 cpp/src/arrow/flight/integration_tests/CMakeLists.txt
create mode 100644 cpp/src/arrow/flight/integration_tests/test_integration.cc
copy cpp/src/arrow/flight/{ => integration_tests}/test_integration.h (95%)
rename cpp/src/arrow/flight/{ => integration_tests}/test_integration_client.cc (94%)
rename cpp/src/arrow/flight/{ => integration_tests}/test_integration_server.cc (94%)
create mode 100644 cpp/src/arrow/flight/sql/ArrowFlightSqlConfig.cmake.in
create mode 100644 cpp/src/arrow/flight/sql/CMakeLists.txt
create mode 100644 cpp/src/arrow/flight/sql/api.h
create mode 100644 cpp/src/arrow/flight/sql/arrow-flight-sql.pc.in
create mode 100644 cpp/src/arrow/flight/sql/client.cc
create mode 100644 cpp/src/arrow/flight/sql/client.h
create mode 100644 cpp/src/arrow/flight/sql/client_test.cc
create mode 100644 cpp/src/arrow/flight/sql/example/sqlite_server.cc
create mode 100644 cpp/src/arrow/flight/sql/example/sqlite_server.h
create mode 100644 cpp/src/arrow/flight/sql/example/sqlite_sql_info.cc
rename cpp/src/arrow/flight/{test_integration.h => sql/example/sqlite_sql_info.h} (50%)
create mode 100644 cpp/src/arrow/flight/sql/example/sqlite_statement.cc
create mode 100644 cpp/src/arrow/flight/sql/example/sqlite_statement.h
create mode 100644 cpp/src/arrow/flight/sql/example/sqlite_statement_batch_reader.cc
create mode 100644 cpp/src/arrow/flight/sql/example/sqlite_statement_batch_reader.h
create mode 100644 cpp/src/arrow/flight/sql/example/sqlite_tables_schema_batch_reader.cc
create mode 100644 cpp/src/arrow/flight/sql/example/sqlite_tables_schema_batch_reader.h
create mode 100644 cpp/src/arrow/flight/sql/server.cc
create mode 100644 cpp/src/arrow/flight/sql/server.h
create mode 100644 cpp/src/arrow/flight/sql/server_test.cc
create mode 100644 cpp/src/arrow/flight/sql/sql_info_internal.cc
create mode 100644 cpp/src/arrow/flight/sql/sql_info_internal.h
create mode 100644 cpp/src/arrow/flight/sql/test_app_cli.cc
create mode 100644 cpp/src/arrow/flight/sql/test_server_cli.cc
create mode 100644 cpp/src/arrow/flight/sql/types.h
delete mode 100644 cpp/src/arrow/flight/test_integration.cc
create mode 100644 format/FlightSql.proto
create mode 100644 java/flight/flight-integration-tests/pom.xml
rename java/flight/{flight-core/src/main/java/org/apache/arrow/flight/example/integration => flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests}/AuthBasicProtoScenario.java (98%)
create mode 100644 java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/FlightSqlScenario.java
create mode 100644 java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/FlightSqlScenarioProducer.java
rename java/flight/{flight-core/src/main/java/org/apache/arrow/flight/example/integration => flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests}/IntegrationAssertions.java (88%)
rename java/flight/{flight-core/src/main/java/org/apache/arrow/flight/example/integration => flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests}/IntegrationTestClient.java (93%)
rename java/flight/{flight-core/src/main/java/org/apache/arrow/flight/example/integration => flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests}/IntegrationTestServer.java (98%)
rename java/flight/{flight-core/src/main/java/org/apache/arrow/flight/example/integration => flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests}/MiddlewareScenario.java (99%)
copy java/flight/{flight-core/src/main/java/org/apache/arrow/flight/example/integration => flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests}/Scenario.java (96%)
rename java/flight/{flight-core/src/main/java/org/apache/arrow/flight/example/integration => flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests}/Scenarios.java (96%)
create mode 100644 java/flight/flight-sql/pom.xml
create mode 100644 java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlClient.java
create mode 100644 java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlProducer.java
create mode 100644 java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/FlightSqlUtils.java
create mode 100644 java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/SqlInfoBuilder.java
create mode 100644 java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/example/FlightSqlClientDemoApp.java
create mode 100644 java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/util/SqlInfoOptionsUtils.java
create mode 100644 java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/util/TableRef.java
create mode 100644 java/flight/flight-sql/src/test/java/org/apache/arrow/flight/TestFlightSql.java
create mode 100644 java/flight/flight-sql/src/test/java/org/apache/arrow/flight/sql/example/FlightSqlExample.java
create mode 100644 java/flight/flight-sql/src/test/java/org/apache/arrow/flight/sql/example/StatementContext.java
rename java/flight/{flight-core/src/main/java/org/apache/arrow/flight/example/integration/Scenario.java => flight-sql/src/test/java/org/apache/arrow/flight/sql/util/AdhocTestOption.java} (50%)
create mode 100644 java/flight/flight-sql/src/test/java/org/apache/arrow/flight/sql/util/SqlInfoOptionsUtilsBitmaskCreationTest.java
create mode 100644 java/flight/flight-sql/src/test/java/org/apache/arrow/flight/sql/util/SqlInfoOptionsUtilsBitmaskParsingTest.java
create mode 100644 java/flight/pom.xml