This is an automated email from the ASF dual-hosted git repository.
lidavidm pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/arrow.git
from df9e0c1264 GH-20379: [Java] Dataset Failed to update reservation while
freeing bytes (#40101)
add 2e2bd8b9f2 GH-34865: [C++][Java][Flight RPC] Add Session management
messages (#34817)
No new revisions were added by this update.
Summary of changes:
cpp/src/arrow/flight/client.cc | 41 +++
cpp/src/arrow/flight/client.h | 21 ++
.../integration_tests/flight_integration_test.cc | 2 +
.../flight/integration_tests/test_integration.cc | 154 +++++++++
cpp/src/arrow/flight/serialization_internal.cc | 159 +++++++++
cpp/src/arrow/flight/serialization_internal.h | 20 ++
cpp/src/arrow/flight/sql/CMakeLists.txt | 7 +-
cpp/src/arrow/flight/sql/client.h | 27 ++
cpp/src/arrow/flight/sql/server.cc | 76 ++++-
cpp/src/arrow/flight/sql/server.h | 19 ++
.../arrow/flight/sql/server_session_middleware.cc | 235 +++++++++++++
.../arrow/flight/sql/server_session_middleware.h | 89 +++++
.../flight/sql/server_session_middleware_factory.h | 61 ++++
...=> server_session_middleware_internals_test.cc} | 26 +-
cpp/src/arrow/flight/transport/grpc/grpc_server.cc | 26 +-
cpp/src/arrow/flight/types.cc | 363 +++++++++++++++++++++
cpp/src/arrow/flight/types.h | 197 +++++++++++
dev/archery/archery/integration/runner.py | 5 +
docs/source/format/FlightSql.rst | 41 +++
format/Flight.proto | 114 +++++++
...htInfoRequest.java => CloseSessionRequest.java} | 28 +-
...ghtInfoRequest.java => CloseSessionResult.java} | 68 +++-
.../java/org/apache/arrow/flight/FlightClient.java | 96 ++++++
.../org/apache/arrow/flight/FlightConstants.java | 14 +
...oRequest.java => GetSessionOptionsRequest.java} | 30 +-
...ntRequest.java => GetSessionOptionsResult.java} | 42 ++-
.../flight/NoOpSessionOptionValueVisitor.java | 72 ++++
.../arrow/flight/ServerSessionMiddleware.java | 227 +++++++++++++
.../apache/arrow/flight/SessionOptionValue.java | 94 ++++++
.../arrow/flight/SessionOptionValueFactory.java | 284 ++++++++++++++++
...dleware.java => SessionOptionValueVisitor.java} | 42 ++-
...tRequest.java => SetSessionOptionsRequest.java} | 43 ++-
.../arrow/flight/SetSessionOptionsResult.java | 152 +++++++++
java/flight/flight-integration-tests/pom.xml | 4 +
.../arrow/flight/integration/tests/Scenarios.java | 1 +
.../integration/tests/SessionOptionsProducer.java | 110 +++++++
.../integration/tests/SessionOptionsScenario.java | 107 ++++++
.../flight/integration/tests/IntegrationTest.java | 5 +
...stener.java => CloseSessionResultListener.java} | 10 +-
.../apache/arrow/flight/sql/FlightSqlClient.java | 18 +
.../apache/arrow/flight/sql/FlightSqlProducer.java | 79 +++++
...r.java => GetSessionOptionsResultListener.java} | 10 +-
...r.java => SetSessionOptionsResultListener.java} | 10 +-
testing | 2 +-
44 files changed, 3080 insertions(+), 151 deletions(-)
create mode 100644 cpp/src/arrow/flight/sql/server_session_middleware.cc
create mode 100644 cpp/src/arrow/flight/sql/server_session_middleware.h
create mode 100644 cpp/src/arrow/flight/sql/server_session_middleware_factory.h
copy cpp/src/arrow/flight/sql/{example/acero_server.h =>
server_session_middleware_internals_test.cc} (54%)
copy
java/flight/flight-core/src/main/java/org/apache/arrow/flight/{CancelFlightInfoRequest.java
=> CloseSessionRequest.java} (65%)
copy
java/flight/flight-core/src/main/java/org/apache/arrow/flight/{CancelFlightInfoRequest.java
=> CloseSessionResult.java} (50%)
copy
java/flight/flight-core/src/main/java/org/apache/arrow/flight/{CancelFlightInfoRequest.java
=> GetSessionOptionsRequest.java} (65%)
copy
java/flight/flight-core/src/main/java/org/apache/arrow/flight/{RenewFlightEndpointRequest.java
=> GetSessionOptionsResult.java} (52%)
create mode 100644
java/flight/flight-core/src/main/java/org/apache/arrow/flight/NoOpSessionOptionValueVisitor.java
create mode 100644
java/flight/flight-core/src/main/java/org/apache/arrow/flight/ServerSessionMiddleware.java
create mode 100644
java/flight/flight-core/src/main/java/org/apache/arrow/flight/SessionOptionValue.java
create mode 100644
java/flight/flight-core/src/main/java/org/apache/arrow/flight/SessionOptionValueFactory.java
copy
java/flight/flight-core/src/main/java/org/apache/arrow/flight/{FlightClientMiddleware.java
=> SessionOptionValueVisitor.java} (50%)
copy
java/flight/flight-core/src/main/java/org/apache/arrow/flight/{RenewFlightEndpointRequest.java
=> SetSessionOptionsRequest.java} (51%)
create mode 100644
java/flight/flight-core/src/main/java/org/apache/arrow/flight/SetSessionOptionsResult.java
create mode 100644
java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/SessionOptionsProducer.java
create mode 100644
java/flight/flight-integration-tests/src/main/java/org/apache/arrow/flight/integration/tests/SessionOptionsScenario.java
copy
java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/{FlightEndpointListener.java
=> CloseSessionResultListener.java} (79%)
copy
java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/{FlightEndpointListener.java
=> GetSessionOptionsResultListener.java} (77%)
copy
java/flight/flight-sql/src/main/java/org/apache/arrow/flight/sql/{FlightEndpointListener.java
=> SetSessionOptionsResultListener.java} (77%)
