Toggle navigation
Home
org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation to java.util.Optional<org.apache.hadoop.hbase.procedure2.RemoteProcedureDispatcher.RemoteOperation>
No. of Instances - 10
No. of Commits - 1
No. of Projects - {'hbase'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Other
new ServerOperation(this,getProcId(),ReplaySyncReplicationWALCallable.class,builder.build().toByteArray())
to
new ServerOperation(this,getProcId(),ReplaySyncReplicationWALCallable.class,builder.build().toByteArray())
new RSProcedureDispatcher.ServerOperation(this,getProcId(),SwitchRpcThrottleRemoteCallable.class,SwitchRpcThrottleRemoteStateData.newBuilder().setTargetServer(ProtobufUtil.toServerName(remote)).setRpcThrottleEnabled(rpcThrottleEnabled).build().toByteArray())
to
new RSProcedureDispatcher.ServerOperation(this,getProcId(),SwitchRpcThrottleRemoteCallable.class,SwitchRpcThrottleRemoteStateData.newBuilder().setTargetServer(ProtobufUtil.toServerName(remote)).setRpcThrottleEnabled(rpcThrottleEnabled).build().toByteArray())
new RSProcedureDispatcher.ServerOperation(null,0L,this.getClass(),new byte[0])
to
new RSProcedureDispatcher.ServerOperation(null,0L,this.getClass(),new byte[0])
new RSProcedureDispatcher.ServerOperation(this,getProcId(),SplitWALCallable.class,MasterProcedureProtos.SplitWALParameter.newBuilder().setWalPath(walPath).build().toByteArray())
to
new RSProcedureDispatcher.ServerOperation(this,getProcId(),SplitWALCallable.class,MasterProcedureProtos.SplitWALParameter.newBuilder().setWalPath(walPath).build().toByteArray())
new ServerOperation(this,getProcId(),RefreshPeerCallable.class,RefreshPeerParameter.newBuilder().setPeerId(peerId).setType(toPeerModificationType(type)).setTargetServer(ProtobufUtil.toServerName(remote)).setStage(stage).build().toByteArray())
to
new ServerOperation(this,getProcId(),RefreshPeerCallable.class,RefreshPeerParameter.newBuilder().setPeerId(peerId).setType(toPeerModificationType(type)).setTargetServer(ProtobufUtil.toServerName(remote)).setStage(stage).build().toByteArray())