Toggle navigation
Home
com.hubspot.singularity.SingularityS3Log to com.hubspot.singularity.SingularityS3LogMetadata
No. of Instances - 12
No. of Commits - 2
No. of Projects - {'Singularity'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
getS3PrefixesForTask(configuration.get(),taskIdObject,start,end)
to
getS3PrefixesForTask(configuration.get(),taskIdObject,start,end,maybeGroup)
getS3PrefixesForRequest(configuration.get(),requestId,start,end)
to
getS3PrefixesForRequest(configuration.get(),requestId,start,end,maybeGroup)
getRequestGroup(requestId)
to
maybeGroup
getS3PrefixesForDeploy(configuration.get(),requestId,deployId,start,end)
to
getS3PrefixesForDeploy(configuration.get(),requestId,deployId,start,end,maybeGroup)
executorService.submit(new Callable<SingularityS3LogMetadata>(){ @Override public SingularityS3Log call() throws Exception { String getUrl=s3Service.createSignedGetUrl(s3Bucket,s3Object.getKey(),expireAt); String downloadUrl=s3Service.createSignedUrl("GET",s3Bucket,s3Object.getKey(),FORCE_DOWNLOAD_S3_PARAMS,null,expireAt.getTime() / 1000,false); Optional<Long> maybeStartTime=Optional.absent(); Optional<Long> maybeEndTime=Optional.absent(); if (!excludeMetadata) { Map<String,Object> objectMetadata=s3Service.getObjectDetails(s3Bucket,s3Object.getKey()).getMetadataMap(); maybeStartTime=getMetadataAsLong(objectMetadata,SingularityS3Log.LOG_START_S3_ATTR); maybeEndTime=getMetadataAsLong(objectMetadata,SingularityS3Log.LOG_END_S3_ATTR); } return new SingularityS3Log(getUrl,s3Object.getKey(),s3Object.getLastModifiedDate().getTime(),s3Object.getContentLength(),downloadUrl,maybeStartTime,maybeEndTime); } } )
to
executorService.submit(new Callable<SingularityS3LogMetadata>(){ @Override public SingularityS3LogMetadata call() throws Exception { Optional<Long> maybeStartTime=Optional.absent(); Optional<Long> maybeEndTime=Optional.absent(); if (!excludeMetadata) { Map<String,Object> objectMetadata=s3Service.getObjectDetails(s3Object.getBucketName(),s3Object.getKey()).getMetadataMap(); maybeStartTime=getMetadataAsLong(objectMetadata,SingularityS3Log.LOG_START_S3_ATTR); maybeEndTime=getMetadataAsLong(objectMetadata,SingularityS3Log.LOG_END_S3_ATTR); } if (listOnly) { return new SingularityS3LogMetadata(s3Object.getKey(),s3Object.getLastModifiedDate().getTime(),s3Object.getContentLength(),maybeStartTime,maybeEndTime); } else { String getUrl=s3Service.createSignedGetUrl(s3Object.getBucketName(),s3Object.getKey(),expireAt); String downloadUrl=s3Service.createSignedUrl("GET",s3Object.getBucketName(),s3Object.getKey(),FORCE_DOWNLOAD_S3_PARAMS,null,expireAt.getTime() / 1000,false); return new SingularityS3Log(getUrl,s3Object.getKey(),s3Object.getLastModifiedDate().getTime(),s3Object.getContentLength(),downloadUrl,maybeStartTime,maybeEndTime); } } } )
Update argument list (Method invocation)
getS3Logs
to
getS3Logs
getS3Logs
to
getS3Logs
getS3Logs
to
getS3Logs
Cascading Type Change (Different)
Callable<SingularityS3Log>
to
Callable<SingularityS3LogMetadata>