Toggle navigation
Home
boolean to org.apache.flink.runtime.blob.BlobKey.BlobType
No. of Instances - 33
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Rename Variable
highAvailability
to
blobType
permanentBlob
to
blobType
highAvailability
to
blobType
permanentBlob
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
permanentBlob
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
permanentBlob
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
permanentBlob
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
highAvailability
to
blobType
Add or Remove Method invocation
CompletableFuture.supplyAsync(() -> { try { BlockingInputStream inputStream=new BlockingInputStream(countDownLatch,data); BlobKey uploadedKey=put(server,jobId,inputStream,highAvailability); verifyContents(server,jobId,uploadedKey,data,highAvailability); return uploadedKey; } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not upload blob.",e)); } } ,executor)
to
CompletableFuture.supplyAsync(() -> { try { BlockingInputStream inputStream=new BlockingInputStream(countDownLatch,data); BlobKey uploadedKey=put(server,jobId,inputStream,blobType); verifyContents(server,jobId,uploadedKey,data); return uploadedKey; } catch ( IOException e) { throw new CompletionException(new FlinkException("Could not upload blob.",e)); } } ,executor)