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();
}