You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-issues@hadoop.apache.org by "Ahmed Hussein (Jira)" <ji...@apache.org> on 2020/07/07 14:54:00 UTC
[jira] [Created] (HADOOP-17114) Replace Guava initialization of
Lists.newArrayList
Ahmed Hussein created HADOOP-17114:
--------------------------------------
Summary: Replace Guava initialization of Lists.newArrayList
Key: HADOOP-17114
URL: https://issues.apache.org/jira/browse/HADOOP-17114
Project: Hadoop Common
Issue Type: Sub-task
Reporter: Ahmed Hussein
There are unjustified use of Guava APIs to initialize Lists. This could be simply replaced by Java API.
{code:java}
Targets
Occurrences of 'Lists.newArrayList' in project
Found Occurrences (787 usages found)
org.apache.hadoop.conf (2 usages found)
TestReconfiguration.java (2 usages found)
testAsyncReconfigure() (1 usage found)
391 List<PropertyChange> changes = Lists.newArrayList();
testStartReconfigurationFailureDueToExistingRunningTask() (1 usage found)
435 List<PropertyChange> changes = Lists.newArrayList(
org.apache.hadoop.crypto (1 usage found)
CryptoCodec.java (1 usage found)
getCodecClasses(Configuration, CipherSuite) (1 usage found)
107 List<Class<? extends CryptoCodec>> result = Lists.newArrayList();
org.apache.hadoop.fs.azurebfs (84 usages found)
ITestAbfsIdentityTransformer.java (7 usages found)
transformAclEntriesForSetRequest() (3 usages found)
240 List<AclEntry> aclEntriesToBeTransformed = Lists.newArrayList(
253 List<AclEntry> aclEntries = Lists.newArrayList(aclEntriesToBeTransformed);
271 List<AclEntry> expectedAclEntries = Lists.newArrayList(
transformAclEntriesForGetRequest() (4 usages found)
291 List<AclEntry> aclEntriesToBeTransformed = Lists.newArrayList(
302 List<AclEntry> aclEntries = Lists.newArrayList(aclEntriesToBeTransformed);
318 aclEntries = Lists.newArrayList(aclEntriesToBeTransformed);
322 List<AclEntry> expectedAclEntries = Lists.newArrayList(
ITestAzureBlobFilesystemAcl.java (76 usages found)
testModifyAclEntries() (2 usages found)
95 List<AclEntry> aclSpec = Lists.newArrayList(
103 aclSpec = Lists.newArrayList(
testModifyAclEntriesOnlyAccess() (2 usages found)
128 List<AclEntry> aclSpec = Lists.newArrayList(
134 aclSpec = Lists.newArrayList(
testModifyAclEntriesOnlyDefault() (2 usages found)
151 List<AclEntry> aclSpec = Lists.newArrayList(
154 aclSpec = Lists.newArrayList(
testModifyAclEntriesMinimal() (1 usage found)
175 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesMinimalDefault() (1 usage found)
192 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesCustomMask() (1 usage found)
213 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesStickyBit() (2 usages found)
231 List<AclEntry> aclSpec = Lists.newArrayList(
238 aclSpec = Lists.newArrayList(
testModifyAclEntriesPathNotFound() (1 usage found)
261 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesDefaultOnFile() (1 usage found)
276 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesWithDefaultMask() (2 usages found)
287 List<AclEntry> aclSpec = Lists.newArrayList(
291 List<AclEntry> modifyAclSpec = Lists.newArrayList(
testModifyAclEntriesWithAccessMask() (2 usages found)
311 List<AclEntry> aclSpec = Lists.newArrayList(
315 List<AclEntry> modifyAclSpec = Lists.newArrayList(
testModifyAclEntriesWithDuplicateEntries() (2 usages found)
332 List<AclEntry> aclSpec = Lists.newArrayList(
336 List<AclEntry> modifyAclSpec = Lists.newArrayList(
testRemoveAclEntries() (2 usages found)
348 List<AclEntry> aclSpec = Lists.newArrayList(
355 aclSpec = Lists.newArrayList(
testRemoveAclEntriesOnlyAccess() (2 usages found)
377 List<AclEntry> aclSpec = Lists.newArrayList(
384 aclSpec = Lists.newArrayList(
testRemoveAclEntriesOnlyDefault() (2 usages found)
401 List<AclEntry> aclSpec = Lists.newArrayList(
408 aclSpec = Lists.newArrayList(
testRemoveAclEntriesMinimal() (2 usages found)
429 List<AclEntry> aclSpec = Lists.newArrayList(
435 aclSpec = Lists.newArrayList(
testRemoveAclEntriesMinimalDefault() (2 usages found)
451 List<AclEntry> aclSpec = Lists.newArrayList(
458 aclSpec = Lists.newArrayList(
testRemoveAclEntriesStickyBit() (2 usages found)
479 List<AclEntry> aclSpec = Lists.newArrayList(
486 aclSpec = Lists.newArrayList(
testRemoveAclEntriesPathNotFound() (1 usage found)
507 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAclEntriesAccessMask() (2 usages found)
518 List<AclEntry> aclSpec = Lists.newArrayList(
523 fs.removeAclEntries(path, Lists.newArrayList(aclEntry(ACCESS, MASK, NONE)));
testRemoveAclEntriesDefaultMask() (2 usages found)
532 List<AclEntry> aclSpec = Lists.newArrayList(
537 fs.removeAclEntries(path, Lists.newArrayList(aclEntry(DEFAULT, MASK, NONE)));
testRemoveAclEntriesWithDuplicateEntries() (2 usages found)
546 List<AclEntry> aclSpec = Lists.newArrayList(
550 List<AclEntry> removeAclSpec = Lists.newArrayList(
testRemoveDefaultAcl() (1 usage found)
562 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveDefaultAclOnlyAccess() (1 usage found)
585 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveDefaultAclOnlyDefault() (1 usage found)
606 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveDefaultAclStickyBit() (1 usage found)
635 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAcl() (1 usage found)
666 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAclStickyBit() (1 usage found)
702 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAclOnlyDefault() (1 usage found)
722 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAcl() (1 usage found)
750 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclOnlyAccess() (1 usage found)
777 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclOnlyDefault() (1 usage found)
797 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclMinimal() (2 usages found)
818 List<AclEntry> aclSpec = Lists.newArrayList(
824 aclSpec = Lists.newArrayList(
testSetAclMinimalDefault() (1 usage found)
841 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclCustomMask() (1 usage found)
862 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclStickyBit() (1 usage found)
883 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclPathNotFound() (1 usage found)
909 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclDefaultOnFile() (1 usage found)
924 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclDoesNotChangeDefaultMask() (2 usages found)
935 List<AclEntry> aclSpec = Lists.newArrayList(
939 List<AclEntry> aclSpec2 = Lists.newArrayList(
testSetAclWithDuplicateEntries() (1 usage found)
959 List<AclEntry> aclSpec = Lists.newArrayList(
testSetPermission() (1 usage found)
971 List<AclEntry> aclSpec = Lists.newArrayList(
testSetPermissionOnlyAccess() (1 usage found)
999 List<AclEntry> aclSpec = Lists.newArrayList(
testSetPermissionOnlyDefault() (1 usage found)
1020 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewFile() (1 usage found)
1044 List<AclEntry> aclSpec = Lists.newArrayList(
testOnlyAccessAclNewFile() (1 usage found)
1064 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultMinimalAclNewFile() (1 usage found)
1081 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewDir() (1 usage found)
1100 List<AclEntry> aclSpec = Lists.newArrayList(
testOnlyAccessAclNewDir() (1 usage found)
1126 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultMinimalAclNewDir() (1 usage found)
1143 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewFileWithMode() (1 usage found)
1165 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewDirWithMode() (1 usage found)
1187 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclRenamedFile() (1 usage found)
1212 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclRenamedDir() (1 usage found)
1234 List<AclEntry> aclSpec = Lists.newArrayList(
testEnsureAclOperationWorksForRoot() (2 usages found)
1255 List<AclEntry> aclSpec1 = Lists.newArrayList(
1264 List<AclEntry> aclSpec2 = Lists.newArrayList(
testModifyAclEntriesForNonNamespaceEnabledAccount() (1 usage found)
1316 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAclEntriesEntriesForNonNamespaceEnabledAccount() (1 usage found)
1333 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclForNonNamespaceEnabledAccount() (1 usage found)
1378 List<AclEntry> aclSpec = Lists.newArrayList(
ITestAzureBlobFileSystemCheckAccess.java (1 usage found)
modifyAcl(Path, String, FsAction) (1 usage found)
304 List<AclEntry> aclSpec = Lists.newArrayList(AclTestHelpers
org.apache.hadoop.fs.http.client (2 usages found)
BaseTestHttpFSWith.java (1 usage found)
testGetXAttrs() (1 usage found)
834 List<String> names = Lists.newArrayList();
HttpFSFileSystem.java (1 usage found)
createXAttrNames(String) (1 usage found)
1368 List<String> names = Lists.newArrayListWithCapacity(jsonArray.size());
org.apache.hadoop.fs.permission (4 usages found)
AclStatus.java (2 usages found)
AclStatus(String, String, boolean, Iterable<AclEntry>, FsPermission) (1 usage found)
220 this.entries = Lists.newArrayList(entries);
125 private List<AclEntry> entries = Lists.newArrayList();
AclUtil.java (2 usages found)
getAclFromPermAndEntries(FsPermission, List<AclEntry>) (1 usage found)
44 List<AclEntry> acl = Lists.newArrayListWithCapacity(entries.size() + 3);
getMinimalAcl(FsPermission) (1 usage found)
100 return Lists.newArrayList(
org.apache.hadoop.fs.s3a (3 usages found)
ITestS3AFailureHandling.java (1 usage found)
testMultiObjectDeleteMissingEntriesSucceeds() (1 usage found)
163 Lists.newArrayList(new Path(base, "1"), new Path(base, "2")));
ITestS3GuardListConsistency.java (1 usage found)
testListingReturnsVersionMetadata() (1 usage found)
665 List<LocatedFileStatus> files = Lists.newArrayList();
S3AUtils.java (1 usage found)
patchSecurityCredentialProviders(Configuration) (1 usage found)
1535 List<String> all = Lists.newArrayList(customCredentials);
org.apache.hadoop.fs.s3a.auth (1 usage found)
RolePolicies.java (1 usage found)
allowS3Operations(String, boolean) (1 usage found)
408 Lists.newArrayList(
org.apache.hadoop.fs.s3a.commit (2 usages found)
ITestCommitOperations.java (1 usage found)
testBulkCommitFiles() (1 usage found)
605 List<Path> destinations = Lists.newArrayList(destFile1, destFile2,
TestMagicCommitPaths.java (1 usage found)
list(String...) (1 usage found)
225 return Lists.newArrayList(args);
org.apache.hadoop.fs.s3a.commit.staging (9 usages found)
StagingTestBase.java (6 usages found)
newMockS3Client(ClientResults, ClientErrors) (1 usage found)
652 etags = Lists.newArrayList();
436 private final List<String> uploads = Lists.newArrayList();
437 private final List<UploadPartRequest> parts = Lists.newArrayList();
440 Lists.newArrayList();
442 = Lists.newArrayList();
445 private final List<DeleteObjectRequest> deletes = Lists.newArrayList();
TestStagingPartitionedFileListing.java (2 usages found)
testTaskOutputListing() (1 usage found)
82 List<String> expectedFiles = Lists.newArrayList();
testTaskOutputListingWithHiddenFiles() (1 usage found)
117 List<String> expectedFiles = Lists.newArrayList();
TestStagingPartitionedTaskCommit.java (1 usage found)
60 private static List<String> relativeFiles = Lists.newArrayList();
org.apache.hadoop.fs.s3a.impl (4 usages found)
RenameOperation.java (1 usage found)
renameFileToDest() (1 usage found)
297 renameTracker.sourceObjectsDeleted(Lists.newArrayList(sourcePath));
TestPartialDeleteFailures.java (3 usages found)
testProcessDeleteFailure() (3 usages found)
173 List<Path> src = Lists.newArrayList(pathA, pathAB, pathAC);
175 List<Path> deleteForbidden = Lists.newArrayList(pathAB);
176 final List<Path> deleteAllowed = Lists.newArrayList(pathA, pathAC);
org.apache.hadoop.fs.s3a.s3guard (5 usages found)
DynamoDBMetadataStore.java (1 usage found)
listAWSPolicyRules(Set<AccessLevel>) (1 usage found)
1809 return Lists.newArrayList(stat);
ITestDynamoDBMetadataStore.java (3 usages found)
testMovePopulatesAncestors() (3 usages found)
904 final Collection<Path> fullSourcePaths = Lists.newArrayList(
910 final Collection<PathMetadata> pathsToCreate = Lists.newArrayList(
924 List<String> paths = Lists.newArrayList(
TestPathOrderComparators.java (1 usage found)
28 import static com.google.common.collect.Lists.newArrayList;
org.apache.hadoop.fs.shell (1 usage found)
AclCommands.java (1 usage found)
processOptions(LinkedList<String>) (1 usage found)
242 accessAclEntries = Lists.newArrayList();
org.apache.hadoop.fs.viewfs (8 usages found)
TestViewFileSystemWithAcls.java (4 usages found)
testAclOnMountEntry() (4 usages found)
121 List<AclEntry> aclSpec = Lists.newArrayList(
137 aclSpec = Lists.newArrayList(
168 aclSpec = Lists.newArrayList(
178 fsView.removeAclEntries(mountOnNn2, Lists.newArrayList(
TestViewFsWithAcls.java (4 usages found)
testAclOnMountEntry() (4 usages found)
121 List<AclEntry> aclSpec = Lists.newArrayList(
137 aclSpec = Lists.newArrayList(
168 aclSpec = Lists.newArrayList(
178 fcView.removeAclEntries(mountOnNn2, Lists.newArrayList(
org.apache.hadoop.ha (4 usages found)
DummyHAService.java (1 usage found)
69 static ArrayList<DummyHAService> instances = Lists.newArrayList();
NodeFencer.java (1 usage found)
parseMethods(Configuration, String) (1 usage found)
121 List<FenceMethodWithArg> methods = Lists.newArrayList();
TestNodeFencer.java (2 usages found)
156 static List<String> callArgs = Lists.newArrayList();
182 static List<String> callArgs = Lists.newArrayList();
org.apache.hadoop.hdfs (74 usages found)
AdminStatesBaseTest.java (2 usages found)
takeNodeOutofService(int, String, long, List<DatanodeInfo>, Map<DatanodeInfo, Long>, AdminStates) (1 usage found)
196 Lists.newArrayList(datanodeUuid) : null),
waitNodeState(DatanodeInfo, AdminStates) (1 usage found)
333 waitNodeState(Lists.newArrayList(node), state);
DFSClient.java (1 usage found)
listXAttrs(String) (1 usage found)
2902 return Lists.newArrayList(xattrs.keySet());
DFSTestUtil.java (2 usages found)
setFederatedHAConfiguration(MiniDFSCluster, Configuration) (1 usage found)
1150 nns = Lists.newArrayList();
runOperations(MiniDFSCluster, DistributedFileSystem, Configuration, long, int) (1 usage found)
1522 List<AclEntry> aclEntryList = Lists.newArrayList();
DFSUtil.java (1 usage found)
flattenAddressMap(Map<String, Map<String, InetSocketAddress>>) (1 usage found)
701 List<ConfiguredNNAddress> ret = Lists.newArrayList();
DistributedFileSystem.java (3 usages found)
batchedListStatusIterator(List<Path>) (1 usage found)
1338 List<Path> absPaths = Lists.newArrayListWithCapacity(paths.size());
batchedListLocatedStatusIterator(List<Path>) (1 usage found)
1348 List<Path> absPaths = Lists.newArrayListWithCapacity(paths.size());
next() (1 usage found)
1424 Lists.newArrayListWithCapacity(statuses.size());
HAUtil.java (1 usage found)
getNameNodeIdOfOtherNodes(Configuration, String) (1 usage found)
186 ArrayList<String> namenodes = Lists.newArrayList(nnIds);
MiniDFSCluster.java (3 usages found)
configureNameNodes(MiniDFSNNTopology, boolean, Configuration) (2 usages found)
1134 List<String> allNsIds = Lists.newArrayList();
1155 List<String> nnIds = Lists.newArrayList();
copyNameDirs(Collection<URI>, Collection<URI>, Configuration) (1 usage found)
1271 URI srcDir = Lists.newArrayList(srcDirs).get(0);
MiniDFSNNTopology.java (2 usages found)
36 private final List<NSConf> nameservices = Lists.newArrayList();
217 private final List<NNConf> nns = Lists.newArrayList();
TestBatchedListDirectories.java (18 usages found)
getListings(List<Path>) (1 usage found)
144 List<PartialListing<FileStatus>> returned = Lists.newArrayList();
listingsToStatuses(List<PartialListing<FileStatus>>) (1 usage found)
155 List<FileStatus> returned = Lists.newArrayList();
testEmptyPath() (1 usage found)
171 List<Path> paths = Lists.newArrayList();
testEmptyDir() (1 usage found)
177 List<Path> paths = Lists.newArrayList(EMPTY_DIR_PATH);
listOneFile() (1 usage found)
186 List<Path> paths = Lists.newArrayList();
listDoesNotExist() (1 usage found)
196 List<Path> paths = Lists.newArrayList();
listSomeDoNotExist() (1 usage found)
203 List<Path> paths = Lists.newArrayList();
listDirRelative() (1 usage found)
234 List<Path> paths = Lists.newArrayList(new Path("."));
listFilesRelative() (1 usage found)
247 List<Path> paths = Lists.newArrayList(new Path("subdir0"));
listDirectoriesInternal(int) (1 usage found)
298 listing.put(parent, Lists.newArrayList());
listTooManyDirectories() (1 usage found)
334 List<Path> paths = Lists.newArrayList(FILE_PATHS);
listDirsAndEmpty() (1 usage found)
341 List<Path> paths = Lists.newArrayList();
listSamePaths() (1 usage found)
356 List<Path> paths = Lists.newArrayList();
listLocatedStatus() (1 usage found)
377 List<Path> paths = Lists.newArrayList();
listInaccessibleDir() (1 usage found)
409 List<Path> paths = Lists.newArrayList(INACCESSIBLE_DIR_PATH);
listInaccessibleFile() (1 usage found)
416 List<Path> paths = Lists.newArrayList(INACCESSIBLE_FILE_PATH);
65 private static final List<Path> SUBDIR_PATHS = Lists.newArrayList();
66 private static final List<Path> FILE_PATHS = Lists.newArrayList();
TestBlockStoragePolicy.java (5 usages found)
run(CheckChooseStorageTypes) (1 usage found)
383 final List<StorageType> chosen = Lists.newArrayList();
testChooseStorageTypesWithDiskUnavailableAndNewBlock() (1 usage found)
520 final List<StorageType> chosen = Lists.newArrayList();
runWithArchiveUnavailable(CheckChooseStorageTypes) (1 usage found)
627 final List<StorageType> chosen = Lists.newArrayList();
testChooseStorageTypesWithDiskUnavailableAndNonNewBlock() (1 usage found)
730 final List<StorageType> chosen = Lists.newArrayList();
checkLocatedBlocks(HdfsLocatedFileStatus, int, int, StorageType...) (1 usage found)
1103 List<StorageType> typeList = Lists.newArrayList();
TestDecommission.java (5 usages found)
testRecommission() (1 usage found)
436 ArrayList<DatanodeInfo> decommissionedNodes = Lists.newArrayList();
doDecomCheck(DatanodeManager, DatanodeAdminManager, int) (1 usage found)
1260 ArrayList<DatanodeInfo> decommissionedNodes = Lists.newArrayList();
testPendingNodeButDecommissioned() (1 usage found)
1294 ArrayList<DatanodeInfo> decommissionedNodes = Lists.newArrayList();
testPendingNodes() (1 usage found)
1354 ArrayList<DatanodeInfo> decommissionedNodes = Lists.newArrayList();
testMultipleNodesDecommission() (1 usage found)
1560 Lists.newArrayList(getCluster().getDataNodes().get(0).getDatanodeUuid(),
TestDFSFinalize.java (1 usage found)
checkResult(String[], String[], String) (1 usage found)
69 List<File> dirs = Lists.newArrayList();
TestDFSRollback.java (1 usage found)
checkResult(NodeType, String[]) (1 usage found)
74 List<File> curDirs = Lists.newArrayList();
TestDFSShell.java (3 usages found)
testCopyCommandsWithPreserveOption() (1 usage found)
2217 dfs.setAcl(src, Lists.newArrayList(
testCopyCommandsToDirectoryWithPreserveOption() (1 usage found)
2498 dfs.setAcl(srcDir, Lists.newArrayList(
testCopyCommandsPreserveAclAndStickyBit() (1 usage found)
2645 dfs.setAcl(src, Lists.newArrayList(
TestEncryptionZones.java (2 usages found)
testVersionAndSuiteNegotiation() (1 usage found)
993 List<KeyProvider.KeyVersion> allVersions = Lists.newArrayList();
testSnapshotsOnEncryptionZones() (1 usage found)
1517 ArrayList<EncryptionZone> listZones = Lists.newArrayList();
TestErasureCodingExerciseAPIs.java (2 usages found)
testACLAPI() (2 usages found)
245 List<AclEntry> aclSpec = Lists.newArrayList(
258 List<AclEntry> maclSpec = Lists.newArrayList(
TestExtendedAcls.java (8 usages found)
testDefaultAclNewChildDirFile() (1 usage found)
96 List<AclEntry> acls = Lists.newArrayList(
testDefaultAclExistingDirFile() (2 usages found)
143 List<AclEntry> acls1 = Lists.newArrayList(
146 List<AclEntry> acls2 = Lists.newArrayList(
testAccessAclNotInherited() (1 usage found)
215 List<AclEntry> acls = Lists.newArrayList(
testGradSubdirMoreAccess() (2 usages found)
263 List<AclEntry> aclsParent = Lists.newArrayList(
265 List<AclEntry> aclsChild = Lists.newArrayList(
testRestrictAtSubDir() (2 usages found)
348 List<AclEntry> aclsParent = Lists.newArrayList(
378 List<AclEntry> newAclsChild = Lists.newArrayList(
TestMaintenanceState.java (2 usages found)
testMultipleNodesMaintenance() (1 usage found)
676 Lists.newArrayList(nodes[0].getDatanodeUuid(),
testFileCloseAfterEnteringMaintenance() (1 usage found)
998 Lists.newArrayList(dnInfos4LastBlock[0].getDatanodeUuid(),
TestQuota.java (6 usages found)
testSetSpaceQuotaNegativeNumber() (1 usage found)
1232 final List<String> outs = Lists.newArrayList();
testSetAndClearSpaceQuotaRegularInternal(String[], Path, int, int) (1 usage found)
1312 final List<String> outs = Lists.newArrayList();
testSetAndClearSpaceQuotaByStorageTypeInternal(String[], Path, int, int, int) (1 usage found)
1365 final List<String> outs = Lists.newArrayList();
testSetAndClearSpaceQuotaDirectoryNotExistInternal(String[], Path, int, String) (1 usage found)
1412 final List<String> outs = Lists.newArrayList();
testSetAndClearSpaceQuotaPathIsFileInternal(String[], Path, int, String) (1 usage found)
1463 final List<String> outs = Lists.newArrayList();
testSetAndClearSpaceQuotaNoAccessInternal(String[], int, String) (1 usage found)
1658 final List<String> outs = Lists.newArrayList();
TestSafeMode.java (1 usage found)
testRbwBlocksNotConsideredUnderReplicated() (1 usage found)
255 List<FSDataOutputStream> stms = Lists.newArrayList();
TestSafeModeWithStripedFile.java (1 usage found)
doTest(int, int) (1 usage found)
127 List<MiniDFSCluster.DataNodeProperties> dnprops = Lists.newArrayList();
TestTrashWithSecureEncryptionZones.java (2 usages found)
testTrashExpunge() (2 usages found)
297 List<Path> trashPaths = Lists.newArrayList();
309 verifyTrashExpunge(Lists.newArrayList(trashPath));
XAttrHelper.java (2 usages found)
buildXAttrAsList(String) (1 usage found)
90 List<XAttr> xAttrs = Lists.newArrayListWithCapacity(1);
buildXAttrs(List<String>) (1 usage found)
167 List<XAttr> xAttrs = Lists.newArrayListWithCapacity(names.size());
org.apache.hadoop.hdfs.protocol (2 usages found)
LocatedBlock.java (1 usage found)
addCachedLoc(DatanodeInfo) (1 usage found)
237 List<DatanodeInfo> cachedList = Lists.newArrayList(cachedLocs);
ReencryptionStatus.java (1 usage found)
48 new BatchedListEntries<>(Lists.newArrayList(), false);
org.apache.hadoop.hdfs.protocol.datatransfer (2 usages found)
PipelineAck.java (2 usages found)
PipelineAck(long, int[], long) (2 usages found)
115 ArrayList<Status> statusList = Lists.newArrayList();
116 ArrayList<Integer> flagList = Lists.newArrayList();
org.apache.hadoop.hdfs.protocol.datatransfer.sasl (2 usages found)
SaslDataTransferClient.java (1 usage found)
doSaslHandshake(InetAddress, OutputStream, InputStream, String, Map<String, String>, CallbackHandler, Token<BlockTokenIdentifier>) (1 usage found)
559 cipherOptions = Lists.newArrayListWithCapacity(1);
SaslDataTransferServer.java (1 usage found)
doSaslHandshake(Peer, OutputStream, InputStream, Map<String, String>, CallbackHandler) (1 usage found)
393 List<CipherOption> cipherOptions = Lists.newArrayList();
org.apache.hadoop.hdfs.protocolPB (19 usages found)
ClientNamenodeProtocolTranslatorPB.java (3 usages found)
listEncryptionZones(long) (1 usage found)
1644 Lists.newArrayListWithCapacity(response.getZonesCount());
listReencryptionStatus(long) (1 usage found)
1724 Lists.newArrayListWithCapacity(response.getStatusesCount());
listOpenFiles(long, EnumSet<OpenFilesType>, String) (1 usage found)
2018 Lists.newArrayListWithCapacity(response.getEntriesCount());
PBHelperClient.java (14 usages found)
convertCipherOptions(List<CipherOption>) (1 usage found)
608 Lists.newArrayListWithCapacity(options.size());
convertCipherOptionProtos(List<CipherOptionProto>) (1 usage found)
621 Lists.newArrayListWithCapacity(protos.size());
convert(GetEditsFromTxidResponseProto) (2 usages found)
864 List<EventBatch> batches = Lists.newArrayList();
875 List<Event> events = Lists.newArrayList();
convertXAttrs(List<XAttrProto>) (1 usage found)
1112 ArrayList<XAttr> xAttrs = Lists.newArrayListWithCapacity(xAttrSpec.size());
convertAclEntry(List<AclEntryProto>) (1 usage found)
1205 ArrayList<AclEntry> r = Lists.newArrayListWithCapacity(aclSpec.size());
convertXAttrProto(List<XAttr>) (2 usages found)
1315 return Lists.newArrayListWithCapacity(0);
1317 ArrayList<XAttrProto> xAttrs = Lists.newArrayListWithCapacity(
convertAclEntryProto(List<AclEntry>) (1 usage found)
1382 ArrayList<AclEntryProto> r = Lists.newArrayListWithCapacity(aclSpec.size());
convertHdfsFileStatus(List<HdfsFileStatusProto>) (1 usage found)
2039 List<HdfsFileStatus> result = Lists.newArrayListWithCapacity(fs.size());
convert(CryptoProtocolVersion[]) (1 usage found)
2087 Lists.newArrayListWithCapacity(versions.length);
convert(StorageType[][]) (1 usage found)
2095 List<StorageTypesProto> list = Lists.newArrayList();
convertEditsResponse(EventBatchList) (1 usage found)
2890 List<InotifyProtos.EventProto> events = Lists.newArrayList();
convertCryptoProtocolVersions(List<CryptoProtocolVersionProto>) (1 usage found)
3014 Lists.newArrayListWithCapacity(protos.size());
TestPBHelper.java (2 usages found)
testConvertBlockRecoveryCommand() (1 usage found)
457 List<RecoveringBlock> cmd2Blks = Lists.newArrayList(
testAclEntryProto() (1 usage found)
718 AclEntry[] actual = Lists.newArrayList(
org.apache.hadoop.hdfs.qjournal (2 usages found)
MiniJournalCluster.java (1 usage found)
getQuorumJournalURI(String) (1 usage found)
130 List<String> addrs = Lists.newArrayList();
QJMTestUtil.java (1 usage found)
recoverAndReturnLastTxn(QuorumJournalManager) (1 usage found)
167 List<EditLogInputStream> streams = Lists.newArrayList();
org.apache.hadoop.hdfs.qjournal.client (9 usages found)
QuorumJournalManager.java (1 usage found)
createLoggers(Configuration, URI, NamespaceInfo, Factory, String) (1 usage found)
416 List<AsyncLogger> ret = Lists.newArrayList();
TestQuorumJournalManager.java (3 usages found)
testReaderWhileAnotherWrites() (1 usage found)
173 List<EditLogInputStream> streams = Lists.newArrayList();
testOneJNMissingSegments() (1 usage found)
246 List<EditLogInputStream> streams = Lists.newArrayList();
testSelectInputStreamsMajorityDown() (1 usage found)
265 List<EditLogInputStream> streams = Lists.newArrayList();
TestQuorumJournalManagerUnit.java (5 usages found)
testReadRpcInputStreams() (1 usage found)
294 List<EditLogInputStream> streams = Lists.newArrayList();
testReadRpcMismatchedInputStreams() (1 usage found)
308 List<EditLogInputStream> streams = Lists.newArrayList();
testReadRpcInputStreamsOneSlow() (1 usage found)
325 List<EditLogInputStream> streams = Lists.newArrayList();
testReadRpcInputStreamsOneException() (1 usage found)
341 List<EditLogInputStream> streams = Lists.newArrayList();
testReadRpcInputStreamsNoNewEdits() (1 usage found)
356 List<EditLogInputStream> streams = Lists.newArrayList();
org.apache.hadoop.hdfs.qjournal.server (14 usages found)
JournalNode.java (1 usage found)
84 private final ArrayList<File> localDir = Lists.newArrayList();
JournalNodeSyncer.java (2 usages found)
getMissingLogList(List<RemoteEditLog>, List<RemoteEditLog>) (1 usage found)
383 List<RemoteEditLog> missingEditLogs = Lists.newArrayList();
76 private List<JournalNodeProxy> otherJNProxies = Lists.newArrayList();
TestJournalNodeSync.java (11 usages found)
testJournalNodeSync() (1 usage found)
116 GenericTestUtils.waitFor(editLogExists(Lists.newArrayList(missingLog)),
testSyncForMultipleMissingLogs() (1 usage found)
130 List<File> missingLogs = Lists.newArrayList();
testSyncForDiscontinuousMissingLogs() (1 usage found)
148 List<File> missingLogs = Lists.newArrayList();
testMultipleJournalsMissingLogs() (1 usage found)
169 List<File> missingLogs = Lists.newArrayList();
testMultipleJournalsMultipleMissingLogs() (1 usage found)
195 List<File> missingLogs = Lists.newArrayList();
testSyncAfterJNdowntime() (1 usage found)
244 List<File> missingLogs = Lists.newArrayList();
testSyncAfterJNdowntimeWithoutQJournalQueue() (1 usage found)
297 List<File> missingLogs = Lists.newArrayList();
testSyncAfterJNformat() (1 usage found)
352 List<File> missingLogs = Lists.newArrayList();
deleteEditLogsFromRandomJN() (3 usages found)
457 List<File> journalCurrentDirs = Lists.newArrayList();
472 List<File> missingLogs = Lists.newArrayList();
473 List<Integer> deletedStartTxIds = Lists.newArrayList();
org.apache.hadoop.hdfs.server.aliasmap (1 usage found)
InMemoryAliasMap.java (1 usage found)
list(Optional<Block>) (1 usage found)
142 Lists.newArrayListWithExpectedSize(batchSize);
org.apache.hadoop.hdfs.server.blockmanagement (10 usages found)
BlockStoragePolicySuite.java (1 usage found)
getAllPolicies() (1 usage found)
155 List<BlockStoragePolicy> list = Lists.newArrayList();
PendingDataNodeMessages.java (1 usage found)
takeAll() (1 usage found)
151 List<ReportedBlockInfo> rbis = Lists.newArrayListWithCapacity(
SlowDiskTracker.java (3 usages found)
getSlowDisks(Map<String, DiskLatency>, int, long) (2 usages found)
234 ArrayList<DiskLatency> oldSlowDiskIDs = Lists.newArrayList();
253 return Lists.newArrayList(topNReports);
99 Lists.newArrayList();
TestBlockManager.java (3 usages found)
getNodes(int...) (1 usage found)
570 List<DatanodeDescriptor> ret = Lists.newArrayList();
getNodes(List<DatanodeStorageInfo>) (1 usage found)
578 List<DatanodeDescriptor> ret = Lists.newArrayList();
getStorages(int...) (1 usage found)
586 List<DatanodeStorageInfo> ret = Lists.newArrayList();
TestRBWBlockInvalidation.java (2 usages found)
testRWRInvalidation() (2 usages found)
167 List<Path> testPaths = Lists.newArrayList();
175 List<FSDataOutputStream> streams = Lists.newArrayList();
org.apache.hadoop.hdfs.server.common (2 usages found)
Util.java (2 usages found)
receiveFile(String, List<File>, Storage, boolean, long, MD5Hash, String, ...) (1 usage found)
230 List<FileOutputStream> outputStreams = Lists.newArrayList();
getAddressesList(URI) (1 usage found)
373 List<InetSocketAddress> addrs = Lists.newArrayList();
org.apache.hadoop.hdfs.server.common.blockaliasmap.impl (2 usages found)
TestInMemoryLevelDBAliasMapClient.java (2 usages found)
iterateSingleBatch() (1 usage found)
140 Lists.newArrayListWithCapacity(2);
iterateThreeBatches() (1 usage found)
209 Lists.newArrayListWithCapacity(6);
org.apache.hadoop.hdfs.server.datanode (29 usages found)
BlockPoolManager.java (6 usages found)
doRefreshNamenodes(Map<String, Map<String, InetSocketAddress>>, Map<String, Map<String, InetSocketAddress>>) (6 usages found)
218 Lists.newArrayListWithCapacity(nnIdToAddr.size());
220 Lists.newArrayListWithCapacity(nnIdToAddr.size());
222 Lists.newArrayListWithCapacity(nnIdToAddr.size());
264 Lists.newArrayListWithCapacity(nnIdToAddr.size());
266 Lists.newArrayListWithCapacity(nnIdToAddr.size());
267 ArrayList<String> nnIds = Lists.newArrayListWithCapacity(
BlockPoolSliceStorage.java (1 usage found)
loadBpStorageDirectories(NamespaceInfo, StorageLocation, StartupOption, List<Callable<StorageDirectory>>, Configuration) (1 usage found)
220 List<StorageDirectory> succeedDirs = Lists.newArrayList();
BPOfferService.java (1 usage found)
getBPServiceActors() (1 usage found)
536 return Lists.newArrayList(bpServices);
DataNode.java (6 usages found)
refreshVolumes(String) (3 usages found)
770 final List<NamespaceInfo> nsInfos = Lists.newArrayList();
781 List<String> effectiveVolumes = Lists.newArrayList();
798 List<Future<IOException>> exceptions = Lists.newArrayList();
662 List<StorageLocation> newLocations = Lists.newArrayList();
664 List<StorageLocation> deactivateLocations = Lists.newArrayList();
666 List<StorageLocation> unchangedLocations = Lists.newArrayList();
DataStorage.java (10 usages found)
addStorageLocations(DataNode, NamespaceInfo, Collection<StorageLocation>, StartupOption) (1 usage found)
393 return Lists.newArrayList();
loadDataStorage(DataNode, NamespaceInfo, Collection<StorageLocation>, StartupOption, ExecutorService) (3 usages found)
406 final List<StorageLocation> success = Lists.newArrayList();
407 final List<UpgradeTask> tasks = Lists.newArrayList();
413 = Lists.newArrayList();
loadBlockPoolSliceStorage(DataNode, NamespaceInfo, Collection<StorageLocation>, StartupOption, ExecutorService) (3 usages found)
457 final List<StorageDirectory> success = Lists.newArrayList();
458 final List<UpgradeTask> tasks = Lists.newArrayList();
463 Lists.newArrayList();
linkBlocks(File, File, int, HardLink, Configuration) (2 usages found)
1102 final ArrayList<LinkArgs> idBasedLayoutSingleLinks = Lists.newArrayList();
1120 List<Future<Void>> futures = Lists.newArrayList();
findDuplicateEntries(ArrayList<LinkArgs>) (1 usage found)
1169 final ArrayList<LinkArgs> duplicates = Lists.newArrayList();
TestBPOfferService.java (2 usages found)
setupBPOSForNNs(DataNode, DatanodeProtocolClientSideTranslatorPB...) (2 usages found)
572 List<String> nnIds = Lists.newArrayListWithCapacity(nns.length);
581 Lists.newArrayList(nnMap.keySet()),
TestDataNodeHotSwapVolumes.java (1 usage found)
testAddVolumeFailures() (1 usage found)
763 List<String> newDirs = Lists.newArrayList();
TestDataNodeMetrics.java (1 usage found)
testTimeoutMetric() (1 usage found)
274 final List<FSDataOutputStream> streams = Lists.newArrayList();
TestDatanodeRegister.java (1 usage found)
testDNShutdwonBeforeRegister() (1 usage found)
148 Lists.newArrayList("nn0"), Lists.newArrayList(nnADDR),
org.apache.hadoop.hdfs.server.datanode.fsdataset.impl (7 usages found)
FsDatasetImpl.java (4 usages found)
getInitialVolumeFailureInfos(Collection<StorageLocation>, DataStorage) (1 usage found)
440 List<VolumeFailureInfo> volumeFailureInfos = Lists.newArrayListWithCapacity(
addVolume(StorageLocation, List<NamespaceInfo>) (1 usage found)
533 ArrayList<IOException> exceptions = Lists.newArrayList();
getFailedStorageLocations() (1 usage found)
700 List<String> failedStorageLocations = Lists.newArrayListWithCapacity(
getVolumeFailureSummary() (1 usage found)
737 List<String> failedStorageLocations = Lists.newArrayListWithCapacity(
TestFsDatasetImpl.java (3 usages found)
testAddVolumes() (1 usage found)
304 List<NamespaceInfo> nsInfos = Lists.newArrayList();
testAddVolumeFailureReleasesInUseLock() (1 usage found)
559 List<NamespaceInfo> nsInfos = Lists.newArrayList();
getDfsUsedValueOfNewVolume(long, long) (1 usage found)
686 List<NamespaceInfo> nsInfos = Lists.newArrayList();
org.apache.hadoop.hdfs.server.datanode.web.webhdfs (1 usage found)
TestDataNodeUGIProvider.java (1 usage found)
testUGICacheSecure() (1 usage found)
85 List<Token<DelegationTokenIdentifier>> tokens = Lists.newArrayList();
org.apache.hadoop.hdfs.server.diskbalancer.command (5 usages found)
Command.java (2 usages found)
getNodes(String) (2 usages found)
311 List<DiskBalancerDataNode> nodeList = Lists.newArrayList();
312 List<String> invalidNodeList = Lists.newArrayList();
ReportCommand.java (2 usages found)
handleNodeReport(CommandLine, TextStringBuilder, String, String) (1 usage found)
156 List<DiskBalancerDataNode> dbdns = Lists.newArrayList();
recordNodeReport(TextStringBuilder, DiskBalancerDataNode, String, String) (1 usage found)
193 List<String> volumeList = Lists.newArrayList();
TestDiskBalancerCommand.java (1 usage found)
runCommandInternal(String, Configuration) (1 usage found)
787 List<String> outputs = Lists.newArrayList();
org.apache.hadoop.hdfs.server.mover (2 usages found)
Mover.java (2 usages found)
readPathFile(String) (1 usage found)
712 List<String> list = Lists.newArrayList();
getNameNodePaths(CommandLine, Configuration) (1 usage found)
774 targets = Lists.newArrayList();
org.apache.hadoop.hdfs.server.namenode (255 usages found)
AclStorage.java (3 usages found)
copyINodeDefaultAcl(INode) (1 usage found)
95 List<AclEntry> accessEntries = Lists.newArrayListWithCapacity(
readINodeLogicalAcl(INode) (1 usage found)
226 existingAcl = Lists.newArrayListWithCapacity(featureEntries.size() + 3);
createAclFeature(List<AclEntry>, List<AclEntry>) (1 usage found)
324 List<AclEntry> featureEntries = Lists.newArrayListWithCapacity(
AclTransformation.java (6 usages found)
filterAclEntriesByAclSpec(List<AclEntry>, List<AclEntry>) (1 usage found)
82 ArrayList<AclEntry> aclBuilder = Lists.newArrayListWithCapacity(MAX_ENTRIES);
filterDefaultAclEntries(List<AclEntry>) (1 usage found)
116 ArrayList<AclEntry> aclBuilder = Lists.newArrayListWithCapacity(MAX_ENTRIES);
mergeAclEntries(List<AclEntry>, List<AclEntry>) (2 usages found)
140 ArrayList<AclEntry> aclBuilder = Lists.newArrayListWithCapacity(MAX_ENTRIES);
142 Lists.newArrayListWithCapacity(MAX_ENTRIES);
replaceAclEntries(List<AclEntry>, List<AclEntry>) (1 usage found)
202 ArrayList<AclEntry> aclBuilder = Lists.newArrayListWithCapacity(MAX_ENTRIES);
copyDefaultsIfNeeded(List<AclEntry>) (1 usage found)
415 List<AclEntry> copiedEntries = Lists.newArrayListWithCapacity(3);
BackupImage.java (1 usage found)
tryConvergeJournalSpool() (1 usage found)
269 List<EditLogInputStream> editStreams = Lists.newArrayList();
Checkpointer.java (1 usage found)
rollForwardByApplyingLogs(RemoteEditLogManifest, FSImage, FSNamesystem) (1 usage found)
307 List<EditLogInputStream> editsStreams = Lists.newArrayList();
EncryptionZoneManager.java (5 usages found)
createEncryptionZone(INodesInPath, CipherSuite, CryptoProtocolVersion, String) (1 usage found)
562 final List<XAttr> xattrs = Lists.newArrayListWithCapacity(1);
listEncryptionZones(long) (2 usages found)
580 return new BatchedListEntries<EncryptionZone>(Lists.newArrayList(), false);
587 Lists.newArrayListWithExpectedSize(numResponses);
reencryptEncryptionZone(INodesInPath, String) (1 usage found)
658 final List<XAttr> xAttrs = Lists.newArrayListWithCapacity(1);
listReencryptionStatus(long) (1 usage found)
724 Lists.newArrayListWithExpectedSize(numResp);
FileJournalManager.java (4 usages found)
getRemoteEditLogs(long, boolean) (1 usage found)
238 List<RemoteEditLog> ret = Lists.newArrayListWithCapacity(
discardEditLogSegments(long) (1 usage found)
276 List<EditLogFile> toTrash = Lists.newArrayList();
matchEditLogs(File[], boolean) (1 usage found)
315 List<EditLogFile> ret = Lists.newArrayList();
getLogFiles(long) (1 usage found)
471 List<EditLogFile> logFiles = Lists.newArrayList();
FSAclBaseTest.java (77 usages found)
testModifyAclEntries() (2 usages found)
118 List<AclEntry> aclSpec = Lists.newArrayList(
128 aclSpec = Lists.newArrayList(
testModifyAclEntriesOnlyAccess() (2 usages found)
153 List<AclEntry> aclSpec = Lists.newArrayList(
159 aclSpec = Lists.newArrayList(
testModifyAclEntriesOnlyDefault() (2 usages found)
174 List<AclEntry> aclSpec = Lists.newArrayList(
177 aclSpec = Lists.newArrayList(
testModifyAclEntriesMinimal() (1 usage found)
196 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesMinimalDefault() (1 usage found)
211 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesCustomMask() (1 usage found)
230 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesStickyBit() (2 usages found)
246 List<AclEntry> aclSpec = Lists.newArrayList(
253 aclSpec = Lists.newArrayList(
testModifyAclEntriesPathNotFound() (1 usage found)
274 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesDefaultOnFile() (1 usage found)
286 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAclEntries() (2 usages found)
294 List<AclEntry> aclSpec = Lists.newArrayList(
301 aclSpec = Lists.newArrayList(
testRemoveAclEntriesOnlyAccess() (2 usages found)
321 List<AclEntry> aclSpec = Lists.newArrayList(
328 aclSpec = Lists.newArrayList(
testRemoveAclEntriesOnlyDefault() (2 usages found)
343 List<AclEntry> aclSpec = Lists.newArrayList(
350 aclSpec = Lists.newArrayList(
testRemoveAclEntriesMinimal() (2 usages found)
369 List<AclEntry> aclSpec = Lists.newArrayList(
375 aclSpec = Lists.newArrayList(
testRemoveAclEntriesMinimalDefault() (2 usages found)
390 List<AclEntry> aclSpec = Lists.newArrayList(
397 aclSpec = Lists.newArrayList(
testRemoveAclEntriesStickyBit() (2 usages found)
416 List<AclEntry> aclSpec = Lists.newArrayList(
423 aclSpec = Lists.newArrayList(
testRemoveAclEntriesPathNotFound() (1 usage found)
442 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveDefaultAcl() (1 usage found)
450 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveDefaultAclOnlyAccess() (1 usage found)
476 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveDefaultAclOnlyDefault() (1 usage found)
500 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveDefaultAclStickyBit() (1 usage found)
535 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAcl() (1 usage found)
566 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAclStickyBit() (1 usage found)
606 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAclOnlyDefault() (1 usage found)
624 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAcl() (1 usage found)
647 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclOnlyAccess() (1 usage found)
672 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclOnlyDefault() (1 usage found)
690 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclMinimal() (2 usages found)
709 List<AclEntry> aclSpec = Lists.newArrayList(
715 aclSpec = Lists.newArrayList(
testSetAclMinimalDefault() (1 usage found)
730 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclCustomMask() (1 usage found)
749 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclStickyBit() (1 usage found)
768 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclPathNotFound() (1 usage found)
792 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclDefaultOnFile() (1 usage found)
804 List<AclEntry> aclSpec = Lists.newArrayList(
testSetPermission() (1 usage found)
812 List<AclEntry> aclSpec = Lists.newArrayList(
testSetPermissionOnlyAccess() (1 usage found)
838 List<AclEntry> aclSpec = Lists.newArrayList(
testSetPermissionOnlyDefault() (1 usage found)
857 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewFile() (1 usage found)
902 List<AclEntry> aclSpec = Lists.newArrayList(
testUMaskDefaultAclNewFile() (1 usage found)
919 List<AclEntry> aclSpec = Lists.newArrayList(
testOnlyAccessAclNewFile() (1 usage found)
959 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultMinimalAclNewFile() (1 usage found)
974 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewDir() (1 usage found)
991 List<AclEntry> aclSpec = Lists.newArrayList(
testUMaskDefaultAclNewDir() (1 usage found)
1019 List<AclEntry> aclSpec = Lists.newArrayList(
testOnlyAccessAclNewDir() (1 usage found)
1069 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultMinimalAclNewDir() (1 usage found)
1084 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewFileIntermediate() (1 usage found)
1104 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewDirIntermediate() (1 usage found)
1136 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewSymlinkIntermediate() (1 usage found)
1168 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewFileWithMode() (1 usage found)
1203 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNewDirWithMode() (1 usage found)
1225 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclRenamedFile() (1 usage found)
1248 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclRenamedDir() (1 usage found)
1268 List<AclEntry> aclSpec = Lists.newArrayList(
testSkipAclEnforcementPermsDisabled() (1 usage found)
1290 fsAsBruce.modifyAclEntries(bruceFile, Lists.newArrayList(
testSkipAclEnforcementSuper() (1 usage found)
1310 fsAsBruce.modifyAclEntries(bruceFile, Lists.newArrayList(
testModifyAclEntriesMustBeOwnerOrSuper() (1 usage found)
1326 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAclEntriesMustBeOwnerOrSuper() (1 usage found)
1342 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclMustBeOwnerOrSuper() (1 usage found)
1386 List<AclEntry> aclSpec = Lists.newArrayList(
testGetAclStatusRequiresTraverseOrSuper() (1 usage found)
1405 fsAsBruce.setAcl(bruceDir, Lists.newArrayList(
testAccess() (4 usages found)
1422 fsAsBruce.setAcl(p1, Lists.newArrayList(
1444 fsAsBruce.modifyAclEntries(p1, Lists.newArrayList(
1456 fsAsBruce.modifyAclEntries(p1, Lists.newArrayList(
1463 Lists.newArrayList(aclEntry(ACCESS, USER, "bob", NONE)));
testEffectiveAccess() (1 usage found)
1485 fs.modifyAclEntries(p1, Lists.newArrayList(
testDeDuplication() (5 usages found)
1537 List<AclEntry> aclSpec = Lists.newArrayList(
1574 List<AclEntry> aclSpec = Lists.newArrayList(aclEntry(ACCESS, USER,
1586 fs.removeAclEntries(child1, Lists.newArrayList(aclEntry));
1621 List<AclEntry> aclSpec = Lists.newArrayList(aclEntry(ACCESS, USER,
1634 fs.removeAclEntries(file1, Lists.newArrayList(aclEntry));
FSDirAttrOp.java (2 usages found)
setDirStoragePolicy(FSDirectory, INodesInPath, byte) (2 usages found)
459 List<XAttr> toRemove = Lists.newArrayList();
461 List<XAttr> removed = Lists.newArrayList();
FSDirEncryptionZoneOp.java (5 usages found)
createEncryptionZone(FSDirectory, String, FSPermissionChecker, String, String, boolean) (1 usage found)
161 List<XAttr> xAttrs = Lists.newArrayListWithCapacity(1);
updateReencryptionSubmitted(FSDirectory, INodesInPath, String) (1 usage found)
272 final List<XAttr> xattrs = Lists.newArrayListWithCapacity(1);
updateReencryptionProgress(FSDirectory, INode, ZoneReencryptionStatus, String, long, long) (1 usage found)
312 final List<XAttr> xattrs = Lists.newArrayListWithCapacity(1);
updateReencryptionFinish(FSDirectory, INodesInPath, ZoneReencryptionStatus) (1 usage found)
336 final List<XAttr> xattrs = Lists.newArrayListWithCapacity(1);
setFileEncryptionInfo(FSDirectory, INodesInPath, FileEncryptionInfo, XAttrSetFlag) (1 usage found)
417 final List<XAttr> xAttrs = Lists.newArrayListWithCapacity(1);
FSDirErasureCodingOp.java (2 usages found)
setErasureCodingPolicyXAttr(FSNamesystem, INodesInPath, ErasureCodingPolicy) (1 usage found)
189 final List<XAttr> xattrs = Lists.newArrayListWithCapacity(1);
removeErasureCodingPolicyXAttr(FSNamesystem, INodesInPath) (1 usage found)
336 final List<XAttr> xattrs = Lists.newArrayListWithCapacity(1);
FSDirSatisfyStoragePolicyOp.java (1 usage found)
removeSPSXattr(FSDirectory, INode, XAttr) (1 usage found)
150 List<XAttr> xAttrs = Lists.newArrayListWithCapacity(1);
FSDirXAttrOp.java (6 usages found)
setXAttr(FSDirectory, FSPermissionChecker, String, XAttr, EnumSet<XAttrSetFlag>, boolean) (1 usage found)
80 List<XAttr> xAttrs = Lists.newArrayListWithCapacity(1);
getXAttrs(FSDirectory, FSPermissionChecker, String, List<XAttr>) (1 usage found)
120 List<XAttr> toGet = Lists.newArrayListWithCapacity(xAttrs.size());
removeXAttr(FSDirectory, FSPermissionChecker, String, XAttr, boolean) (1 usage found)
174 List<XAttr> xAttrs = Lists.newArrayListWithCapacity(1);
unprotectedRemoveXAttrs(FSDirectory, INodesInPath, List<XAttr>) (1 usage found)
207 List<XAttr> removedXAttrs = Lists.newArrayListWithCapacity(toRemove.size());
filterINodeXAttrs(List<XAttr>, List<XAttr>, List<XAttr>) (1 usage found)
240 Lists.newArrayListWithCapacity(existingXAttrs.size());
setINodeXAttrs(FSDirectory, List<XAttr>, List<XAttr>, EnumSet<XAttrSetFlag>) (1 usage found)
357 List<XAttr> xAttrs = Lists.newArrayListWithCapacity(newSize);
FSEditLog.java (2 usages found)
FSEditLog(Configuration, NNStorage, List<URI>) (1 usage found)
252 this.editsDirs = Lists.newArrayList(editsDirs);
getFormatConfirmables() (1 usage found)
438 List<FormatConfirmable> ret = Lists.newArrayList();
FSEditLogOp.java (5 usages found)
read(DataInputStream, int) (1 usage found)
361 List<AclEntry> aclEntries = Lists.newArrayListWithCapacity(size);
fromXml(Stanza) (1 usage found)
4398 aclEntries = Lists.newArrayList();
readAclEntriesFromXml(Stanza) (1 usage found)
5521 List<AclEntry> aclEntries = Lists.newArrayList();
readXAttrsFromXml(Stanza) (1 usage found)
5563 List<XAttr> xattrs = Lists.newArrayListWithCapacity(stanzas.size());
4351 List<AclEntry> aclEntries = Lists.newArrayList();
FSImage.java (5 usages found)
confirmFormat(boolean, boolean) (1 usage found)
205 List<FormatConfirmable> confirms = Lists.newArrayList();
renameCheckpoint(long, NameNodeFile, NameNodeFile, boolean) (1 usage found)
1294 al = Lists.newArrayList();
renameCheckpoint(NameNodeFile, NameNodeFile) (1 usage found)
1318 al = Lists.newArrayList();
deleteCancelledCheckpoint(long) (1 usage found)
1333 ArrayList<StorageDirectory> al = Lists.newArrayList();
saveDigestAndRenameCheckpointImage(NameNodeFile, long, MD5Hash) (1 usage found)
1449 List<StorageDirectory> badSds = Lists.newArrayList();
FSImageFormatProtobuf.java (3 usages found)
loadInternal(RandomAccessFile, FileInputStream) (1 usage found)
370 ArrayList<FileSummary.Section> sections = Lists.newArrayList(summary
93 private final ArrayList<INodeReference> refList = Lists.newArrayList();
134 private final ArrayList<INodeReference> refList = Lists.newArrayList();
FSImageTestUtil.java (5 usages found)
createStandaloneEditLog(File) (1 usage found)
201 List<StorageDirectory> sds = Lists.newArrayList(sd);
getCurrentDirs(NNStorage, NameNodeDirType) (1 usage found)
458 List<File> ret = Lists.newArrayList();
getNameNodeCurrentDirs(MiniDFSCluster, int) (1 usage found)
521 List<File> nameDirs = Lists.newArrayList();
findLatestEditsLog(StorageDirectory) (1 usage found)
536 = Lists.newArrayList(FileJournalManager.matchEditLogs(currentDir));
assertNNFilesMatch(MiniDFSCluster) (1 usage found)
609 List<File> curDirs = Lists.newArrayList();
FSImageTransactionalStorageInspector.java (1 usage found)
51 private final List<Pattern> namePatterns = Lists.newArrayList();
FSNamesystem.java (6 usages found)
initAuditLoggers(Configuration) (1 usage found)
1133 List<AuditLogger> auditLoggers = Lists.newArrayList();
getNamespaceEditsDirs(Configuration, boolean) (2 usages found)
1680 return Lists.newArrayList(getNamespaceDirs(conf));
1682 return Lists.newArrayList(editsDirs);
getFilesBlockingDecom(long, String) (1 usage found)
1960 final List<OpenFileEntry> openFileEntries = Lists.newArrayList();
sortLocatedBlocks(String, LocatedBlocks) (1 usage found)
2174 ArrayList<LocatedBlock> lastBlockList = Lists.newArrayList(lastBlock);
getBatchedListing(String[], byte[], boolean) (1 usage found)
4167 srcsIndex, Lists.newArrayList(dirListing.getPartialListing()));
FSXAttrBaseTest.java (3 usages found)
testGetXAttrs() (1 usage found)
416 final List<String> names = Lists.newArrayList();
testXAttrAcl() (2 usages found)
944 fsAsBruce.modifyAclEntries(path, Lists.newArrayList(
963 fsAsBruce.modifyAclEntries(path, Lists.newArrayList(
InotifyFSEditLogOpTranslator.java (1 usage found)
translate(FSEditLogOp) (1 usage found)
84 List<Event> events = Lists.newArrayList();
LeaseManager.java (3 usages found)
getINodeWithLeases(INodeDirectory) (2 usages found)
231 List<Future<List<INodesInPath>>> futureList = Lists.newArrayList();
241 List<INodesInPath> iNodesInPaths = Lists.newArrayList();
getUnderConstructionFiles(long, String) (1 usage found)
308 Lists.newArrayListWithExpectedSize(numResponses);
NameNode.java (1 usage found)
320 .newTreeSet(Lists.newArrayList(
NameNodeRpcServer.java (2 usages found)
getEventBatchList(long, long, FSEditLog, boolean, int) (1 usage found)
2401 List<EventBatch> batches = Lists.newArrayList();
listReconfigurableProperties() (1 usage found)
2631 List<String> result = Lists.newArrayList(nn.getReconfigurableProperties());
NNStorage.java (1 usage found)
NNStorage(Configuration, Collection<URI>, Collection<URI>) (1 usage found)
180 Lists.newArrayList(editsDirs),
NNStorageRetentionManager.java (1 usage found)
getImageTxIdToRetain(FSImageTransactionalStorageInspector) (1 usage found)
200 List<Long> imageTxIdsList = Lists.newArrayList(imageTxIds);
ReencryptionUpdater.java (1 usage found)
processCheckpoints(INode, ZoneSubmissionTracker) (1 usage found)
384 final List<XAttr> xAttrs = Lists.newArrayListWithCapacity(1);
SecondaryNameNode.java (2 usages found)
getCheckpointDirectories() (1 usage found)
751 ArrayList<String> r = Lists.newArrayListWithCapacity(checkpointDirs.size());
getCheckpointEditlogDirectories() (1 usage found)
760 ArrayList<String> r = Lists.newArrayListWithCapacity(checkpointEditsDirs.size());
TestAclConfigFlag.java (6 usages found)
testModifyAclEntries() (1 usage found)
70 fs.modifyAclEntries(PATH, Lists.newArrayList(
testRemoveAclEntries() (1 usage found)
79 fs.removeAclEntries(PATH, Lists.newArrayList(
testRemoveDefaultAcl() (1 usage found)
88 fs.removeAclEntries(PATH, Lists.newArrayList(
testSetAcl() (1 usage found)
105 fs.setAcl(PATH, Lists.newArrayList(
testEditLog() (1 usage found)
122 fs.setAcl(PATH, Lists.newArrayList(
testFsImage() (1 usage found)
134 fs.setAcl(PATH, Lists.newArrayList(
TestAclTransformation.java (49 usages found)
testFilterAclEntriesByAclSpec() (1 usage found)
67 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecUnchanged() (1 usage found)
91 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecAccessMaskCalculated() (1 usage found)
108 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecDefaultMaskCalculated() (1 usage found)
134 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecDefaultMaskPreserved() (1 usage found)
165 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecAccessMaskPreserved() (1 usage found)
199 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecAutomaticDefaultUser() (1 usage found)
230 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecAutomaticDefaultGroup() (1 usage found)
256 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecAutomaticDefaultOther() (1 usage found)
280 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecEmptyAclSpec() (1 usage found)
307 List<AclEntry> aclSpec = Lists.newArrayList();
testFilterAclEntriesByAclSpecRemoveAccessMaskRequired() (1 usage found)
321 List<AclEntry> aclSpec = Lists.newArrayList(
testFilterAclEntriesByAclSpecRemoveDefaultMaskRequired() (1 usage found)
339 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntries() (1 usage found)
412 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesUnchanged() (1 usage found)
440 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesMultipleNewBeforeExisting() (1 usage found)
466 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesAccessMaskCalculated() (1 usage found)
491 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesDefaultMaskCalculated() (1 usage found)
517 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesDefaultMaskPreserved() (1 usage found)
546 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesAccessMaskPreserved() (1 usage found)
579 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesAutomaticDefaultUser() (1 usage found)
605 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesAutomaticDefaultGroup() (1 usage found)
626 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesAutomaticDefaultOther() (1 usage found)
647 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesProvidedAccessMask() (1 usage found)
668 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesProvidedDefaultMask() (1 usage found)
688 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesEmptyAclSpec() (1 usage found)
719 List<AclEntry> aclSpec = Lists.newArrayList();
testMergeAclEntriesResultTooLarge() (1 usage found)
756 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclDefaultEntriesResultTooLarge() (1 usage found)
774 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesDuplicateEntries() (1 usage found)
786 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesNamedMask() (1 usage found)
801 List<AclEntry> aclSpec = Lists.newArrayList(
testMergeAclEntriesNamedOther() (1 usage found)
813 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntries() (1 usage found)
827 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesUnchanged() (1 usage found)
873 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesAccessMaskCalculated() (1 usage found)
896 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesDefaultMaskCalculated() (1 usage found)
920 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesDefaultMaskPreserved() (1 usage found)
958 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesAccessMaskPreserved() (1 usage found)
996 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesAutomaticDefaultUser() (1 usage found)
1024 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesAutomaticDefaultGroup() (1 usage found)
1052 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesAutomaticDefaultOther() (1 usage found)
1080 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesOnlyDefaults() (1 usage found)
1108 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesResultTooLarge() (1 usage found)
1150 List<AclEntry> aclSpec = Lists.newArrayListWithCapacity(32);
testReplaceAclEntriesDuplicateEntries() (1 usage found)
1169 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesNamedMask() (1 usage found)
1187 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesNamedOther() (1 usage found)
1202 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesMissingUser() (1 usage found)
1217 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesMissingGroup() (1 usage found)
1233 List<AclEntry> aclSpec = Lists.newArrayList(
testReplaceAclEntriesMissingOther() (1 usage found)
1249 List<AclEntry> aclSpec = Lists.newArrayList(
47 ACL_SPEC_TOO_LARGE = Lists.newArrayListWithCapacity(33);
48 ACL_SPEC_DEFAULT_TOO_LARGE = Lists.newArrayListWithCapacity(33);
TestAuditLogger.java (3 usages found)
testAuditLogWithAclFailure() (1 usage found)
426 final List<AclEntry> acls = Lists.newArrayList();
testAuditLogForAcls() (2 usages found)
489 final List<AclEntry> acls = Lists.newArrayList();
506 List<AclEntry> aclsToRemove = Lists.newArrayList();
TestBackupNode.java (1 usage found)
assertStorageDirsMatch(NameNode, BackupNode) (1 usage found)
338 List<File> dirs = Lists.newArrayList(
TestCheckpoint.java (3 usages found)
testNamespaceVerifiedOnFileTransfer() (1 usage found)
1985 Mockito.doReturn(Lists.newArrayList(new File("/wont-be-written")))
assertParallelFilesInvariant(MiniDFSCluster, ImmutableList<SecondaryNameNode>) (1 usage found)
2597 List<File> allCurrentDirs = Lists.newArrayList();
getCheckpointCurrentDirs(SecondaryNameNode) (1 usage found)
2607 List<File> ret = Lists.newArrayList();
TestEditLog.java (6 usages found)
testMultiStreamsLoadEditWithConfMaxTxns() (1 usage found)
361 List<EditLogInputStream> editStreams = Lists.newArrayList();
doTestCrashRecoveryEmptyLog(boolean, boolean, boolean) (1 usage found)
954 Lists.newArrayList(uri));
mockStorageWithEdits(String...) (3 usages found)
1193 List<StorageDirectory> sds = Lists.newArrayList();
1194 List<URI> uris = Lists.newArrayList();
1198 List<String> files = Lists.newArrayList();
testResetThreadLocalCachedOps() (1 usage found)
1680 List<AclEntry> aclSpec = Lists.newArrayList(
TestFSDirectory.java (11 usages found)
testINodeXAttrsLimit() (2 usages found)
191 List<XAttr> existingXAttrs = Lists.newArrayListWithCapacity(2);
206 List<XAttr> newXAttrs = Lists.newArrayListWithCapacity(2);
generateXAttrs(int) (1 usage found)
247 List<XAttr> generatedXAttrs = Lists.newArrayListWithCapacity(numXAttrs);
testXAttrMultiSetRemove() (4 usages found)
264 List<XAttr> existingXAttrs = Lists.newArrayListWithCapacity(0);
273 List<XAttr> toAdd = Lists.newArrayListWithCapacity(numToAdd);
296 List<XAttr> toRemove = Lists.newArrayListWithCapacity(numToRemove);
306 List<XAttr> removedXAttrs = Lists.newArrayList();
testXAttrMultiAddRemoveErrors() (4 usages found)
321 List<XAttr> existingXAttrs = Lists.newArrayList();
322 List<XAttr> toAdd = Lists.newArrayList();
366 toAdd = Lists.newArrayList();
385 toAdd = Lists.newArrayList();
TestFSImage.java (2 usages found)
testParallelSaveAndLoad() (1 usage found)
1076 ArrayList<Section> sections = Lists.newArrayList(
testNoParallelSectionsWithCompressionEnabled() (1 usage found)
1120 ArrayList<Section> sections = Lists.newArrayList(
TestFSImageWithAcl.java (10 usages found)
testAcl(boolean) (5 usages found)
71 fs.modifyAclEntries(p, Lists.newArrayList(e));
76 AclEntry[] returned = Lists.newArrayList(s.getEntries()).toArray(
94 returned = Lists.newArrayList(s.getEntries()).toArray(new AclEntry[0]);
97 fs.modifyAclEntries(p, Lists.newArrayList(e));
99 returned = Lists.newArrayList(s.getEntries()).toArray(new AclEntry[0]);
doTestDefaultAclNewChildren(boolean) (2 usages found)
122 List<AclEntry> aclSpec = Lists.newArrayList(
161 aclSpec = Lists.newArrayList(aclEntry(DEFAULT, USER, "foo", READ_WRITE));
testRootACLAfterLoadingFsImage() (3 usages found)
221 fs.modifyAclEntries(rootdir, Lists.newArrayList(e1, e2));
225 Lists.newArrayList(s.getEntries()).toArray(new AclEntry[0]);
235 returned = Lists.newArrayList(s.getEntries()).toArray(new AclEntry[0]);
TestINodeAttributeProvider.java (2 usages found)
getAttributes(String[], INodeAttributes) (2 usages found)
174 Lists.newArrayList(acl)));
186 Lists.newArrayList(
TestLeaseManager.java (1 usage found)
testRemoveLeases() (1 usage found)
67 ArrayList<Long> ids = Lists.newArrayList(INodeId.ROOT_INODE_ID + 1,
TestNNStorageRetentionManager.java (4 usages found)
FakeRoot(NameNodeDirType) (1 usage found)
349 files = Lists.newArrayList();
mockStorage() (1 usage found)
395 List<StorageDirectory> sds = Lists.newArrayList();
mockEditLog(StoragePurger) (1 usage found)
419 final List<JournalManager> jms = Lists.newArrayList();
filesToPaths(Collection<File>) (1 usage found)
472 List<String> paths = Lists.newArrayList();
TransferFsImage.java (1 usage found)
downloadMostRecentImageToDirectory(URL, File) (1 usage found)
106 getFileClient(infoServer, fileId, Lists.newArrayList(dir),
XAttrPermissionFilter.java (1 usage found)
filterXAttrsForApi(FSPermissionChecker, List<XAttr>, boolean) (1 usage found)
107 List<XAttr> filteredXAttrs = Lists.newArrayListWithCapacity(xAttrs.size());
org.apache.hadoop.hdfs.server.namenode.ha (10 usages found)
StandbyCheckpointer.java (1 usage found)
doCheckpoint() (1 usage found)
286 List<IOException> ioes = Lists.newArrayList();
TestDNFencing.java (1 usage found)
chooseReplicaToDelete(Collection<DatanodeStorageInfo>, Collection<DatanodeStorageInfo>, List<StorageType>, Map<String, List<DatanodeStorageInfo>>) (1 usage found)
645 List<DatanodeStorageInfo> l = Lists.newArrayList(chooseFrom);
TestEditLogsDuringFailover.java (1 usage found)
testStartup() (1 usage found)
77 List<URI> allDirs = Lists.newArrayList();
TestHASafeMode.java (1 usage found)
testSafeBlockTracking(boolean) (1 usage found)
650 List<FSDataOutputStream> stms = Lists.newArrayList();
TestRequestHedgingProxyProvider.java (1 usage found)
createFactory(ClientProtocol...) (1 usage found)
697 Lists.newArrayList(protos).iterator();
TestStandbyCheckpoints.java (2 usages found)
testBothNodesInStandbyState() (1 usage found)
251 List<File> dirs = Lists.newArrayList();
testStandbyAndObserverState() (1 usage found)
281 List<File> dirs = Lists.newArrayList();
TestStandbyInProgressTail.java (3 usages found)
testDefault() (1 usage found)
111 List<URI> allDirs = Lists.newArrayList();
testSetup() (1 usage found)
176 List<URI> allDirs = Lists.newArrayList();
waitForFileInfo(NameNode, String...) (1 usage found)
472 List<String> remainingFiles = Lists.newArrayList(fileNames);
org.apache.hadoop.hdfs.server.namenode.snapshot (24 usages found)
Snapshot.java (1 usage found)
Root(INodeDirectory) (1 usage found)
152 super(other, false, Lists.newArrayList(
TestAclWithSnapshot.java (21 usages found)
testOriginalAclEnforcedForSnapshotRootAfterChange() (2 usages found)
107 List<AclEntry> aclSpec = Lists.newArrayList(
137 aclSpec = Lists.newArrayList(
testOriginalAclEnforcedForSnapshotContentsAfterChange() (2 usages found)
186 List<AclEntry> aclSpec = Lists.newArrayList(
229 aclSpec = Lists.newArrayList(
testOriginalAclEnforcedForSnapshotRootAfterRemoval() (1 usage found)
290 List<AclEntry> aclSpec = Lists.newArrayList(
testOriginalAclEnforcedForSnapshotContentsAfterRemoval() (1 usage found)
362 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyReadsCurrentState() (2 usages found)
461 List<AclEntry> aclSpec = Lists.newArrayList(
465 aclSpec = Lists.newArrayList(
testRemoveReadsCurrentState() (1 usage found)
487 List<AclEntry> aclSpec = Lists.newArrayList(
testDefaultAclNotCopiedToAccessAclOfNewSnapshot() (1 usage found)
506 List<AclEntry> aclSpec = Lists.newArrayList(
testModifyAclEntriesSnapshotPath() (1 usage found)
539 List<AclEntry> aclSpec = Lists.newArrayList(
testRemoveAclEntriesSnapshotPath() (1 usage found)
549 List<AclEntry> aclSpec = Lists.newArrayList(
testSetAclSnapshotPath() (1 usage found)
575 List<AclEntry> aclSpec = Lists.newArrayList(
testChangeAclExceedsQuota() (2 usages found)
591 List<AclEntry> aclSpec = Lists.newArrayList(
611 aclSpec = Lists.newArrayList(
testRemoveAclExceedsQuota() (2 usages found)
626 List<AclEntry> aclSpec = Lists.newArrayList(
646 aclSpec = Lists.newArrayList(
testDeDuplication() (4 usages found)
664 List<AclEntry> aclSpec = Lists.newArrayList(
740 List<AclEntry> newAcl = Lists.newArrayList(aclEntry(ACCESS, USER,
763 List<AclEntry> newAcl = Lists.newArrayList(aclEntry(ACCESS, USER,
783 List<AclEntry> newAcl = Lists.newArrayList(aclEntry(ACCESS, USER,
TestFileWithSnapshotFeature.java (2 usages found)
testUpdateQuotaAndCollectBlocks() (2 usages found)
87 .thenReturn(Lists.newArrayList(SSD));
89 .thenReturn(Lists.newArrayList(DISK));
org.apache.hadoop.hdfs.server.namenode.top.metrics (1 usage found)
TopMetrics.java (1 usage found)
getTopWindows() (1 usage found)
107 List<TopWindow> windows = Lists.newArrayListWithCapacity
org.apache.hadoop.hdfs.server.namenode.top.window (2 usages found)
RollingWindowManager.java (2 usages found)
TopWindow(int) (1 usage found)
69 this.top = Lists.newArrayList();
Op(String, long) (1 usage found)
96 this.topUsers = Lists.newArrayList();
org.apache.hadoop.hdfs.server.namenode.web.resources (1 usage found)
NamenodeWebHdfsMethods.java (1 usage found)
get(UserGroupInformation, DelegationParam, UserParam, DoAsParam, String, GetOpParam, OffsetParam, ...) (1 usage found)
1264 names = Lists.newArrayListWithCapacity(xattrNames.size());
org.apache.hadoop.hdfs.tools (17 usages found)
TestDFSAdmin.java (13 usages found)
testGetDatanodeInfo() (1 usage found)
236 final List<String> outs = Lists.newArrayList();
testTriggerBlockReport() (1 usage found)
263 final List<String> outs = Lists.newArrayList();
testGetVolumeReport() (1 usage found)
290 final List<String> outs = Lists.newArrayList();
testDFSAdminUnreachableDatanode() (1 usage found)
310 final List<String> outs = Lists.newArrayList();
testDataNodeGetReconfigurableProperties() (2 usages found)
326 final List<String> outs = Lists.newArrayList();
327 final List<String> errs = Lists.newArrayList();
testDataNodeGetReconfigurationStatus(boolean) (2 usages found)
367 final List<String> outs = Lists.newArrayList();
368 final List<String> errs = Lists.newArrayList();
testNameNodeGetReconfigurableProperties() (2 usages found)
421 final List<String> outs = Lists.newArrayList();
422 final List<String> errs = Lists.newArrayList();
testPrintTopology() (1 usage found)
481 final List<String> outs = Lists.newArrayList();
testNameNodeGetReconfigurationStatus() (2 usages found)
520 final List<String> outs = Lists.newArrayList();
521 final List<String> errs = Lists.newArrayList();
TestViewFileSystemOverloadSchemeWithDFSAdmin.java (2 usages found)
assertErrMsg(String, int) (1 usage found)
128 final List<String> errList = Lists.newArrayList();
assertOutMsg(String, int) (1 usage found)
134 final List<String> errList = Lists.newArrayList();
TestViewFileSystemOverloadSchemeWithFSCommands.java (2 usages found)
testDFWithViewFsOverloadScheme() (2 usages found)
142 List<String> mounts = Lists.newArrayList();
157 final List<String> errList = Lists.newArrayList();
org.apache.hadoop.hdfs.tools.offlineImageViewer (8 usages found)
FSImageLoader.java (2 usages found)
load(String) (1 usage found)
129 Lists.newArrayList(summary.getSectionsList());
getXAttrs(String, List<String>, String) (1 usage found)
439 filtered = Lists.newArrayListWithCapacity(names.size());
PBImageTextWriter.java (1 usage found)
visit(RandomAccessFile) (1 usage found)
574 Lists.newArrayList(summary.getSectionsList());
PBImageXmlWriter.java (1 usage found)
visit(RandomAccessFile) (1 usage found)
306 ArrayList<FileSummary.Section> sections = Lists.newArrayList(summary
TestOfflineImageViewer.java (1 usage found)
createOriginalFSImage() (1 usage found)
316 Lists.newArrayList(aclEntry(ACCESS, USER, ALL),
TestOfflineImageViewerForAcl.java (3 usages found)
createOriginalFSImage() (3 usages found)
113 hdfs.setAcl(dir, Lists.newArrayList(
130 hdfs.setAcl(file, Lists.newArrayList(
141 hdfs.setAcl(file, Lists.newArrayList(
org.apache.hadoop.hdfs.web (8 usages found)
JsonUtil.java (1 usage found)
toJsonString(List<XAttr>) (1 usage found)
485 final List<String> names = Lists.newArrayListWithCapacity(xAttrs.size());
JsonUtilClient.java (1 usage found)
toXAttrNames(Map<?, ?>) (1 usage found)
641 Lists.newArrayListWithCapacity(json.keySet().size());
TestJsonUtil.java (4 usages found)
testToAclStatus() (1 usage found)
272 Lists.newArrayList(aclEntry(ACCESS, USER, ALL),
testToJsonFromAclStatus() (1 usage found)
297 Lists.newArrayList(aclEntry(ACCESS, USER,"user1", ALL),
testToJsonFromXAttrs() (1 usage found)
348 List<XAttr> xAttrs = Lists.newArrayList();
testToXAttrMap() (1 usage found)
366 List<XAttr> xAttrs = Lists.newArrayList();
TestURLConnectionFactory.java (1 usage found)
testConnConfiguratior() (1 usage found)
44 final List<HttpURLConnection> conns = Lists.newArrayList();
WebHdfsFileSystem.java (1 usage found)
getAuthParameters(Op) (1 usage found)
591 List<Param<?,?>> authParams = Lists.newArrayList();
org.apache.hadoop.http (2 usages found)
HttpServer2.java (2 usages found)
176 private final List<ServerConnector> listeners = Lists.newArrayList();
208 private ArrayList<URI> endpoints = Lists.newArrayList();
org.apache.hadoop.lib.wsrs (2 usages found)
Parameters.java (1 usage found)
getValues(String, Class<T>) (1 usage found)
71 List<V> values = Lists.newArrayList();
ParametersProvider.java (1 usage found)
getValue(HttpContext) (1 usage found)
85 List<Param<?>> paramList = Lists.newArrayList();
org.apache.hadoop.mapred (3 usages found)
TestFileInputFormat.java (3 usages found)
testListStatusSimple() (1 usage found)
158 .verifyFileStatuses(expectedPaths, Lists.newArrayList(statuses),
testListStatusNestedRecursive() (1 usage found)
175 .verifyFileStatuses(expectedPaths, Lists.newArrayList(statuses),
testListStatusNestedNonRecursive() (1 usage found)
192 .verifyFileStatuses(expectedPaths, Lists.newArrayList(statuses),
org.apache.hadoop.mapred.nativetask.kvtest (2 usages found)
KVTest.java (2 usages found)
parseClassNames(String) (1 usage found)
60 List<Class<?>> ret = Lists.newArrayList();
data() (1 usage found)
90 List<Class<?>[]> pairs = Lists.newArrayList();
org.apache.hadoop.mapred.uploader (1 usage found)
TestFrameworkUploader.java (1 usage found)
testNativeIO() (1 usage found)
439 IOUtils.writeLines(Lists.newArrayList("a", "b"), null, os);
org.apache.hadoop.mapreduce.counters (1 usage found)
CounterGroupFactory.java (1 usage found)
51 private static final List<String> i2s = Lists.newArrayList();
org.apache.hadoop.mapreduce.lib.input (9 usages found)
FileInputFormat.java (1 usage found)
listStatus(JobContext) (1 usage found)
292 result = Lists.newArrayList(locatedFiles);
TestFileInputFormat.java (8 usages found)
testNumInputFilesRecursively() (2 usages found)
106 verifySplits(Lists.newArrayList("test:/a1/a2/file2", "test:/a1/a2/file3",
114 verifySplits(Lists.newArrayList("test:/a1/a2/file2", "test:/a1/a2/file3",
testNumInputFilesWithoutRecursively() (1 usage found)
126 verifySplits(Lists.newArrayList("test:/a1/a2", "test:/a1/file1"), splits);
testNumInputFilesIgnoreDirs() (1 usage found)
138 verifySplits(Lists.newArrayList("test:/a1/file1"), splits);
configureTestSimple(Configuration, FileSystem) (1 usage found)
306 List<Path> expectedPaths = Lists.newArrayList(in1File1, in1File2, in2File1,
configureTestNestedRecursive(Configuration, FileSystem) (1 usage found)
340 List<Path> expectedPaths = Lists.newArrayList(inFile1, dir1File1,
configureTestNestedNonRecursive(Configuration, FileSystem) (1 usage found)
374 List<Path> expectedPaths = Lists.newArrayList(inFile1, inDir1, inDir2);
configureTestErrorOnNonExistantDir(Configuration, FileSystem) (1 usage found)
395 List<Path> expectedPaths = Lists.newArrayList();
org.apache.hadoop.mapreduce.util (1 usage found)
CountersStrings.java (1 usage found)
toEscapedCompactString(G) (1 usage found)
103 List<String> escapedStrs = Lists.newArrayList();
org.apache.hadoop.mapreduce.v2.app (1 usage found)
MockJobs.java (1 usage found)
newTaskAttempt(TaskId, int) (1 usage found)
330 return Lists.newArrayList(report.getDiagnosticInfo());
org.apache.hadoop.maven.plugin.resourcegz (1 usage found)
ResourceGzMojo.java (1 usage found)
execute() (1 usage found)
68 List<String> exts = Lists.newArrayList(extensions.split(","));
org.apache.hadoop.metrics2.impl (8 usages found)
MBeanInfoBuilder.java (1 usage found)
MBeanInfoBuilder(String, String) (1 usage found)
45 attrs = Lists.newArrayList();
MetricsCollectorImpl.java (2 usages found)
getRecords() (1 usage found)
57 List<MetricsRecordImpl> recs = Lists.newArrayListWithCapacity(rbs.size());
38 private final List<MetricsRecordBuilderImpl> rbs = Lists.newArrayList();
MetricsRecordBuilderImpl.java (2 usages found)
MetricsRecordBuilderImpl(MetricsCollector, MetricsInfo, MetricsFilter, MetricsFilter, boolean) (2 usages found)
64 metrics = Lists.newArrayList();
65 tags = Lists.newArrayList();
MetricsSystemImpl.java (2 usages found)
MetricsSystemImpl(String) (2 usages found)
126 callbacks = Lists.newArrayList();
128 injectedTags = Lists.newArrayList();
TestKafkaMetrics.java (1 usage found)
testPutMetrics() (1 usage found)
112 Iterable<AbstractMetric> metrics = Lists.newArrayList(metric);
org.apache.hadoop.metrics2.util (1 usage found)
Servers.java (1 usage found)
parse(String, int) (1 usage found)
52 List<InetSocketAddress> result = Lists.newArrayList();
org.apache.hadoop.net (1 usage found)
NetworkTopology.java (1 usage found)
sortByDistance(Node, T[], int, Consumer<List<T>>, boolean) (1 usage found)
976 list = Lists.newArrayListWithExpectedSize(1);
org.apache.hadoop.registry.client.impl.zk (1 usage found)
RegistrySecurity.java (1 usage found)
splitAclPairs(String, String) (1 usage found)
530 List<String> list = Lists.newArrayList(
org.apache.hadoop.tools (3 usages found)
CopyListingFileStatus.java (1 usage found)
readFields(DataInput) (1 usage found)
350 aclEntries = Lists.newArrayListWithCapacity(aclEntriesSize);
SimpleCopyListing.java (2 usages found)
doBuildListingWithSnapshotDiff(Writer, DistCpContext) (1 usage found)
275 List<FileStatusInfo> fileStatuses = Lists.newArrayList();
doBuildListing(Writer, DistCpContext) (1 usage found)
342 List<FileStatusInfo> statusList = Lists.newArrayList();
org.apache.hadoop.tools.dynamometer (3 usages found)
ApplicationMaster.java (1 usage found)
getContainerStartCommand() (1 usage found)
810 return Lists.newArrayList(Joiner.on(" ").join(vargs));
Client.java (2 usages found)
getAMCommand() (1 usage found)
729 return Lists.newArrayList(Joiner.on(" ").join(vargs));
setupRemoteResource(ApplicationId, DynoResource, Map<String, String>, String...) (1 usage found)
803 filesToZip = Lists.newArrayList(childFiles);
org.apache.hadoop.tools.dynamometer.workloadgenerator (1 usage found)
CreateFileMapper.java (1 usage found)
getConfigDescriptions() (1 usage found)
82 return Lists.newArrayList(
org.apache.hadoop.tools.dynamometer.workloadgenerator.audit (1 usage found)
AuditReplayMapper.java (1 usage found)
getConfigDescriptions() (1 usage found)
185 return Lists.newArrayList(
org.apache.hadoop.tools.util (2 usages found)
TestDistCpUtils.java (2 usages found)
testPreserveAclsforDefaultACL() (2 usages found)
303 List<AclEntry> acls = Lists.newArrayList(
307 final List<AclEntry> acls1 = Lists.newArrayList(aclEntry(ACCESS, USER, ALL),
org.apache.hadoop.util (9 usages found)
ChunkedArrayList.java (2 usages found)
addChunk(int) (1 usage found)
159 lastChunk = Lists.newArrayListWithCapacity(capacity);
53 private final List<List<T>> chunks = Lists.newArrayList();
JvmPauseMonitor.java (2 usages found)
formatMessage(long, Map<String, GcTimes>, Map<String, GcTimes>) (1 usage found)
128 List<String> gcDiffs = Lists.newArrayList();
main(String[]) (1 usage found)
226 List<String> list = Lists.newArrayList();
TestApplicationClassLoader.java (1 usage found)
classes(String) (1 usage found)
122 return Lists.newArrayList(Splitter.on(',').split(classes));
ZKUtil.java (4 usages found)
parseACLs(String) (2 usages found)
97 List<ACL> acl = Lists.newArrayList();
102 List<String> aclComps = Lists.newArrayList(
parseAuth(String) (2 usages found)
135 List<ZKAuthInfo> ret = Lists.newArrayList();
140 List<String> authComps = Lists.newArrayList(
org.apache.hadoop.yarn.api (1 usage found)
BasePBImplRecordsTest.java (1 usage found)
genTypeValue(Type) (1 usage found)
113 ret = Lists.newArrayList(genTypeValue(params[0]));
org.apache.hadoop.yarn.client.api.impl (1 usage found)
NMClientImpl.java (1 usage found)
getLocalizationStatuses(ContainerId, NodeId) (1 usage found)
504 List<ContainerId> containerIds = Lists.newArrayList(containerId);
org.apache.hadoop.yarn.client.cli (1 usage found)
NodeAttributesCLI.java (1 usage found)
buildNodeLabelsListFromStr(String, boolean, String) (1 usage found)
690 return Lists.newArrayList(nodeToAttributesMap.values());
org.apache.hadoop.yarn.server.nodemanager (1 usage found)
TestContainerExecutor.java (1 usage found)
testCleanupBeforeLaunch() (1 usage found)
225 Lists.newArrayList(linkName.toFile().getAbsolutePath()));
org.apache.hadoop.yarn.server.nodemanager.containermanager (4 usages found)
TestContainerManager.java (4 usages found)
testGetLocalizationStatuses() (2 usages found)
2221 Lists.newArrayList(containerId));
2239 StopContainersRequest.newInstance(Lists.newArrayList(containerId));
testGetLocalizationStatusesMultiContainers() (2 usages found)
2284 Lists.newArrayList(container1, container2));
2306 StopContainersRequest.newInstance(Lists.newArrayList(container1,
org.apache.hadoop.yarn.server.nodemanager.containermanager.launcher (2 usages found)
TestContainerLaunch.java (2 usages found)
testContainerLaunchOnConfigurationError() (1 usage found)
1797 when(clc.getCommands()).thenReturn(Lists.newArrayList());
testFilesAndEnv(boolean) (1 usage found)
2497 when(clc.getCommands()).thenReturn(Lists.newArrayList());
org.apache.hadoop.yarn.server.nodemanager.containermanager.linux.resources.gpu (2 usages found)
TestGpuResourceAllocator.java (2 usages found)
createMockContainers(int, int) (1 usage found)
125 List<Container> containers = Lists.newArrayList();
testCreateLotsOfContainersVerifyGpuAssignmentsAreCorrect() (1 usage found)
410 List<GpuAllocation> allocations = Lists.newArrayList();
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.com.nec (4 usages found)
TestNECVEPlugin.java (2 usages found)
testParseMultipleDevices() (1 usage found)
162 List<Device> devicesList = Lists.newArrayList(devices);
testUnparseableLineSkipped() (1 usage found)
235 List<Device> devicesList = Lists.newArrayList(devices);
TestVEDeviceDiscoverer.java (2 usages found)
testDetectMultipleOnlineDevices() (1 usage found)
124 List<Device> devicesList = Lists.newArrayList(devices);
testDeviceNumberFromMajorAndMinor() (1 usage found)
201 List<Device> devicesList = Lists.newArrayList(devices);
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.fpga (1 usage found)
TestIntelFpgaOpenclPlugin.java (1 usage found)
createResources() (1 usage found)
78 Lists.newArrayList("/symlinked/fpga.aocx"));
org.apache.hadoop.yarn.server.nodemanager.containermanager.resourceplugin.gpu (2 usages found)
GpuDiscoverer.java (1 usage found)
parseGpuDevicesFromUserDefinedValues() (1 usage found)
207 List<GpuDevice> gpuDevices = Lists.newArrayList();
TestGpuResourcePlugin.java (1 usage found)
createMockDiscoverer() (1 usage found)
42 List<PerGpuDeviceInformation> gpus = Lists.newArrayList();
org.apache.hadoop.yarn.server.resourcemanager (3 usages found)
MockNodes.java (2 usages found)
newNodes(int, int, Resource) (1 usage found)
61 List<RMNode> list = Lists.newArrayList();
deactivatedNodes(int, int, Resource) (1 usage found)
80 List<RMNode> list = Lists.newArrayList();
TestAppManager.java (1 usage found)
newRMApps(int, long, RMAppState) (1 usage found)
141 List<RMApp> list = Lists.newArrayList();
org.apache.hadoop.yarn.server.resourcemanager.applicationsmanager (3 usages found)
MockAsm.java (1 usage found)
newApplications(int) (1 usage found)
387 List<RMApp> list = Lists.newArrayList();
TestAMRestart.java (2 usages found)
testContainersFromPreviousAttemptsWithRMRestart() (2 usages found)
1174 nm1.registerNode(Lists.newArrayList(container2Status), null);
1215 nm2.registerNode(Lists.newArrayList(container3Status), null);
org.apache.hadoop.yarn.server.resourcemanager.placement (2 usages found)
TestUserGroupMappingPlacementRule.java (2 usages found)
63 private List<String> queuePaths = Lists.newArrayList();
64 private List<String> managedParentQueues = Lists.newArrayList();
org.apache.hadoop.yarn.server.resourcemanager.recovery (16 usages found)
TestZKRMStateStore.java (16 usages found)
testAppNodeSplit() (6 usages found)
1026 Lists.newArrayList(attemptId1, attemptId2), Lists.newArrayList(-1000,
1027 -1000), Lists.newArrayList((FinalApplicationStatus) null, null));
1047 Lists.newArrayList(dummyAttemptId), Lists.newArrayList(111),
1048 Lists.newArrayList(FinalApplicationStatus.SUCCEEDED));
1050 Lists.newArrayList(attemptId1, attemptId2),
1051 Lists.newArrayList(-1000, 100), Lists.newArrayList(null,
testAppNodeSplitChangeAcrossRestarts() (10 usages found)
1107 Lists.newArrayList(attemptId1, attemptId2), Lists.newArrayList(-1000,
1108 -1000), Lists.newArrayList((FinalApplicationStatus) null, null));
1130 Lists.newArrayList(attemptId1, attemptId2), Lists.newArrayList(-1000,
1131 100), Lists.newArrayList(null, FinalApplicationStatus.SUCCEEDED));
1146 Lists.newArrayList(dummyAttemptId), Lists.newArrayList(111),
1147 Lists.newArrayList(FinalApplicationStatus.SUCCEEDED));
1151 Lists.newArrayList(attemptId11), Lists.newArrayList(-1000),
1152 Lists.newArrayList((FinalApplicationStatus) null));
1154 Lists.newArrayList(attemptId2), Lists.newArrayList(100),
1155 Lists.newArrayList(FinalApplicationStatus.SUCCEEDED));
org.apache.hadoop.yarn.server.resourcemanager.rmapp (1 usage found)
TestRMAppTransitions.java (1 usage found)
196 List<RMAppManagerEvent> events = Lists.newArrayList();
org.apache.hadoop.yarn.server.resourcemanager.scheduler (5 usages found)
SchedulerUtils.java (1 usage found)
validateResourceRequestsAgainstQueueMaxResource(ResourceRequest, Resource) (1 usage found)
428 List<ResourceInformation> invalidResources = Lists.newArrayList();
TestAbstractYarnScheduler.java (4 usages found)
testContainerReleaseWithAllocationTags() (3 usages found)
482 .schedulingRequests(Lists.newArrayList(sr, sr1)).build();
516 am1.allocate(new ArrayList<>(), Lists.newArrayList(cid));
529 nm1.nodeHeartbeat(Lists.newArrayList(cs), true);
testNodeRemovedWithAllocationTags() (1 usage found)
583 .schedulingRequests(Lists.newArrayList(sr)).build();
org.apache.hadoop.yarn.server.resourcemanager.scheduler.activities (1 usage found)
ActivitiesManager.java (1 usage found)
getAppActivitiesInfo(ApplicationId, Set<Integer>, Set<Long>, ActivitiesGroupBy, int, boolean, double) (1 usage found)
153 allocations = Lists.newArrayList(summaryAppAllocation);
org.apache.hadoop.yarn.server.resourcemanager.scheduler.constraint.processor (1 usage found)
PlacementConstraintProcessor.java (1 usage found)
addToRetryList(SchedulingResponse, int, List<BatchedRequests>) (1 usage found)
341 Lists.newArrayList(schedulerResponse.getSchedulingRequest()),
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair (7 usages found)
FairScheduler.java (1 usage found)
validateResourceRequests(List<ResourceRequest>, FSLeafQueue) (1 usage found)
977 List<MaxResourceValidationResult> validationResults = Lists.newArrayList();
FairSchedulerConfiguration.java (1 usage found)
findOldStyleResourcesInSpaceSeparatedInput(String) (1 usage found)
627 List<String> resources = Lists.newArrayList();
FairSchedulerTestBase.java (1 usage found)
createSchedulingRequest(int, int, String, String, int, int) (1 usage found)
173 return createSchedulingRequest(Lists.newArrayList(request), queueId,
TestFairScheduler.java (4 usages found)
testAppRejectedToQueueWithZeroCapacityOfResource(String) (2 usages found)
5363 final List<Event> recordedEvents = Lists.newArrayList();
5387 Resource.newInstance(GB, 1), Lists.newArrayList(amReqs));
testSchedulingRejectedToQueueWithZeroCapacityOfMemory() (1 usage found)
5438 Lists.newArrayList(invalidRequest, validRequest));
testSchedulingRejectedToQueueWithZeroCapacityOfVcores() (1 usage found)
5461 Lists.newArrayList(invalidRequest, validRequest));
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.allocationfile (2 usages found)
AllocationFileQueue.java (1 usage found)
161 private final List<AllocationFileQueue> subQueues = Lists.newArrayList();
AllocationFileQueuePlacementPolicy.java (1 usage found)
31 private List<AllocationFileQueuePlacementRule> rules = Lists.newArrayList();
org.apache.hadoop.yarn.server.resourcemanager.scheduler.fair.converter (4 usages found)
TestFSConfigToCSConfigArgumentHandler.java (3 usages found)
getDefaultArguments() (1 usage found)
118 return Lists.newArrayList("-y", FSConfigConverterTestCommons.YARN_SITE_XML,
getDefaultArgumentsWithNoOutput() (1 usage found)
123 return Lists.newArrayList("-y", FSConfigConverterTestCommons.YARN_SITE_XML);
getArgumentsAsArray(String...) (1 usage found)
140 List<String> result = Lists.newArrayList();
TestQueuePlacementConverter.java (1 usage found)
initPlacementManagerMock(PlacementRule...) (1 usage found)
237 List<PlacementRule> listOfRules = Lists.newArrayList(rules);
org.apache.hadoop.yarn.server.resourcemanager.webapp (1 usage found)
ActivitiesTestUtils.java (1 usage found)
getSubNodesFromJson(JSONObject, String...) (1 usage found)
246 List<JSONObject> results = Lists.newArrayList(json);
org.apache.hadoop.yarn.server.resourcemanager.webapp.helper (2 usages found)
ResourceRequestsJsonVerifications.java (1 usage found)
216 private List<String> expectedCustomResourceTypes = Lists.newArrayList();
ResourceRequestsXmlVerifications.java (1 usage found)
180 private List<String> expectedCustomResourceTypes = Lists.newArrayList();
org.apache.hadoop.yarn.server.webproxy (2 usages found)
TestProxyUriUtils.java (2 usages found)
testGetProxyUriFromPluginsReturnsNullIfNoPlugins() (1 usage found)
97 Lists.newArrayListWithExpectedSize(0);
testGetProxyUriFromPluginsReturnsValidUriWhenAble() (1 usage found)
106 Lists.newArrayListWithExpectedSize(2);
org.apache.hadoop.yarn.service (4 usages found)
MockServiceAM.java (1 usage found)
addContainerStatus(Container, ContainerState, String) (1 usage found)
430 status.setIPs(Lists.newArrayList(host));
TestDefaultUpgradeComponentsFinder.java (2 usages found)
testChangeInConfigFileProperty() (2 usages found)
100 Configuration conf = new Configuration().files(Lists.newArrayList(file));
112 conf = new Configuration().files(Lists.newArrayList(file));
TestYarnNativeServices.java (1 usage found)
testCancelUpgrade() (1 usage found)
492 client.actionUpgrade(service, Lists.newArrayList(container));
org.apache.hadoop.yarn.service.client (3 usages found)
TestApiServiceClient.java (2 usages found)
testInstancesUpgrade() (1 usage found)
316 int result = asc.actionUpgradeInstances(appName, Lists.newArrayList(
testComponentsUpgrade() (1 usage found)
328 int result = asc.actionUpgradeComponents(appName, Lists.newArrayList(
TestServiceClient.java (1 usage found)
testGetCompInstances() (1 usage found)
171 service.getName(), Lists.newArrayList("compa"), "v1", null);
org.apache.hadoop.yarn.service.component.instance (3 usages found)
TestComponentInstance.java (3 usages found)
testUpdateLocalizationStatuses() (3 usages found)
288 Lists.newArrayList(configFile1)));
298 instance.updateLocalizationStatuses(Lists.newArrayList(status));
313 instance.updateLocalizationStatuses(Lists.newArrayList(status));
org.apache.hadoop.yarn.service.provider (2 usages found)
TestAbstractProviderService.java (2 usages found)
testBuildContainerLaunchCommand() (1 usage found)
94 Assert.assertEquals("commands", Lists.newArrayList(clc.getLaunchCommand()),
testBuildContainerLaunchCommandWithSpace() (1 usage found)
114 Lists.newArrayList("ls,-l, space"), launcher.getCommands());
org.apache.hadoop.yarn.service.utils (4 usages found)
TestFilterUtils.java (4 usages found)
testFilterWithComp() (1 usage found)
57 .addAllComponentNames(Lists.newArrayList("compa")).build();
testFilterWithVersion() (1 usage found)
80 reqBuilder.addAllComponentNames(Lists.newArrayList("compa"))
testFilterWithState() (2 usages found)
95 reqBuilder.addAllContainerStates(Lists.newArrayList(
105 reqBuilder.addAllContainerStates(Lists.newArrayList(
org.apache.hadoop.yarn.service.webapp (1 usage found)
ApiServer.java (1 usage found)
updateComponentInstance(HttpServletRequest, String, String, String, Container) (1 usage found)
538 Lists.newArrayList(liveContainer));
org.apache.hadoop.yarn.util.resource (1 usage found)
CustomResourceTypesConfigurationProvider.java (1 usage found)
createCustomResourceTypes(Map<String, String>) (1 usage found)
110 List<String> resourceNames = Lists.newArrayList(
org.apache.hadoop.yarn.webapp (2 usages found)
ResponseInfo.java (1 usage found)
58 final List<Item> items = Lists.newArrayList();
WebApp.java (1 usage found)
parseRoute(String) (1 usage found)
243 List<String> result = Lists.newArrayList();
org.apache.hadoop.yarn.webapp.view (2 usages found)
JQueryUI.java (1 usage found)
render(Block) (1 usage found)
80 List<String> list = Lists.newArrayList();
TwoColumnLayout.java (1 usage found)
setTableStyles(HTML<__>, String, String...) (1 usage found)
125 List<String> styles = Lists.newArrayList();
patches (4 usages found)
HADOOP-17101.001.patch (2 usages found)
94 - List<RemoteEditLog> allLogs = Lists.newArrayList();
115 - List<RemoteEditLog> logs = Lists.newArrayList();
HADOOP-17101.002.patch (2 usages found)
328 - List<RemoteEditLog> allLogs = Lists.newArrayList();
345 - List<RemoteEditLog> logs = Lists.newArrayList();
{code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
---------------------------------------------------------------------
To unsubscribe, e-mail: common-issues-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-issues-help@hadoop.apache.org