[
https://issues.apache.org/jira/browse/HADOOP-17115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Viraj Jasani updated HADOOP-17115:
----------------------------------
Target Version/s: 3.4.0
> Replace Guava Sets usage by Hadoop's own Sets
> ---------------------------------------------
>
> Key: HADOOP-17115
> URL: https://issues.apache.org/jira/browse/HADOOP-17115
> Project: Hadoop Common
> Issue Type: Sub-task
> Reporter: Ahmed Hussein
> Assignee: Viraj Jasani
> Priority: Major
> Labels: pull-request-available
> Time Spent: 8h
> Remaining Estimate: 0h
>
> Unjustified usage of Guava API to initialize a {{HashSet}}. This should be
> replaced by Java APIs.
> {code:java}
> Targets
> Occurrences of 'Sets.newHashSet' in project
> Found Occurrences (223 usages found)
> org.apache.hadoop.crypto.key (2 usages found)
> TestValueQueue.java (2 usages found)
> testWarmUp() (2 usages found)
> 106 Assert.assertEquals(Sets.newHashSet("k1", "k2", "k3"),
> 107 Sets.newHashSet(fillInfos[0].key,
> org.apache.hadoop.crypto.key.kms (6 usages found)
> TestLoadBalancingKMSClientProvider.java (6 usages found)
> testCreation() (6 usages found)
> 86
> assertEquals(Sets.newHashSet("http://host1:9600/kms/foo/v1/";),
> 87 Sets.newHashSet(providers[0].getKMSUrl()));
> 95
> assertEquals(Sets.newHashSet("http://host1:9600/kms/foo/v1/";,
> 98 Sets.newHashSet(providers[0].getKMSUrl(),
> 108
> assertEquals(Sets.newHashSet("http://host1:9600/kms/foo/v1/";,
> 111 Sets.newHashSet(providers[0].getKMSUrl(),
> org.apache.hadoop.crypto.key.kms.server (1 usage found)
> KMSAudit.java (1 usage found)
> 59 static final Set<KMS.KMSOp> AGGREGATE_OPS_WHITELIST =
> Sets.newHashSet(
> org.apache.hadoop.fs.s3a (1 usage found)
> TestS3AAWSCredentialsProvider.java (1 usage found)
> testFallbackToDefaults() (1 usage found)
> 183 Sets.newHashSet());
> org.apache.hadoop.fs.s3a.auth (1 usage found)
> AssumedRoleCredentialProvider.java (1 usage found)
> AssumedRoleCredentialProvider(URI, Configuration) (1 usage found)
> 113 Sets.newHashSet(this.getClass()));
> org.apache.hadoop.fs.s3a.commit.integration (1 usage found)
> ITestS3ACommitterMRJob.java (1 usage found)
> test_200_execute() (1 usage found)
> 232 Set<String> expectedKeys = Sets.newHashSet();
> org.apache.hadoop.fs.s3a.commit.staging (5 usages found)
> TestStagingCommitter.java (3 usages found)
> testSingleTaskMultiFileCommit() (1 usage found)
> 341 Set<String> keys = Sets.newHashSet();
> runTasks(JobContext, int, int) (1 usage found)
> 603 Set<String> uploads = Sets.newHashSet();
> commitTask(StagingCommitter, TaskAttemptContext, int) (1 usage
> found)
> 640 Set<String> files = Sets.newHashSet();
> TestStagingPartitionedTaskCommit.java (2 usages found)
> verifyFilesCreated(PartitionedStagingCommitter) (1 usage found)
> 148 Set<String> files = Sets.newHashSet();
> buildExpectedList(StagingCommitter) (1 usage found)
> 188 Set<String> expected = Sets.newHashSet();
> org.apache.hadoop.hdfs (5 usages found)
> DFSUtil.java (2 usages found)
> getNNServiceRpcAddressesForCluster(Configuration) (1 usage found)
> 615 Set<String> availableNameServices = Sets.newHashSet(conf
> getNNLifelineRpcAddressesForCluster(Configuration) (1 usage
> found)
> 660 Set<String> availableNameServices = Sets.newHashSet(conf
> MiniDFSCluster.java (1 usage found)
> 597 private Set<FileSystem> fileSystems = Sets.newHashSet();
> TestDFSUtil.java (2 usages found)
> testGetNNServiceRpcAddressesForNsIds() (2 usages found)
> 1046 assertEquals(Sets.newHashSet("nn1"), internal);
> 1049 assertEquals(Sets.newHashSet("nn1", "nn2"), all);
> org.apache.hadoop.hdfs.net (5 usages found)
> TestDFSNetworkTopology.java (5 usages found)
> testChooseRandomWithStorageType() (4 usages found)
> 277 Sets.newHashSet("host2", "host4", "host5", "host6");
> 278 Set<String> archiveUnderL1 = Sets.newHashSet("host1",
> "host3");
> 279 Set<String> ramdiskUnderL1 = Sets.newHashSet("host7");
> 280 Set<String> ssdUnderL1 = Sets.newHashSet("host8");
> testChooseRandomWithStorageTypeWithExcluded() (1 usage found)
> 363 Set<String> expectedSet = Sets.newHashSet("host4",
> "host5");
> org.apache.hadoop.hdfs.qjournal.server (2 usages found)
> JournalNodeSyncer.java (2 usages found)
> getOtherJournalNodeAddrs() (1 usage found)
> 276 HashSet<String> sharedEditsUri = Sets.newHashSet();
> getJournalAddrList(String) (1 usage found)
> 318 Sets.newHashSet(jn.getBoundIpcAddress()));
> org.apache.hadoop.hdfs.server.datanode (5 usages found)
> BlockPoolManager.java (1 usage found)
> doRefreshNamenodes(Map<String, Map<String, InetSocketAddress>>,
> Map<String, Map<String, InetSocketAddress>>) (1 usage found)
> 198 toRemove = Sets.newHashSet(Sets.difference(
> BPOfferService.java (2 usages found)
> refreshNNList(String, List<String>, ArrayList<InetSocketAddress>,
> ArrayList<InetSocketAddress>) (2 usages found)
> 146 Set<InetSocketAddress> oldAddrs = Sets.newHashSet();
> 150 Set<InetSocketAddress> newAddrs = Sets.newHashSet(addrs);
> TestRefreshNamenodes.java (2 usages found)
> testRefreshNamenodes() (2 usages found)
> 74 Set<InetSocketAddress> nnAddrsFromCluster =
> Sets.newHashSet();
> 80 Set<InetSocketAddress> nnAddrsFromDN = Sets.newHashSet();
> org.apache.hadoop.hdfs.server.datanode.fsdataset.impl (1 usage found)
> FsDatasetImpl.java (1 usage found)
> getInitialVolumeFailureInfos(Collection<StorageLocation>,
> DataStorage) (1 usage found)
> 430 Set<StorageLocation> failedLocationSet =
> Sets.newHashSetWithExpectedSize(
> org.apache.hadoop.hdfs.server.namenode (11 usages found)
> FSImageTestUtil.java (2 usages found)
> assertFileContentsSame(File...) (1 usage found)
> 418 if (Sets.newHashSet(md5s.values()).size() > 1) {
> assertFileContentsDifferent(int, File...) (1 usage found)
> 435 if (Sets.newHashSet(md5s.values()).size() !=
> expectedUniqueHashes) {
> TestFsck.java (6 usages found)
> testFsckMove() (5 usages found)
> 388 new CorruptedTestFile(fileNames[0], Sets.newHashSet(0),
> 390 new CorruptedTestFile(fileNames[1], Sets.newHashSet(2, 3),
> 392 new CorruptedTestFile(fileNames[2], Sets.newHashSet(4),
> 394 new CorruptedTestFile(fileNames[3], Sets.newHashSet(0, 1,
> 2, 3),
> 396 new CorruptedTestFile(fileNames[4], Sets.newHashSet(1, 2,
> 3, 4),
> testFsckMoveAfterCorruption() (1 usage found)
> 2217 Sets.newHashSet(0), dfsClient, numDatanodes,
> dfsBlockSize);
> TestNameNodeRecovery.java (3 usages found)
> getValidTxIds() (1 usage found)
> 303 return Sets.newHashSet(0L);
> getValidTxIds() (1 usage found)
> 345 return Sets.newHashSet(0L);
> getValidTxIds() (1 usage found)
> 391 return Sets.newHashSet(1L , 2L, 3L, 5L, 6L, 7L, 8L, 9L,
> 10L);
> org.apache.hadoop.mapred (1 usage found)
> TestMRTimelineEventHandling.java (1 usage found)
> checkNewTimelineEvent(ApplicationId, ApplicationReport, String)
> (1 usage found)
> 302 Set<String> cfgsToCheck = Sets.newHashSet("dummy_conf1",
> "dummy_conf2",
> org.apache.hadoop.mapreduce.lib.input (2 usages found)
> TestFileInputFormat.java (2 usages found)
> verifyFileStatuses(List<Path>, List<FileStatus>, FileSystem) (1
> usage found)
> 408 Set<Path> expectedPathSet =
> Sets.newHashSet(fqExpectedPaths);
> verifySplits(List<String>, List<InputSplit>) (1 usage found)
> 426 Set<String> expectedSet = Sets.newHashSet(expected);
> org.apache.hadoop.mapreduce.v2.app.webapp (1 usage found)
> TestAMWebServices.java (1 usage found)
> configureServlets() (1 usage found)
> 78 appContext.setBlacklistedNodes(Sets.newHashSet("badnode1",
> "badnode2"));
> org.apache.hadoop.mapreduce.v2.hs.webapp (4 usages found)
> TestHsWebServicesLogs.java (4 usages found)
> testGetAggregatedLogsMetaForFinishedApp() (1 usage found)
> 302 Set<String> expectedIdStrings = Sets.newHashSet(
> testGetAggregatedLogsMetaForRunningApp() (1 usage found)
> 335 Set<String> expectedIdStrings = Sets.newHashSet(
> testGetAggregatedLogsMetaForFinishedAppAttempt() (1 usage found)
> 368 Set<String> expectedIdStrings = Sets.newHashSet(
> testGetAggregatedLogsMetaForRunningAppAttempt() (1 usage found)
> 401 Set<String> expectedIdStrings = Sets.newHashSet(
> org.apache.hadoop.metrics2.lib (2 usages found)
> MutableRates.java (1 usage found)
> 47 private final Set<Class<?>> protocolCache = Sets.newHashSet();
> MutableRatesWithAggregation.java (1 usage found)
> 55 private final Set<Class<?>> protocolCache = Sets.newHashSet();
> org.apache.hadoop.tools (2 usages found)
> CopyListing.java (2 usages found)
> validateFinalListing(Path, DistCpContext) (2 usages found)
> 166 Set<URI> aclSupportCheckFsSet = Sets.newHashSet();
> 167 Set<URI> xAttrSupportCheckFsSet = Sets.newHashSet();
> org.apache.hadoop.tools.dynamometer (3 usages found)
> TestDynamometerInfra.java (3 usages found)
> setupClass() (3 usages found)
> 272 Sets.newHashSet(NAMENODE_NODELABEL, DATANODE_NODELABEL));
> 275 Sets.newHashSet(NAMENODE_NODELABEL));
> 277 Sets.newHashSet(DATANODE_NODELABEL));
> org.apache.hadoop.yarn.api (1 usage found)
> BasePBImplRecordsTest.java (1 usage found)
> genTypeValue(Type) (1 usage found)
> 115 ret = Sets.newHashSet(genTypeValue(params[0]));
> org.apache.hadoop.yarn.api.protocolrecords.impl.pb (1 usage found)
> GetNodesToLabelsResponsePBImpl.java (1 usage found)
> initNodeToLabels() (1 usage found)
> 70 Sets.newHashSet(c.getNodeLabelsList()));
> org.apache.hadoop.yarn.api.resource (3 usages found)
> TestPlacementConstraintParser.java (3 usages found)
> testTargetExpressionParser() (1 usage found)
> 116 Set<TargetExpression> expectedTargetExpressions =
> Sets.newHashSet(
> testCardinalityConstraintParser() (1 usage found)
> 169 Set<TargetExpression> expectedTargetExpressions =
> Sets.newHashSet(
> testParseAllocationTagNameSpace() (1 usage found)
> 583 Set<TargetExpression> expectedTargetExpressions =
> Sets.newHashSet(
> org.apache.hadoop.yarn.client.cli (10 usages found)
> TestYarnCLI.java (10 usages found)
> testGetApplications() (10 usages found)
> 410 Sets.newHashSet("tag1", "tag3"), false,
> Priority.UNDEFINED, "", "");
> 421 null, Sets.newHashSet("tag2", "tag3"), false,
> Priority.UNDEFINED,
> 431 null, Sets.newHashSet("tag1", "tag4"), false,
> Priority.UNDEFINED,
> 441 "NON-MAPREDUCE", null, Sets.newHashSet("tag1"), false,
> 451 Sets.newHashSet("tag2", "tag4"), false,
> Priority.UNDEFINED, "", "");
> 756 Set<String> appTag1 = Sets.newHashSet("tag1");
> 829 Set<String> appType9 = Sets.newHashSet("YARN");
> 830 Set<String> appTag2 = Sets.newHashSet("tag3");
> 858 Set<String> appType10 = Sets.newHashSet("HIVE");
> 859 Set<String> appTag3 = Sets.newHashSet("tag4");
> org.apache.hadoop.yarn.logaggregation (1 usage found)
> AggregatedLogFormat.java (1 usage found)
> getFileCandidates(Set<File>, boolean) (1 usage found)
> 366 return Sets.newHashSet(mask);
> org.apache.hadoop.yarn.logaggregation.filecontroller (1 usage found)
> LogAggregationFileController.java (1 usage found)
> cleanOldLogs(Path, NodeId, UserGroupInformation) (1 usage found)
> 545 status = Sets.newHashSet(mask);
> org.apache.hadoop.yarn.logaggregation.filecontroller.ifile (1 usage
> found)
> LogAggregationIndexedFileController.java (1 usage found)
> parseCheckSumFiles(List<FileStatus>) (1 usage found)
> 718 status = Sets.newHashSet(mask);
> org.apache.hadoop.yarn.nodelabels (7 usages found)
> NodeLabelTestBase.java (1 usage found)
> toSet(E...) (1 usage found)
> 123 Set<E> set = Sets.newHashSet(elements);
> TestCommonNodeLabelsManager.java (6 usages found)
> testAddRemovelabel() (5 usages found)
> 65 verifyNodeLabelAdded(Sets.newHashSet("hello"),
> mgr.lastAddedlabels);
> 69 verifyNodeLabelAdded(Sets.newHashSet("hello1", "world1"),
> mgr.lastAddedlabels);
> 72 Sets.newHashSet("hello", "world", "hello1", "world1")));
> 103 assertCollectionEquals(Sets.newHashSet("hello"),
> mgr.lastRemovedlabels);
> 109
> Assert.assertTrue(mgr.lastRemovedlabels.containsAll(Sets.newHashSet(
> testAddlabelWithCase() (1 usage found)
> 118 verifyNodeLabelAdded(Sets.newHashSet("HeLlO"),
> mgr.lastAddedlabels);
> org.apache.hadoop.yarn.nodelabels.store.op (1 usage found)
> RemoveClusterLabelOp.java (1 usage found)
> write(OutputStream, CommonNodeLabelsManager) (1 usage found)
> 48
> .newInstance(Sets.newHashSet(labels.iterator()))).getProto()
> org.apache.hadoop.yarn.server.api.protocolrecords (1 usage found)
> TestProtocolRecords.java (1 usage found)
> testNodeHeartBeatRequest() (1 usage found)
> 185 Sets.newHashSet(NodeAttribute.newInstance("attributeA",
> org.apache.hadoop.yarn.server.api.protocolrecords.impl.pb (1 usage found)
> ReplaceLabelsOnNodeRequestPBImpl.java (1 usage found)
> initNodeToLabels() (1 usage found)
> 66 Sets.newHashSet(c.getNodeLabelsList()));
> org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer (2
> usages found)
> TestResourceLocalizationService.java (2 usages found)
> doLocalization(ResourceLocalizationService, DrainDispatcher,
> DummyExecutor, DeletionService) (1 usage found)
> 1400 Sets.newHashSet(new Path(locPath1), new Path(locPath1 +
> "_tmp"),
> doLocalizationAfterCleanup(ResourceLocalizationService,
> DrainDispatcher, DummyExecutor, DeletionService) (1 usage found)
> 1547 Sets.newHashSet(new Path(locPath1), new Path(locPath1 +
> "_tmp"),
> org.apache.hadoop.yarn.server.nodemanager.containermanager.logaggregation
> (1 usage found)
> AppLogAggregatorImpl.java (1 usage found)
> doContainerLogAggregation(LogAggregationFileController, boolean,
> boolean) (1 usage found)
> 674 this.uploadedFileMeta = Sets.newHashSet(mask);
>
> org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.com.nec
> (1 usage found)
> TestNECVEPlugin.java (1 usage found)
> testFindDevicesWithUdev() (1 usage found)
> 388 .thenReturn(Sets.newHashSet(testDevice));
>
> org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.fpga
> (1 usage found)
> FpgaDiscoverer.java (1 usage found)
> discover() (1 usage found)
> 123 Set<String> minors = Sets.newHashSet(allowed.split(","));
>
> org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.gpu
> (1 usage found)
> GpuDiscoverer.java (1 usage found)
> lookupBinaryInDefaultDirsInternal() (1 usage found)
> 328 Set<String> triedBinaryPaths = Sets.newHashSet();
> org.apache.hadoop.yarn.server.resourcemanager (5 usages found)
> TestAppManager.java (1 usage found)
> testEscapeApplicationSummary() (1 usage found)
> 977
> when(app.getApplicationTags()).thenReturn(Sets.newHashSet("tag2", "tag1"));
> TestClientRMService.java (3 usages found)
> testGetApplications() (3 usages found)
> 1442 tagSet = Sets.newHashSet(tags.get(0));
> 1447 tagSet = Sets.newHashSet(tags.get(1));
> 1452 tagSet = Sets.newHashSet(tags.get(2));
> TestRMRestart.java (1 usage found)
> toSet(E...) (1 usage found)
> 2587 Set<E> set = Sets.newHashSet(elements);
> org.apache.hadoop.yarn.server.resourcemanager.nodelabels (11 usages
> found)
> TestNodeAttributesManager.java (11 usages found)
> testAddNodeAttributes() (2 usages found)
> 132 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[0]));
> 138
> .getClusterNodeAttributes(Sets.newHashSet("non_exist_prefix"));
> testRemoveNodeAttributes() (4 usages found)
> 219 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[0]));
> 222 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[1]));
> 225 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[2]));
> 263 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[0]));
> testReplaceNodeAttributes() (5 usages found)
> 299 Sets.newHashSet(NodeAttribute.PREFIX_DISTRIBUTED,
> PREFIXES[0]));
> 313 Sets.newHashSet(NodeAttribute.PREFIX_DISTRIBUTED,
> PREFIXES[0]));
> 340 Sets.newHashSet(NodeAttribute.PREFIX_DISTRIBUTED));
> 357 .getClusterNodeAttributes(Sets.newHashSet(PREFIXES[1]));
> 360 .getClusterNodeAttributes(Sets.newHashSet(
> org.apache.hadoop.yarn.server.resourcemanager.scheduler (5 usages found)
> TestAbstractYarnScheduler.java (3 usages found)
> testContainerReleaseWithAllocationTags() (2 usages found)
> 469 Sets.newHashSet(testTag1),
> 477 Sets.newHashSet(testTag2),
> testNodeRemovedWithAllocationTags() (1 usage found)
> 578 Sets.newHashSet(testTag1),
> TestSchedulerUtils.java (2 usages found)
> testValidateResourceRequestWithErrorLabelsPermission() (1 usage
> found)
> 246 Set<String> queueAccessibleNodeLabels = Sets.newHashSet();
> testNormalizeNodeLabelExpression() (1 usage found)
> 795 Set<String> queueAccessibleNodeLabels = Sets.newHashSet();
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.capacity (8
> usages found)
> CapacitySchedulerTestBase.java (1 usage found)
> toSet(E...) (1 usage found)
> 56 Set<E> set = Sets.newHashSet(elements);
> TestApplicationLimits.java (1 usage found)
> toSet(String...) (1 usage found)
> 790 Set<String> set = Sets.newHashSet(elements);
> TestCapacityScheduler.java (1 usage found)
> testParseQueueWithAbsoluteResource() (1 usage found)
> 1042 Sets.newHashSet(labelName));
> TestCapacitySchedulerMaxParallelApps.java (1 usage found)
> executeCommonStepsAndChecks() (1 usage found)
> 200 Sets.newHashSet(
> TestCapacitySchedulerNodeLabelUpdate.java (1 usage found)
> toSet(String...) (1 usage found)
> 144 Set<String> set = Sets.newHashSet(elements);
> TestNodeLabelContainerAllocation.java (1 usage found)
> toSet(E...) (1 usage found)
> 157 Set<E> set = Sets.newHashSet(elements);
> TestUtils.java (1 usage found)
> toSet(E...) (1 usage found)
> 262 Set<E> set = Sets.newHashSet(elements);
> TestWorkPreservingRMRestartForNodeLabel.java (1 usage found)
> toSet(E...) (1 usage found)
> 77 Set<E> set = Sets.newHashSet(elements);
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.constraint (3
> usages found)
> TestPlacementConstraintManagerService.java (3 usages found)
> testGetRequestConstraint() (3 usages found)
> 209 Sets.newHashSet("not_exist_tag"), null);
> 228 Sets.newHashSet(sourceTag1), null);
> 256 Sets.newHashSet(sourceTag1), c1);
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair (2 usages
> found)
> TestFairScheduler.java (1 usage found)
> testGetAppsInQueue() (1 usage found)
> 4455 Set<ApplicationAttemptId> appAttIds =
> Sets.newHashSet(apps.get(0), apps.get(1));
> TestQueueManager.java (1 usage found)
> updateConfiguredLeafQueues(QueueManager, String...) (1 usage
> found)
> 185 .addAll(Sets.newHashSet(confLeafQueues));
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.allocation
> (1 usage found)
> AllocationFileParser.java (1 usage found)
> 81 Sets.newHashSet(QUEUE_MAX_RESOURCES_DEFAULT,
> USER_MAX_APPS_DEFAULT,
> org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.converter
> (8 usages found)
> TestFSQueueConverter.java (8 usages found)
> testConvertQueueHierarchy() (1 usage found)
> 168 Sets.newHashSet("root",
> testQueueMaxAMShare() (1 usage found)
> 192 Sets.newHashSet("root.admins.bob", "root.admins.alice"));
> testQueueMaxParallelApps() (1 usage found)
> 208 Sets.newHashSet("root.admins.alice"));
> testQueueMaxAllocations() (1 usage found)
> 232 Sets.newHashSet("root.admins", "root.users.john"));
> testQueuePreemptionDisabled() (1 usage found)
> 251 Sets.newHashSet("root.admins.alice", "root.users.joe"));
> testQueueAutoCreateChildQueue() (2 usages found)
> 319 Set<String> parentQueues = Sets.newHashSet(
> 323 Set<String> leafQueues = Sets.newHashSet(
> 64 Sets.newHashSet("root",
> org.apache.hadoop.yarn.server.resourcemanager.webapp (25 usages found)
> ApplicationsRequestBuilder.java (5 usages found)
> 34 private Set<String> statesQuery = Sets.newHashSet();
> 35 private Set<String> users = Sets.newHashSetWithExpectedSize(1);
> 36 private Set<String> queues =
> Sets.newHashSetWithExpectedSize(1);
> 45 private Set<String> appTypes = Sets.newHashSet();
> 46 private Set<String> appTags = Sets.newHashSet();
> RMWebAppFilter.java (1 usage found)
> 71 private static final Set<String> NON_REDIRECTED_URIS =
> Sets.newHashSet(
> TestApplicationsRequestBuilder.java (16 usages found)
> testRequestWithValidStateQuery() (1 usage found)
> 86
> Sets.newHashSet(YarnApplicationState.NEW_SAVING.toString());
> testRequestWithEmptyStateQueries() (1 usage found)
> 96 .withStatesQuery(Sets.newHashSet()).build();
> testRequestWithInvalidStateQueries() (1 usage found)
> 106 .withStatesQuery(Sets.newHashSet("a1", "a2", "")).build();
> testRequestWithValidStateQueries() (2 usages found)
> 127
> Sets.newHashSet(YarnApplicationState.NEW_SAVING.toString(),
> 133
> Sets.newHashSet(YarnApplicationState.NEW_SAVING.toString(),
> testRequestWithUserQuery() (1 usage found)
> 165 expectedRequest.setUsers(Sets.newHashSet("user1"));
> testRequestWithQueueQueryExistingQueue() (1 usage found)
> 196 expectedRequest.setQueues(Sets.newHashSet("queue1"));
> testRequestWithQueueQueryNotExistingQueue() (1 usage found)
> 212 expectedRequest.setQueues(Sets.newHashSet("queue1"));
> testRequestWithEmptyApplicationTypesQuery() (2 usages found)
> 487 .withApplicationTypes(Sets.newHashSet()).build();
> 490 expectedRequest.setApplicationTypes(Sets.newHashSet());
> testRequestWithValidApplicationTypesQuery() (2 usages found)
> 497 .withApplicationTypes(Sets.newHashSet("type1")).build();
> 500
> expectedRequest.setApplicationTypes(Sets.newHashSet("type1"));
> testRequestWithEmptyApplicationTagsQuery() (2 usages found)
> 513 .withApplicationTags(Sets.newHashSet()).build();
> 516 expectedRequest.setApplicationTags(Sets.newHashSet());
> testRequestWithValidApplicationTagsQuery() (2 usages found)
> 523 .withApplicationTags(Sets.newHashSet("tag1")).build();
> 526
> expectedRequest.setApplicationTags(Sets.newHashSet("tag1"));
> TestRMWebServiceAppsNodelabel.java (1 usage found)
> toSet(E...) (1 usage found)
> 242 Set<E> set = Sets.newHashSet(elements);
> TestRMWebServicesApps.java (1 usage found)
> getApplicationIds(JSONArray) (1 usage found)
> 107 Set<String> ids = Sets.newHashSet();
> TestRMWebServicesForCSWithPartitions.java (1 usage found)
> testPartitionInSchedulerActivities() (1 usage found)
> 273 .of(NodeId.newInstance("127.0.0.1", 0),
> Sets.newHashSet(LABEL_LX)));
> org.apache.hadoop.yarn.server.resourcemanager.webapp.fairscheduler (4
> usages found)
> FairSchedulerJsonVerifications.java (2 usages found)
> FairSchedulerJsonVerifications(List<String>) (1 usage found)
> 49 this.customResourceTypes =
> Sets.newHashSet(customResourceTypes);
> 42 Sets.newHashSet("minResources", "amUsedResources",
> "amMaxResources",
> FairSchedulerXmlVerifications.java (2 usages found)
> FairSchedulerXmlVerifications(List<String>) (1 usage found)
> 53 this.customResourceTypes =
> Sets.newHashSet(customResourceTypes);
> 46 private static final Set<String> RESOURCE_FIELDS =
> Sets.newHashSet(
> org.apache.hadoop.yarn.server.resourcemanager.webapp.helper (1 usage
> found)
> ResourceRequestsXmlVerifications.java (1 usage found)
> extractActualCustomResourceType(Element, List<String>) (1 usage
> found)
> 85 Sets.newHashSet(expectedResourceTypes));
> org.apache.hadoop.yarn.server.timeline (3 usages found)
> EntityGroupPlugInForTest.java (3 usages found)
> getTimelineEntityGroupId(String, NameValuePair,
> Collection<NameValuePair>) (1 usage found)
> 39 return Sets.newHashSet(getStandardTimelineGroupId(appId));
> getTimelineEntityGroupId(String, String) (1 usage found)
> 47 return Sets.newHashSet(getStandardTimelineGroupId(appId));
> getTimelineEntityGroupId(String, SortedSet<String>, Set<String>)
> (1 usage found)
> 54 return Sets.newHashSet();
> org.apache.hadoop.yarn.server.timelineservice.collector (1 usage found)
> TestTimelineCollector.java (1 usage found)
> testClearPreviousEntitiesOnAggregation() (1 usage found)
> 306 assertEquals(Sets.newHashSet("type"),
> aggregationGroups.keySet());
>
> org.apache.hadoop.yarn.server.timelineservice.documentstore.reader.cosmosdb
> (1 usage found)
> CosmosDBDocumentStoreReader.java (1 usage found)
> fetchEntityTypes(String, TimelineReaderContext) (1 usage found)
> 118 return Sets.newHashSet(client.queryDocuments(
> org.apache.hadoop.yarn.server.timelineservice.reader (38 usages found)
> TestTimelineReaderWebServicesHBaseStorage.java (16 usages found)
> loadData() (16 usages found)
> 266 Sets.newHashSet("entity21", "entity22", "entity23",
> "entity24"));
> 267 isRelatedTo1.put("type4", Sets.newHashSet("entity41",
> "entity42"));
> 268 isRelatedTo1.put("type1", Sets.newHashSet("entity14",
> "entity15"));
> 270 Sets.newHashSet("entity31", "entity35", "entity32",
> "entity33"));
> 274 Sets.newHashSet("entity21", "entity22", "entity23",
> "entity24"));
> 275 relatesTo1.put("type4", Sets.newHashSet("entity41",
> "entity42"));
> 276 relatesTo1.put("type1", Sets.newHashSet("entity14",
> "entity15"));
> 278 Sets.newHashSet("entity31", "entity35", "entity32",
> "entity33"));
> 327 Sets.newHashSet("entity21", "entity22", "entity23",
> "entity24"));
> 328 isRelatedTo2.put("type5", Sets.newHashSet("entity51",
> "entity52"));
> 329 isRelatedTo2.put("type6", Sets.newHashSet("entity61",
> "entity66"));
> 330 isRelatedTo2.put("type3", Sets.newHashSet("entity31"));
> 334 Sets.newHashSet("entity21", "entity22", "entity23",
> "entity24"));
> 335 relatesTo2.put("type5", Sets.newHashSet("entity51",
> "entity52"));
> 336 relatesTo2.put("type6", Sets.newHashSet("entity61",
> "entity66"));
> 337 relatesTo2.put("type3", Sets.newHashSet("entity31"));
> TestTimelineReaderWebServicesUtils.java (22 usages found)
> testRelationFiltersParsing() (22 usages found)
> 721 "type1", Sets.newHashSet((Object)"entity11")),
> 723 "type2", Sets.newHashSet((Object)"entity21", "entity22"))
> 737 "type1", Sets.newHashSet((Object)"entity11")),
> 739 "type2", Sets.newHashSet((Object)"entity21", "entity22"))
> 743 "type3", Sets.newHashSet(
> 746 "type1", Sets.newHashSet((Object)"entity11", "entity12"))
> 758 "type1", Sets.newHashSet((Object)"entity11")),
> 760 "type2", Sets.newHashSet((Object)"entity21", "entity22")),
> 762 "type5", Sets.newHashSet((Object)"entity51"))
> 766 "type3", Sets.newHashSet(
> 769 "type1", Sets.newHashSet((Object)"entity11", "entity12"))
> 784 "type1", Sets.newHashSet((Object)"entity11")),
> 786 "type2", Sets.newHashSet(
> 789 "type5", Sets.newHashSet((Object)"entity51"))
> 793 "type3", Sets.newHashSet(
> 796 "type1", Sets.newHashSet(
> 803 "type11", Sets.newHashSet((Object)"entity111"))
> 807 "type4", Sets.newHashSet((Object)"entity43", "entity44",
> 810 "type7", Sets.newHashSet((Object)"entity71"))
> 817 "type2", Sets.newHashSet((Object)"entity2")),
> 819 "type8", Sets.newHashSet((Object)"entity88"))
> 822 Sets.newHashSet((Object)"e", "e1"))
> org.apache.hadoop.yarn.service (1 usage found)
> TestApiServer.java (1 usage found)
> testUpgradeSingleInstance() (1 usage found)
> 533 mockServerClient.setExpectedInstances(Sets.newHashSet(
> org.apache.hadoop.yarn.service.utils (2 usages found)
> ServiceApiUtil.java (2 usages found)
> validateAndResolveCompsUpgrade(Service, Collection<String>) (1
> usage found)
> 625 HashSet<String> requestedComps =
> Sets.newHashSet(compNames);
> validateAndResolveCompsStable(Service, Collection<String>) (1
> usage found)
> 651 HashSet<String> requestedComps =
> Sets.newHashSet(compNames);
> org.apache.hadoop.yarn.service.webapp (1 usage found)
> ApiServer.java (1 usage found)
> updateComponent(HttpServletRequest, String, String, Component)
> (1 usage found)
> 374 Sets.newHashSet(componentName));
> org.apache.hadoop.yarn.webapp.hamlet (2 usages found)
> HamletGen.java (2 usages found)
> 67 final Set<String> endTagOptional = Sets.newHashSet();
> 68 final Set<String> inlineElements = Sets.newHashSet();
> org.apache.hadoop.yarn.webapp.hamlet2 (2 usages found)
> HamletGen.java (2 usages found)
> 65 final Set<String> endTagOptional = Sets.newHashSet();
> 66 final Set<String> inlineElements = Sets.newHashSet();
> patches (4 usages found)
> HADOOP-17101.001.patch (2 usages found)
> 226 Set<Path> expectedPathSet =
> Sets.newHashSet(fqExpectedPaths);
> 244 Set<String> expectedSet = Sets.newHashSet(expected);
> HADOOP-17101.002.patch (2 usages found)
> 456 Set<Path> expectedPathSet =
> Sets.newHashSet(fqExpectedPaths);
> 474 Set<String> expectedSet = Sets.newHashSet(expected);
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
