Apache Arrow Flight RPC clients

public class Query {
    public static void main(String[] args) {       
        String query = "SELECT * FROM home";
        Location location = Location.forGrpcTls(HOST, 443);

        CredentialCallOption auth = new CredentialCallOption(new BearerCredentialWriter(TOKEN));
        BufferAllocator allocator = new RootAllocator(Long.MAX_VALUE);

        FlightClientMiddleware.Factory f = info -> new FlightClientMiddleware() {
            @Override
            public void onBeforeSendingHeaders(CallHeaders outgoingHeaders) {
                outgoingHeaders.insert(DATABASE_FIELD, DATABASE_NAME);
            }
        };

        FlightClient client = FlightClient.builder(allocator, location)
                .intercept(f)
                .build();
        FlightSqlClient sqlClient = new FlightSqlClient(client);
        FlightInfo flightInfo = sqlClient.execute(query, auth);
    }
}

from pyarrow.flight import FlightClient, Ticket, FlightCallOptions 
import json
import pandas
import tabulate

# Downsampling query groups data into 2-hour bins
sql="""
  SELECT DATE_BIN(INTERVAL '2 hours',
      time,
      '1970-01-01T00:00:00Z'::TIMESTAMP) AS time,
    room,
    selector_max(temp, time)['value'] AS 'max temp',
    selector_min(temp, time)['value'] AS 'min temp',
    avg(temp) AS 'average temp'
  FROM home
  GROUP BY
    1,
    room
  ORDER BY room, 1"""
  
flight_ticket = Ticket(json.dumps({
  "namespace_name": "BUCKET_NAME",
  "sql_query": sql,
  "query_type": "sql"
}))

token = (b"authorization", bytes(f"Bearer API_TOKEN".encode('utf-8')))
options = FlightCallOptions(headers=[token])
client = FlightClient(f"grpc+tls://cloud2.influxdata.com:443")

reader = client.do_get(flight_ticket, options)
arrow_table = reader.read_all()