public void handle()

in http/get_simple/java/server/src/main/java/com/example/ArrowHttpServer.java [115:141]

• 21 lines of code
• 2 McCabe index (conditional complexity)

    public void handle(String target, Request baseRequest, HttpServletRequest request, HttpServletResponse response)
            throws IOException, ServletException {

        response.setContentType("application/vnd.apache.arrow.stream");
        response.setStatus(HttpServletResponse.SC_OK);

        //// set this header to disable chunked transfer encoding:
        //response.setHeader("Connection", "close");
        
        response.flushBuffer();

        try (
            OutputStream stream = response.getOutputStream();
            VectorSchemaRoot root = VectorSchemaRoot.create(schema, allocator);
            ArrowStreamWriter writer = new ArrowStreamWriter(root, /*DictionaryProvider=*/null, stream);
        ) {
            VectorLoader loader = new VectorLoader(root);
            writer.start();
            for (ArrowRecordBatch batch : batches) {
                loader.load(batch);
                writer.writeBatch();
                stream.flush();
            }
            writer.end();
        }
        baseRequest.setHandled(true);
    }