From e6918187568dbd01842d8d1d2c808ce16a894239 Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 21 Apr 2024 13:54:28 +0200 Subject: Adding upstream version 18.2.2. Signed-off-by: Daniel Baumann --- src/arrow/java/flight/flight-core/README.md | 95 +++++++++++++++++++++++++++++ 1 file changed, 95 insertions(+) create mode 100644 src/arrow/java/flight/flight-core/README.md (limited to 'src/arrow/java/flight/flight-core/README.md') diff --git a/src/arrow/java/flight/flight-core/README.md b/src/arrow/java/flight/flight-core/README.md new file mode 100644 index 000000000..37b41ede2 --- /dev/null +++ b/src/arrow/java/flight/flight-core/README.md @@ -0,0 +1,95 @@ + + +# Arrow Flight Java Package + +Exposing Apache Arrow data on the wire. + +[Protocol Description Slides](https://www.slideshare.net/JacquesNadeau5/apache-arrow-flight-overview) + +[GRPC Protocol Definition](https://github.com/apache/arrow/blob/master/format/Flight.proto) + +## Example usage + +* Compile the java tree: + + ``` + cd java + mvn clean install -DskipTests + ``` + +* Go Into the Flight tree + + ``` + cd flight/flight-core + ``` + + +* Start the ExampleFlightServer (supports get/put of streams and listing these streams) + + ``` + mvn exec:exec + ``` + +* In new terminal, run the TestExampleServer to populate the server with example data + + ``` + cd arrow/java/flight/flight-core + mvn surefire:test -DdisableServer=true -Dtest=TestExampleServer + ``` + +## Python Example Usage + +* Compile example python headers + + ``` + mkdir target/generated-python + pip install grpcio-tools # or conda install grpcio + python -m grpc_tools.protoc -I./src/main/protobuf/ --python_out=./target/generated-python --grpc_python_out=./target/generated-python ../../format/Flight.proto + ``` + +* Connect to the Flight Service + + ``` + cd target/generated-python + python + ``` + + + ``` + import grpc + import flight_pb2 + import flight_pb2_grpc as flightrpc + channel = grpc.insecure_channel('localhost:12233') + service = flightrpc.FlightServiceStub(channel) + ``` + +* List the Flight from Python + + ``` + for f in service.ListFlights(flight_pb2.Criteria()): f + ``` + +* Try to Drop + + ``` + action = flight_pb2.Action() + action.type="drop" + service.DoAction(action) + ``` -- cgit v1.2.3