Toggle navigation
Home
org.apache.hadoop.io.retry.RetryPolicy to long
No. of Instances - 3
No. of Commits - 1
No. of Projects - {'hadoop'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Jdk
Mapping:
Add or Remove Method invocation
OzoneClientUtils.createRetryPolicy(conf)
to
conf.getTimeDuration(OzoneConfigKeys.OZONE_CLIENT_WATCH_REQUEST_TIMEOUT,OzoneConfigKeys.OZONE_CLIENT_WATCH_REQUEST_TIMEOUT_DEFAULT,TimeUnit.MILLISECONDS)
new ChunkGroupOutputStream.Builder().setHandler(openKey).setXceiverClientManager(xceiverClientManager).setScmClient(storageContainerLocationClient).setOmClient(ozoneManagerClient).setChunkSize(chunkSize).setRequestID(requestId).setType(HddsProtos.ReplicationType.valueOf(type.toString())).setFactor(HddsProtos.ReplicationFactor.valueOf(factor.getValue())).setRetryPolicy(retryPolicy)
to
new ChunkGroupOutputStream.Builder().setHandler(openKey).setXceiverClientManager(xceiverClientManager).setScmClient(storageContainerLocationClient).setOmClient(ozoneManagerClient).setChunkSize(chunkSize).setRequestID(requestId).setType(HddsProtos.ReplicationType.valueOf(type.toString())).setFactor(HddsProtos.ReplicationFactor.valueOf(factor.getValue())).setStreamBufferFlushSize(streamBufferFlushSize).setStreamBufferMaxSize(streamBufferMaxSize).setWatchTimeout(watchTimeout).setBlockSize(blockSize)
OzoneClientUtils.createRetryPolicy(conf)
to
conf.getLong(OzoneConfigKeys.OZONE_CLIENT_STREAM_BUFFER_MAX_SIZE,OzoneConfigKeys.OZONE_CLIENT_STREAM_BUFFER_MAX_SIZE_DEFAULT)
new ChunkGroupOutputStream.Builder().setHandler(openKey).setXceiverClientManager(xceiverClientManager).setScmClient(storageContainerLocationClient).setOmClient(ozoneManagerClient).setChunkSize(chunkSize).setRequestID(args.getRequestID()).setType(xceiverClientManager.getType()).setFactor(xceiverClientManager.getFactor()).setRetryPolicy(retryPolicy)
to
new ChunkGroupOutputStream.Builder().setHandler(openKey).setXceiverClientManager(xceiverClientManager).setScmClient(storageContainerLocationClient).setOmClient(ozoneManagerClient).setChunkSize(chunkSize).setRequestID(args.getRequestID()).setType(xceiverClientManager.getType()).setFactor(xceiverClientManager.getFactor()).setStreamBufferFlushSize(streamBufferFlushSize).setStreamBufferMaxSize(streamBufferMaxSize).setBlockSize(blockSize).setWatchTimeout(watchTimeout)
Rename Variable
retryPolicy
to
watchTimeout
retryPolicy
to
watchTimeout
retryPolicy
to
streamBufferFlushSize
retryPolicy
to
streamBufferMaxSize
retryPolicy
to
streamBufferMaxSize