|
Push Down Method public setAutoRead(enableAutoRead boolean) : void from class org.apache.drill.exec.rpc.RemoteConnection to public setAutoRead(enableAutoRead boolean) : void from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method package recordRemoteFailure(coordinationId int, failure DrillPBError) : void from class org.apache.drill.exec.rpc.RemoteConnection to public recordRemoteFailure(coordinationId int, failure DrillPBError) : void from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method public getChannel() : Channel from class org.apache.drill.exec.rpc.RemoteConnection to public getChannel() : Channel from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method public RemoteConnection(channel SocketChannel, name String) from class org.apache.drill.exec.rpc.RemoteConnection to public AbstractRemoteConnection(channel SocketChannel, name String) from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method public close() : void from class org.apache.drill.exec.rpc.RemoteConnection to public close() : void from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method package channelClosed(ex RpcException) : void from class org.apache.drill.exec.rpc.RemoteConnection to public channelClosed(ex RpcException) : void from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method package getAndRemoveRpcOutcome(rpcType int, coordinationId int, clazz Class<V>) : RpcOutcome<V> from class org.apache.drill.exec.rpc.RemoteConnection to public getAndRemoveRpcOutcome(rpcType int, coordinationId int, clazz Class<V>) : RpcOutcome<V> from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method package createNewRpcListener(handler RpcOutcomeListener<V>, clazz Class<V>) : ChannelListenerWithCoordinationId from class org.apache.drill.exec.rpc.RemoteConnection to public createNewRpcListener(handler RpcOutcomeListener<V>, clazz Class<V>) : ChannelListenerWithCoordinationId from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method public isActive() : boolean from class org.apache.drill.exec.rpc.RemoteConnection to public isActive() : boolean from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method public blockOnNotWritable(listener RpcOutcomeListener<?>) : boolean from class org.apache.drill.exec.rpc.RemoteConnection to public blockOnNotWritable(listener RpcOutcomeListener<?>) : boolean from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method public inEventLoop() : boolean from class org.apache.drill.exec.rpc.RemoteConnection to public inEventLoop() : boolean from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Method public getName() : String from class org.apache.drill.exec.rpc.RemoteConnection to public getName() : String from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Change Parameter Type cmd : C to cmd : R in method public runCommand(cmd R) : void in class org.apache.drill.exec.rpc.ReconnectingConnection |
From |
To |
|
Change Parameter Type l : RpcConnectionHandler<R> to l : RpcConnectionHandler<CC> in method public ConnectionMultiListener(l RpcConnectionHandler<CC>, handshakeValue HS) in class org.apache.drill.exec.rpc.BasicClient.ConnectionMultiListener |
From |
To |
|
Change Parameter Type type : RpcConnectionHandler.FailureType to type : FailureType in method public connectionFailed(type FailureType, t Throwable) : void in class org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture |
From |
To |
|
Change Parameter Type msg : HANDSHAKE_RESPONSE to msg : HR in method protected consumeHandshake(ctx ChannelHandlerContext, msg HR) : void in class org.apache.drill.exec.rpc.BasicClient.ClientHandshakeHandler |
From |
To |
|
Change Parameter Type incoming : CONNECTION_TYPE to incoming : C in method public connectionSucceeded(incoming C) : void in class org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture |
From |
To |
|
Change Parameter Type handshakeValue : HANDSHAKE_SEND to handshakeValue : HS in method public ConnectionMultiListener(l RpcConnectionHandler<CC>, handshakeValue HS) in class org.apache.drill.exec.rpc.BasicClient.ConnectionMultiListener |
From |
To |
|
Change Parameter Type connection : CONNECTION_TYPE to connection : C in method public getHandler(connection C, parent GenericFutureListener<ChannelFuture>) : GenericFutureListener<ChannelFuture> in class org.apache.drill.exec.rpc.ReconnectingConnection.CloseHandlerCreator |
From |
To |
|
Change Parameter Type connection : CONNECTION_TYPE to connection : C in method public CloseHandler(connection C, parent GenericFutureListener<ChannelFuture>) in class org.apache.drill.exec.rpc.ReconnectingConnection.CloseHandler |
From |
To |
|
Change Parameter Type connection : CONNECTION_TYPE to connection : C in method public addExternalConnection(connection C) : void in class org.apache.drill.exec.rpc.ReconnectingConnection |
From |
To |
|
Change Parameter Type cmd : C to cmd : RpcCommand<R,C> in method public ConnectionListeningFuture(cmd RpcCommand<R,C>) in class org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture |
From |
To |
|
Change Parameter Type connection : C to connection : SC in method public LoggingReadTimeoutHandler(connection SC, timeoutSeconds int) in class org.apache.drill.exec.rpc.BasicServer.LoggingReadTimeoutHandler |
From |
To |
|
Change Parameter Type value : HANDSHAKE_RESPONSE to value : HR in method public success(value HR, buffer ByteBuf) : void in class org.apache.drill.exec.rpc.BasicClient.ConnectionMultiListener.HandshakeSendHandler |
From |
To |
|
Change Parameter Type handshakeValue : HANDSHAKE_SEND to handshakeValue : HS in method protected connectAsClient(connectionListener RpcConnectionHandler<CC>, handshakeValue HS, host String, port int) : void in class org.apache.drill.exec.rpc.BasicClient |
From |
To |
|
Change Parameter Type connection : R to connection : CC in method public ClientHandshakeHandler(connection CC) in class org.apache.drill.exec.rpc.BasicClient.ClientHandshakeHandler |
From |
To |
|
Change Parameter Type responseClass : Class<HANDSHAKE_RESPONSE> to responseClass : Class<HR> in method public BasicClient(rpcMapping RpcConfig, alloc ByteBufAllocator, eventLoopGroup EventLoopGroup, handshakeType T, responseClass Class<HR>, handshakeParser Parser<HR>) in class org.apache.drill.exec.rpc.BasicClient |
From |
To |
|
Change Parameter Type handshakeParser : Parser<HANDSHAKE_RESPONSE> to handshakeParser : Parser<HR> in method public BasicClient(rpcMapping RpcConfig, alloc ByteBufAllocator, eventLoopGroup EventLoopGroup, handshakeType T, responseClass Class<HR>, handshakeParser Parser<HR>) in class org.apache.drill.exec.rpc.BasicClient |
From |
To |
|
Change Parameter Type connectionListener : RpcConnectionHandler<R> to connectionListener : RpcConnectionHandler<CC> in method protected connectAsClient(connectionListener RpcConnectionHandler<CC>, handshakeValue HS, host String, port int) : void in class org.apache.drill.exec.rpc.BasicClient |
From |
To |
|
Change Parameter Type handshake : OUTBOUND_HANDSHAKE to handshake : HS in method public ReconnectingConnection(handshake HS, host String, port int) in class org.apache.drill.exec.rpc.ReconnectingConnection |
From |
To |
|
Push Down Attribute package logger : org.slf4j.Logger from class org.apache.drill.exec.rpc.RemoteConnection to private logger : org.slf4j.Logger from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Attribute private channel : Channel from class org.apache.drill.exec.rpc.RemoteConnection to private channel : Channel from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Attribute private writeManager : WriteManager from class org.apache.drill.exec.rpc.RemoteConnection to private writeManager : WriteManager from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Attribute private clientName : String from class org.apache.drill.exec.rpc.RemoteConnection to private clientName : String from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Attribute private requestIdMap : RequestIdMap from class org.apache.drill.exec.rpc.RemoteConnection to private requestIdMap : RequestIdMap from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Push Down Attribute private name : String from class org.apache.drill.exec.rpc.RemoteConnection to private name : String from class org.apache.drill.exec.rpc.AbstractRemoteConnection |
From |
To |
|
Change Variable Type response : RpcOutcome<HANDSHAKE_RESPONSE> to response : RpcOutcome<HR> in method protected consumeHandshake(ctx ChannelHandlerContext, msg HR) : void in class org.apache.drill.exec.rpc.BasicClient.ClientHandshakeHandler |
From |
To |
|
Change Variable Type connection : CONNECTION_TYPE to connection : C in method public runCommand(cmd R) : void in class org.apache.drill.exec.rpc.ReconnectingConnection |
From |
To |
|
Change Variable Type connection : CONNECTION_TYPE to connection : C in method public waitAndRun() : void in class org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture |
From |
To |
|
Change Variable Type c : CONNECTION_TYPE to c : C in method public close() : void in class org.apache.drill.exec.rpc.ReconnectingConnection |
From |
To |
|
Change Variable Type connection : CONNECTION_TYPE to connection : C in method public connectionSucceeded(incoming C) : void in class org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture |
From |
To |
|
Change Variable Type client : BasicClient<?,CONNECTION_TYPE,OUTBOUND_HANDSHAKE,?> to client : BasicClient<?,C,HS,?> in method public runCommand(cmd R) : void in class org.apache.drill.exec.rpc.ReconnectingConnection |
From |
To |
|
Change Attribute Type connection : CONNECTION_TYPE to connection : C in class org.apache.drill.exec.rpc.ReconnectingConnection.CloseHandler |
From |
To |
|
Change Attribute Type handshakeParser : Parser<HANDSHAKE_RESPONSE> to handshakeParser : Parser<HR> in class org.apache.drill.exec.rpc.BasicClient |
From |
To |
|
Change Attribute Type handshakeValue : HANDSHAKE_SEND to handshakeValue : HS in class org.apache.drill.exec.rpc.BasicClient.ConnectionMultiListener |
From |
To |
|
Change Attribute Type connection : R to connection : CC in class org.apache.drill.exec.rpc.BasicClient.ClientHandshakeHandler |
From |
To |
|
Change Attribute Type l : RpcConnectionHandler<R> to l : RpcConnectionHandler<CC> in class org.apache.drill.exec.rpc.BasicClient.ConnectionMultiListener |
From |
To |
|
Change Attribute Type connectionHolder : AtomicReference<CONNECTION_TYPE> to connectionHolder : AtomicReference<C> in class org.apache.drill.exec.rpc.ReconnectingConnection |
From |
To |
|
Change Attribute Type connection : R to connection : CC in class org.apache.drill.exec.rpc.BasicClient |
From |
To |
|
Change Attribute Type handshake : OUTBOUND_HANDSHAKE to handshake : HS in class org.apache.drill.exec.rpc.ReconnectingConnection |
From |
To |
|
Change Attribute Type responseClass : Class<HANDSHAKE_RESPONSE> to responseClass : Class<HR> in class org.apache.drill.exec.rpc.BasicClient |
From |
To |
|
Change Attribute Type connection : C to connection : SC in class org.apache.drill.exec.rpc.BasicServer.LoggingReadTimeoutHandler |
From |
To |
|
Change Attribute Type cmd : C to cmd : RpcCommand<R,C> in class org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture |
From |
To |