|
Change Parameter Type response : short to response : int in method public messageAckReceived(taskId int, requestId long, response int) : void in class org.apache.giraph.comm.flow_control.StaticFlowControl |
From |
To |
|
Change Parameter Type response : short to response : int in method public getAckSignalFlag(response int) : AckSignalFlag in class org.apache.giraph.comm.flow_control.FlowControl |
From |
To |
|
Change Parameter Type response : short to response : int in method public getAckSignalFlag(response int) : AckSignalFlag in class org.apache.giraph.comm.flow_control.StaticFlowControl |
From |
To |
|
Change Parameter Type response : short to response : int in method public messageReceived(senderId int, requestId long, response int, shouldDrop boolean) : void in class org.apache.giraph.comm.netty.NettyClient |
From |
To |
|
Change Parameter Type value : long to value : T in method public set(value T, hostname String) : void in class org.apache.giraph.metrics.ValueWithHostname |
From |
To |
|
Change Parameter Type value : long to value : Long in method public addItem(value Long, hostnamePartitionId String) : void in class org.apache.giraph.metrics.AggregatedMetricLong |
From |
To |
|
Change Parameter Type response : short to response : int in method public getAckSignalFlag(response int) : AckSignalFlag in class org.apache.giraph.comm.flow_control.NoOpFlowControl |
From |
To |
|
Change Parameter Type value : long to value : T in method public ValueWithHostname(value T) in class org.apache.giraph.metrics.ValueWithHostname |
From |
To |
|
Change Parameter Type response : short to response : int in method public messageAckReceived(taskId int, requestId long, response int) : void in class org.apache.giraph.comm.flow_control.FlowControl |
From |
To |
|
Change Parameter Type value : long to value : Double in method public addItem(value Double, hostnamePartitionId String) : void in class org.apache.giraph.metrics.AggregatedMetricDouble |
From |
To |
|
Change Return Type void to boolean in method public execute(basePath String) : boolean in class org.apache.giraph.ooc.io.LoadPartitionIOCommand |
From |
To |
|
Change Return Type void to long in method public loadPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedEdgeStore |
From |
To |
|
Change Return Type void to long in method public loadPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedMessageStore |
From |
To |
|
Change Return Type void to boolean in method public abstract execute(basePath String) : boolean in class org.apache.giraph.ooc.io.IOCommand |
From |
To |
|
Change Return Type short to int in method public calculateResponse(flag AckSignalFlag, taskId int) : int in class org.apache.giraph.comm.flow_control.FlowControl |
From |
To |
|
Change Return Type void to boolean in method public execute(basePath String) : boolean in class org.apache.giraph.ooc.io.StoreDataBufferIOCommand |
From |
To |
|
Change Return Type void to long in method public offloadPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedPartitionStore |
From |
To |
|
Change Return Type void to boolean in method public execute(basePath String) : boolean in class org.apache.giraph.ooc.io.StorePartitionIOCommand |
From |
To |
|
Change Return Type void to long in method public offloadPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.OutOfCoreDataManager |
From |
To |
|
Change Return Type void to Long in method public doSend(destTaskId int, request WritableRequest) : Long in class org.apache.giraph.comm.netty.NettyClient |
From |
To |
|
Change Return Type void to long in method protected abstract loadInMemoryPartitionData(partitionId int, path String) : long in class org.apache.giraph.ooc.data.OutOfCoreDataManager |
From |
To |
|
Change Return Type void to boolean in method public execute(basePath String) : boolean in class org.apache.giraph.ooc.io.StoreIncomingMessageIOCommand |
From |
To |
|
Change Return Type void to long in method public offloadBuffers(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedPartitionStore |
From |
To |
|
Change Return Type void to long in method protected offloadInMemoryPartitionData(partitionId int, path String) : long in class org.apache.giraph.ooc.data.DiskBackedEdgeStore |
From |
To |
|
Change Return Type ValueWithHostname to ValueWithHostname<T> in method public min() : ValueWithHostname<T> in class org.apache.giraph.metrics.AggregatedMetric |
From |
To |
|
Change Return Type short to int in method public calculateResponse(flag AckSignalFlag, taskId int) : int in class org.apache.giraph.comm.flow_control.CreditBasedFlowControl |
From |
To |
|
Change Return Type void to long in method public offloadPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedEdgeStore |
From |
To |
|
Change Return Type long to T in method public getValue() : T in class org.apache.giraph.metrics.ValueWithHostname |
From |
To |
|
Change Return Type ValueWithHostname to ValueWithHostname<T> in method public max() : ValueWithHostname<T> in class org.apache.giraph.metrics.AggregatedMetric |
From |
To |
|
Change Return Type void to long in method protected offloadInMemoryPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedMessageStore |
From |
To |
|
Change Return Type void to long in method protected abstract offloadInMemoryPartitionData(partitionId int, path String) : long in class org.apache.giraph.ooc.data.OutOfCoreDataManager |
From |
To |
|
Change Return Type void to long in method public loadPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedPartitionStore |
From |
To |
|
Change Return Type void to long in method public offloadBuffers(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.OutOfCoreDataManager |
From |
To |
|
Change Return Type void to long in method protected offloadInMemoryPartitionData(partitionId int, path String) : long in class org.apache.giraph.ooc.data.DiskBackedPartitionStore |
From |
To |
|
Change Return Type short to int in method public calculateResponse(alreadyDone AckSignalFlag, taskId int) : int in class org.apache.giraph.comm.flow_control.NoOpFlowControl |
From |
To |
|
Change Return Type void to long in method protected loadInMemoryPartitionData(partitionId int, path String) : long in class org.apache.giraph.ooc.data.DiskBackedPartitionStore |
From |
To |
|
Change Return Type void to long in method public offloadPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedMessageStore |
From |
To |
|
Change Return Type short to int in method public calculateResponse(alreadyDone AckSignalFlag, clientId int) : int in class org.apache.giraph.comm.flow_control.StaticFlowControl |
From |
To |
|
Change Return Type void to long in method public offloadBuffers(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedEdgeStore |
From |
To |
|
Change Return Type void to long in method protected loadInMemoryPartitionData(partitionId int, path String) : long in class org.apache.giraph.ooc.data.DiskBackedEdgeStore |
From |
To |
|
Change Return Type void to long in method public offloadBuffers(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedMessageStore |
From |
To |
|
Change Return Type void to long in method public loadPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.OutOfCoreDataManager |
From |
To |
|
Change Return Type Map<String,AggregatedMetric> to Map<String,AggregatedMetric<?>> in method public getAll() : Map<String,AggregatedMetric<?>> in class org.apache.giraph.metrics.AggregatedMetrics |
From |
To |
|
Change Return Type void to long in method protected loadInMemoryPartitionData(partitionId int, basePath String) : long in class org.apache.giraph.ooc.data.DiskBackedMessageStore |
From |
To |
|
Change Return Type void to boolean in method public execute(basePath String) : boolean in class org.apache.giraph.ooc.io.WaitIOCommand |
From |
To |
|
Change Return Type long to T in method public sum() : T in class org.apache.giraph.metrics.AggregatedMetric |
From |
To |
|
Change Attribute Type metrics : Map<String,AggregatedMetric> to metrics : Map<String,AggregatedMetric<?>> in class org.apache.giraph.metrics.AggregatedMetrics |
From |
To |
|
Change Attribute Type perThreadPartitions : List<PerThreadPartitionStatus> to perThreadPartitionDictionary : List<MetaPartitionDictionary> in class org.apache.giraph.ooc.data.MetaPartitionManager |
From |
To |
|
Change Attribute Type sum : long to sum : T in class org.apache.giraph.metrics.AggregatedMetric |
From |
To |
|
Change Attribute Type max : ValueWithHostname to max : ValueWithHostname<T> in class org.apache.giraph.metrics.AggregatedMetric |
From |
To |
|
Change Attribute Type min : ValueWithHostname to min : ValueWithHostname<T> in class org.apache.giraph.metrics.AggregatedMetric |
From |
To |
|
Change Attribute Type value : long to value : T in class org.apache.giraph.metrics.ValueWithHostname |
From |
To |
|
Change Attribute Type perWorkerOpenRequestMap : ConcurrentMap<Integer,AdjustableSemaphore> to perWorkerOpenRequestMap : ConcurrentMap<Integer,Pair<AdjustableSemaphore,Integer>> in class org.apache.giraph.comm.flow_control.CreditBasedFlowControl |
From |
To |
|
Change Attribute Type maxOpenRequestsPerWorker : int to maxOpenRequestsPerWorker : short in class org.apache.giraph.comm.flow_control.CreditBasedFlowControl |
From |
To |