Toggle navigation
Home
org.apache.flink.runtime.blob.BlobCache to org.apache.flink.runtime.blob.BlobCacheService
No. of Instances - 49
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Rename Variable
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
getBlobCache
to
getBlobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
blobCache
to
blobService
Add or Remove Method invocation
cache.getPermanentBlobStore().getStorageLocation(jobId2,key)
to
cache.getPermanentBlobService().getStorageLocation(jobId2,key)
cache.getTransientBlobStore().getStorageLocation(jobId2,key)
to
cache.getTransientBlobService().getStorageLocation(jobId2,key)
cache.getPermanentBlobStore().getStorageLocation(jobId2,key)
to
cache.getPermanentBlobService().getStorageLocation(jobId2,key)
cache.getPermanentBlobStore().createTemporaryFilename().getParentFile()
to
cache.getPermanentBlobService().createTemporaryFilename().getParentFile()
cache.getTransientBlobStore().createTemporaryFilename().getParentFile()
to
cache.getTransientBlobService().createTemporaryFilename().getParentFile()
blobCache.getPermanentBlobStore()
to
blobService.getPermanentBlobService()
blobCache.getPermanentBlobStore()
to
blobService.getPermanentBlobService()
cache.getPermanentBlobStore().getStorageLocation(jobId,new PermanentBlobKey())
to
cache.getPermanentBlobService().getStorageLocation(jobId,new PermanentBlobKey())
cache.getTransientBlobStore().getStorageLocation(jobId,new TransientBlobKey())
to
cache.getTransientBlobService().getStorageLocation(jobId,new TransientBlobKey())
put(cache,jobId,inputStream,false)
to
put(cache,jobId,inputStream,blobType)
verifyContents(server,jobId,uploadedKey,data,false)
to
verifyContents(server,jobId,uploadedKey,data)
CompletableFuture.supplyAsync(() -> { try { File file=get(cache,jobId,blobKey,highAvailability); validateGetAndClose(new FileInputStream(file),data); return file; } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not upload blob.",e)); } } ,executor)
to
CompletableFuture.supplyAsync(() -> { try { File file=get(cache,jobId,blobKey); validateGetAndClose(new FileInputStream(file),data); return file; } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not read blob for key " + blobKey + '.',e)); } } ,executor)
CompletableFuture.supplyAsync(() -> { try { assertTrue(delete(cache,jobId,blobKey)); assertFalse(cache.getTransientBlobStore().getStorageLocation(jobId,blobKey).exists()); assertFalse(server.getStorageLocation(jobId,blobKey).exists()); return null; } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not upload blob.",e)); } } ,executor)
to
CompletableFuture.supplyAsync(() -> { try { assertTrue(delete(cache,jobId,blobKey)); assertFalse(cache.getTransientBlobService().getStorageLocation(jobId,blobKey).exists()); assertTrue(server.getStorageLocation(jobId,blobKey).exists()); return null; } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not upload blob.",e)); } } ,executor)
cache.getTransientBlobStore().getStorageLocation(jobId,key)
to
cache.getTransientBlobService().getStorageLocation(jobId,key)
Cascading Type Change (Different)
BlobKey
to
PermanentBlobKey
BlobKey
to
TransientBlobKey
Cascading Type Change (Similar)
BlobCache
to
BlobCacheService
BlobCache
to
BlobCacheService
BlobCache
to
BlobCacheService
Rename Method invocation
getBlobCache
to
getBlobService