public NexusTile nexusTileProcessor()

in src/main/java/org/apache/sdap/ningester/processors/PythonChainProcessor.java [47:68]


    public NexusTile nexusTileProcessor(NexusTile nexusTile) {

        HttpHeaders headers = new HttpHeaders();
        headers.setAccept(Collections.singletonList(MediaType.APPLICATION_OCTET_STREAM));
        headers.setContentType(MediaType.APPLICATION_JSON);

        PythonChainProcessorRequest chainProcessorRequest = new PythonChainProcessorRequest();
        chainProcessorRequest.setProcessorList(processorList);
        try {
            chainProcessorRequest.setNexusTile(JsonFormat.printer().print(nexusTile));
        } catch (InvalidProtocolBufferException e) {
            throw new RuntimeException(e);
        }

        HttpEntity<PythonChainProcessorRequest> requestEntity = new HttpEntity<>(chainProcessorRequest, headers);

        return restTemplate.exchange(
                uriPath,
                HttpMethod.POST,
                requestEntity,
                NexusTile.class).getBody();
    }