Toggle navigation
Home
org.apache.pulsar.functions.spawner.ExecutionResult to org.apache.pulsar.functions.instance.JavaExecutionResult
No. of Instances - 4
No. of Commits - 2
No. of Projects - {'pulsar'}
Hierarchy/Composition: T_SUPER_R
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
requestHandler.handleRequest(obj,context)
to
output
executorService.submit(new Runnable(){ @Override public void run(){ if (requestHandler != null) { try { Object obj=deserialize(data); executionResult.setResultValue(output); } catch ( Exception ex) { executionResult.setUserException(ex); } } else if (rawRequestHandler != null) { try { ByteArrayInputStream inputStream=new ByteArrayInputStream(data); ByteArrayOutputStream outputStream=new ByteArrayOutputStream(); rawRequestHandler.handleRequest(inputStream,outputStream,context); executionResult.setOutputStream(outputStream); } catch ( Exception ex) { executionResult.setUserException(ex); } } } } )
to
executorService.submit(new Runnable(){ @Override public void run(){ if (requestHandler != null) { try { Object input=deserialize(data); Object output=requestHandler.handleRequest(input,context); executionResult.setResult(serialize(output)); } catch ( Exception ex) { executionResult.setUserException(ex); } } else if (rawRequestHandler != null) { try { ByteArrayInputStream inputStream=new ByteArrayInputStream(data); ByteArrayOutputStream outputStream=new ByteArrayOutputStream(); rawRequestHandler.handleRequest(inputStream,outputStream,context); executionResult.setResult(outputStream.toByteArray()); } catch ( Exception ex) { executionResult.setUserException(ex); } } } } )