francoisa
05/19/2022, 3:54 PMSegmentZkMetada
my lastPurgeTime
during the segment build using something like what have been done in MergeRollupMinionClusterIntegrationTest
in the buildSegmentsFromAvroWithPostfix
method. Is there any way to put a metadata to the generated segment in order to validate my code ?francoisa
05/20/2022, 9:13 AM//set up not passed delay
List<SegmentZKMetadata> segmentsZKMetadataDeltaNotPassed= _pinotHelixResourceManager.getSegmentsZKMetadata(tablenameOfflineNotPassed);
Map<String,String> customSegmentMetadataNotPassed = new HashMap<>();
customSegmentMetadataNotPassed.put(MinionConstants.PurgeTask.TASK_TYPE + MinionConstants.TASK_TIME_SUFFIX, String.valueOf(System.currentTimeMillis()-4000));
for (SegmentZKMetadata segmentZKMetadata : segmentsZKMetadataDeltaNotPassed) {
segmentZKMetadata.setCustomMap(customSegmentMetadataNotPassed);
_pinotHelixResourceManager.updateZkMetadata(tablenameOfflineNotPassed,segmentZKMetadata);
}