java.lang.Void to java.lang.Long
No. of Instances - 3
No. of Commits - 3
No. of Projects - {'orientdb'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Jdk
Mapping:
- Cascading Type Change (Different)
- Cascading Type Change (Similar)
- Void to Long
- AsyncMethodCallback<Void> to AsyncMethodCallback<Long>
- Void to Long
- AsyncMethodCallback<Void> to AsyncMethodCallback<Long>
- Void to Long
- AsyncMethodCallback<Void> to AsyncMethodCallback<Long>
- Void to Long
- AsyncMethodCallback<Void> to AsyncMethodCallback<Long>
- Consumer<Void> to Consumer<Long>
- Add or Remove Method invocation
- result.setEPIsSet(true) to result.setFdneeIsSet(true)
- result.setEBIsSet(true) to result.setBieIsSet(true)
- resultHandler.handle(Future.succeededFuture()) to resultHandler.handle(Future.succeededFuture(bytesWritten))
- resultHandler.handle(Future.succeededFuture()) to resultHandler.handle(Future.succeededFuture(bytesWritten))
- onReceive to onReceive
- Update Anonymous class
- { public void onComplete( Void o){ workerCacheBlock_result result=new workerCacheBlock_result(); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; workerCacheBlock_result result=new workerCacheBlock_result(); if (e instanceof FileDoesNotExistException) { result.eP=(FileDoesNotExistException)e; result.setEPIsSet(true); msg=result; } else if (e instanceof BlockInfoException) { result.eB=(BlockInfoException)e; result.setEBIsSet(true); msg=result; } else { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } } to { public void onComplete( Long o){ getFileBlockId_result result=new getFileBlockId_result(); result.success=o; result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; getFileBlockId_result result=new getFileBlockId_result(); if (e instanceof FileDoesNotExistException) { result.fdnee=(FileDoesNotExistException)e; result.setFdneeIsSet(true); msg=result; } else if (e instanceof BlockInfoException) { result.bie=(BlockInfoException)e; result.setBieIsSet(true); msg=result; } else { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } }
- { public void onComplete( Void o){ ufsCreateFile_result result=new ufsCreateFile_result(); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; ufsCreateFile_result result=new ufsCreateFile_result(); if (e instanceof alluxio.thrift.AlluxioTException) { result.e=(alluxio.thrift.AlluxioTException)e; result.setEIsSet(true); msg=result; } else if (e instanceof alluxio.thrift.ThriftIOException) { result.ioe=(alluxio.thrift.ThriftIOException)e; result.setIoeIsSet(true); msg=result; } else { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } } to { public void onComplete( Long o){ ufsCreateFile_result result=new ufsCreateFile_result(); result.success=o; result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; ufsCreateFile_result result=new ufsCreateFile_result(); if (e instanceof alluxio.thrift.AlluxioTException) { result.e=(alluxio.thrift.AlluxioTException)e; result.setEIsSet(true); msg=result; } else if (e instanceof alluxio.thrift.ThriftIOException) { result.ioe=(alluxio.thrift.ThriftIOException)e; result.setIoeIsSet(true); msg=result; } else { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } }
- { public void onComplete( Void o){ completeUfsFile_result result=new completeUfsFile_result(); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; completeUfsFile_result result=new completeUfsFile_result(); if (e instanceof alluxio.thrift.AlluxioTException) { result.e=(alluxio.thrift.AlluxioTException)e; result.setEIsSet(true); msg=result; } else if (e instanceof alluxio.thrift.ThriftIOException) { result.ioe=(alluxio.thrift.ThriftIOException)e; result.setIoeIsSet(true); msg=result; } else { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } } to { public void onComplete( Long o){ completeUfsFile_result result=new completeUfsFile_result(); result.success=o; result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; completeUfsFile_result result=new completeUfsFile_result(); if (e instanceof alluxio.thrift.AlluxioTException) { result.e=(alluxio.thrift.AlluxioTException)e; result.setEIsSet(true); msg=result; } else if (e instanceof alluxio.thrift.ThriftIOException) { result.ioe=(alluxio.thrift.ThriftIOException)e; result.setIoeIsSet(true); msg=result; } else { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } }
- { public void onComplete( Void o){ completeUfsFile_result result=new completeUfsFile_result(); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; completeUfsFile_result result=new completeUfsFile_result(); if (e instanceof alluxio.thrift.AlluxioTException) { result.e=(alluxio.thrift.AlluxioTException)e; result.setEIsSet(true); msg=result; } else if (e instanceof alluxio.thrift.ThriftIOException) { result.ioe=(alluxio.thrift.ThriftIOException)e; result.setIoeIsSet(true); msg=result; } else { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } } to { public void onComplete( Long o){ completeUfsFile_result result=new completeUfsFile_result(); result.success=o; result.setSuccessIsSet(true); try { fcall.sendResponse(fb,result,org.apache.thrift.protocol.TMessageType.REPLY,seqid); return; } catch ( Exception e) { LOGGER.error("Exception writing to internal frame buffer",e); } fb.close(); } public void onError( Exception e){ byte msgType=org.apache.thrift.protocol.TMessageType.REPLY; org.apache.thrift.TBase msg; completeUfsFile_result result=new completeUfsFile_result(); if (e instanceof alluxio.thrift.AlluxioTException) { result.e=(alluxio.thrift.AlluxioTException)e; result.setEIsSet(true); msg=result; } else if (e instanceof alluxio.thrift.ThriftIOException) { result.ioe=(alluxio.thrift.ThriftIOException)e; result.setIoeIsSet(true); msg=result; } else { msgType=org.apache.thrift.protocol.TMessageType.EXCEPTION; msg=(org.apache.thrift.TBase)new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.INTERNAL_ERROR,e.getMessage()); } try { fcall.sendResponse(fb,msg,msgType,seqid); return; } catch ( Exception ex) { LOGGER.error("Exception writing to internal frame buffer",ex); } fb.close(); } }
- { @Override public void userEventTriggered( ChannelHandlerContext ctx, Object evt) throws Exception { if (evt instanceof RandomAccessFile) { ChannelFuture fut=ctx.writeAndFlush(new ChunkedFile((RandomAccessFile)evt)); fut.addListener(f -> { if (resultHandler != null) { resultCtx.runOnContext(v -> { if (f.isSuccess()) { resultHandler.handle(Future.succeededFuture()); } else { resultHandler.handle(Future.failedFuture(f.cause())); } } ); } fut.addListener(ChannelFutureListener.CLOSE); } ); } } } to { @Override public void userEventTriggered( ChannelHandlerContext ctx, Object evt) throws Exception { if (evt instanceof RandomAccessFile) { ChannelFuture fut=ctx.writeAndFlush(new ChunkedFile((RandomAccessFile)evt)); fut.addListener(f -> { if (resultHandler != null) { if (f.isSuccess()) { resultHandler.handle(Future.succeededFuture(bytesWritten)); } else { resultHandler.handle(Future.failedFuture(f.cause())); } } fut.addListener(ChannelFutureListener.CLOSE); } ); } } }
- Other
- null to bytesWritten
- null to epoch
- Wrap or Un-wrap
- Rename Variable