[GitHub] [arrow] emkornfield commented on a change in pull request #7012: ARROW-8555: [FlightRPC][Java] implement DoExchange

2020-05-03 Thread GitBox
emkornfield commented on a change in pull request #7012: URL: https://github.com/apache/arrow/pull/7012#discussion_r419200568 ## File path: java/flight/flight-core/src/test/java/org/apache/arrow/flight/TestDoExchange.java ## @@ -0,0 +1,395 @@ +/* + * Licensed to the Apache Sof

[GitHub] [arrow] emkornfield commented on a change in pull request #7012: ARROW-8555: [FlightRPC][Java] implement DoExchange

2020-05-03 Thread GitBox
emkornfield commented on a change in pull request #7012: URL: https://github.com/apache/arrow/pull/7012#discussion_r419200063 ## File path: java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightClient.java ## @@ -293,6 +292,76 @@ public void onCompleted() {

[GitHub] [arrow] emkornfield commented on a change in pull request #7012: ARROW-8555: [FlightRPC][Java] implement DoExchange

2020-05-03 Thread GitBox
emkornfield commented on a change in pull request #7012: URL: https://github.com/apache/arrow/pull/7012#discussion_r419200128 ## File path: java/flight/flight-core/src/test/java/org/apache/arrow/flight/TestDoExchange.java ## @@ -0,0 +1,407 @@ +/* + * Licensed to the Apache Sof

[GitHub] [arrow] emkornfield commented on a change in pull request #7012: ARROW-8555: [FlightRPC][Java] implement DoExchange

2020-05-03 Thread GitBox
emkornfield commented on a change in pull request #7012: URL: https://github.com/apache/arrow/pull/7012#discussion_r419199838 ## File path: java/flight/flight-core/src/main/java/org/apache/arrow/flight/FlightService.java ## @@ -155,79 +152,35 @@ public void setOnCancelHandler(

[GitHub] [arrow] emkornfield commented on a change in pull request #7012: ARROW-8555: [FlightRPC][Java] implement DoExchange

2020-04-28 Thread GitBox
emkornfield commented on a change in pull request #7012: URL: https://github.com/apache/arrow/pull/7012#discussion_r417067307 ## File path: java/flight/flight-core/src/main/java/org/apache/arrow/flight/ArrowMessage.java ## @@ -154,6 +154,20 @@ public ArrowMessage(ArrowDictiona