/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/ |
H A D | TestAMRMClientContainerRequest.java | 50 ContainerRequest request = in testFillInRacks() 72 ContainerRequest nodeLevelRequest = in testDisableLocalityRelaxation() 139 ContainerRequest request1 = in testDifferentLocalityRelaxationSamePriority() 143 ContainerRequest request2 = in testDifferentLocalityRelaxationSamePriority() 160 ContainerRequest request1 = in testInvalidValidWhenOldRemoved() 167 ContainerRequest request2 = in testInvalidValidWhenOldRemoved() 174 ContainerRequest request3 = in testInvalidValidWhenOldRemoved() 181 ContainerRequest request4 = in testInvalidValidWhenOldRemoved() 199 ContainerRequest request1 = in testLocalityRelaxationDifferentLevels() 203 ContainerRequest request2 = in testLocalityRelaxationDifferentLevels() [all …]
|
H A D | TestAMRMClient.java | 244 ContainerRequest storedContainer1 = in testAMRMClientMatchingFit() 246 ContainerRequest storedContainer2 = in testAMRMClientMatchingFit() 248 ContainerRequest storedContainer3 = in testAMRMClientMatchingFit() 250 ContainerRequest storedContainer4 = in testAMRMClientMatchingFit() 252 ContainerRequest storedContainer5 = in testAMRMClientMatchingFit() 254 ContainerRequest storedContainer6 = in testAMRMClientMatchingFit() 256 ContainerRequest storedContainer7 = in testAMRMClientMatchingFit() 268 ContainerRequest storedRequest; in testAMRMClientMatchingFit() 352 ContainerRequest storedContainer1 = in testAMRMClientMatchingFitInferredRack() 358 ContainerRequest storedRequest; in testAMRMClientMatchingFitInferredRack() [all …]
|
H A D | TestAMRMClientOnRMRestart.java | 45 import org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest; 136 AMRMClient<ContainerRequest> amClient = new MyAMRMClientImpl(rm1); in testAMRMClientResendsRequestsOnRMRestart() 142 ContainerRequest cRequest1 = createReq(1, 1024, new String[] { "h1" }); in testAMRMClientResendsRequestsOnRMRestart() 145 ContainerRequest cRequest2 = in testAMRMClientResendsRequestsOnRMRestart() 194 ContainerRequest cRequest3 = createReq(1, 1024, new String[] { "h1" }); in testAMRMClientResendsRequestsOnRMRestart() 244 ContainerRequest cRequest4 = in testAMRMClientResendsRequestsOnRMRestart() 262 ContainerRequest cRequest5 = in testAMRMClientResendsRequestsOnRMRestart() 334 AMRMClient<ContainerRequest> amClient = new MyAMRMClientImpl(rm1); in testAMRMClientForUnregisterAMOnRMRestart() 416 AMRMClient<ContainerRequest> amClient = new MyAMRMClientImpl(rm1); in testAMRMClientOnAMRMTokenRollOverOnRMRestart() 601 AMRMClientImpl<ContainerRequest> { [all …]
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/testcontainers/testcontainers-go/ |
H A D | docker_test.go | 37 ContainerRequest: ContainerRequest{ 104 ContainerRequest: ContainerRequest{ 143 ContainerRequest: ContainerRequest{ 162 ContainerRequest: ContainerRequest{ 193 ContainerRequest: ContainerRequest{ 225 ContainerRequest: ContainerRequest{ 256 ContainerRequest: ContainerRequest{ 281 ContainerRequest: ContainerRequest{ 317 ContainerRequest: ContainerRequest{ 352 ContainerRequest: ContainerRequest{ [all …]
|
H A D | container_test.go | 23 ContainerRequest ContainerRequest 30 ContainerRequest: ContainerRequest{ 40 ContainerRequest: ContainerRequest{ 47 ContainerRequest: ContainerRequest{ 76 ContainerRequest ContainerRequest 83 ContainerRequest: ContainerRequest{}, 88 ContainerRequest: ContainerRequest{ 95 ContainerRequest: ContainerRequest{ 274 req := ContainerRequest{ 281 ContainerRequest: req, [all …]
|
H A D | container.go | 27 …CreateContainer(context.Context, ContainerRequest) (Container, error) // create a container withou… argument 28 …RunContainer(context.Context, ContainerRequest) (Container, error) // create a container and st… argument 71 type ContainerRequest struct { struct 119 func (c *ContainerRequest) Validate() error { argument 138 func (c *ContainerRequest) GetContext() (io.Reader, error) { argument 152 func (c *ContainerRequest) GetDockerfile() string { argument 161 func (c *ContainerRequest) ShouldBuildImage() bool { argument 165 func (c *ContainerRequest) validateContextAndImage() error { argument 173 func (c *ContainerRequest) validateContextOrImageIsSpecified() error { argument
|
H A D | network_test.go | 24 ContainerRequest: ContainerRequest{ 51 dbContainerRequest := ContainerRequest{ 71 ContainerRequest: dbContainerRequest, 86 amqpRequest := ContainerRequest{ 95 ContainerRequest: amqpRequest,
|
H A D | logconsumer_test.go | 38 req := ContainerRequest{ 48 ContainerRequest: req, 115 req := ContainerRequest{ 125 ContainerRequest: req,
|
/dports/databases/timescaledb-backup/timescaledb-backup-0.1.1/vendor/github.com/testcontainers/testcontainers-go/ |
H A D | container_test.go | 22 ContainerRequest ContainerRequest 29 ContainerRequest: ContainerRequest{ 39 ContainerRequest: ContainerRequest{ 46 ContainerRequest: ContainerRequest{ 75 ContainerRequest ContainerRequest 82 ContainerRequest: ContainerRequest{}, 87 ContainerRequest: ContainerRequest{ 94 ContainerRequest: ContainerRequest{ 253 ContainerRequest: req, 273 req := ContainerRequest{ [all …]
|
H A D | docker_test.go | 33 ContainerRequest: ContainerRequest{ 99 ContainerRequest: ContainerRequest{ 128 ContainerRequest: ContainerRequest{ 147 ContainerRequest: ContainerRequest{ 178 ContainerRequest: ContainerRequest{ 210 ContainerRequest: ContainerRequest{ 241 ContainerRequest: ContainerRequest{ 266 ContainerRequest: ContainerRequest{ 302 ContainerRequest: ContainerRequest{ 337 ContainerRequest: ContainerRequest{ [all …]
|
H A D | container.go | 25 …CreateContainer(context.Context, ContainerRequest) (Container, error) // create a container withou… argument 26 …RunContainer(context.Context, ContainerRequest) (Container, error) // create a container and st… argument 66 type ContainerRequest struct { struct 111 func (c *ContainerRequest) Validate() error { argument 130 func (c *ContainerRequest) GetContext() (io.Reader, error) { argument 144 func (c *ContainerRequest) GetDockerfile() string { argument 153 func (c *ContainerRequest) ShouldBuildImage() bool { argument 157 func (c *ContainerRequest) validateContextAndImage() error { argument 165 func (c *ContainerRequest) validateContexOrImageIsSpecified() error { argument
|
H A D | logconsumer_test.go | 38 req := ContainerRequest{ 48 ContainerRequest: req, 115 req := ContainerRequest{ 125 ContainerRequest: req,
|
H A D | network_test.go | 10 ContainerRequest: ContainerRequest{
|
H A D | generic.go | 11 ContainerRequest // embedded request for provider anonMember 23 c, err := provider.CreateContainer(ctx, req.ContainerRequest)
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/main/java/org/apache/hadoop/mapreduce/v2/app/rm/ |
H A D | RMContainerAllocator.java | 140 new LinkedList<ContainerRequest>(); 903 ContainerRequest req = null; in remove() 918 ContainerRequest removeReduce() { in removeReduce() 930 ContainerRequest request = null; in addMap() 966 void addReduce(ContainerRequest req) { in addReduce() 1039 ContainerRequest toBeReplacedReq = in assign() 1044 ContainerRequest newReq = in assign() 1105 ContainerRequest assigned = null; in assignWithoutLocality() 1138 ContainerRequest toBeReplaced = null; in getContainerReqToReplace() 1176 ContainerRequest assigned = null; in assignToFailedMap() [all …]
|
H A D | RMContainerRequestor.java | 117 static class ContainerRequest { class in RMContainerRequestor 130 public ContainerRequest(ContainerRequestEvent event, Priority priority) { in ContainerRequest() method in RMContainerRequestor.ContainerRequest 135 public ContainerRequest(ContainerRequestEvent event, Priority priority, in ContainerRequest() method in RMContainerRequestor.ContainerRequest 141 public ContainerRequest(TaskAttemptId attemptID, in ContainerRequest() method in RMContainerRequestor.ContainerRequest 148 public ContainerRequest(TaskAttemptId attemptID, in ContainerRequest() method in RMContainerRequestor.ContainerRequest 388 protected void addContainerReq(ContainerRequest req) { in addContainerReq() 406 protected void decContainerReq(ContainerRequest req) { in decContainerReq() 527 protected ContainerRequest getFilteredContainerRequest(ContainerRequest orig) { in getFilteredContainerRequest() 535 ContainerRequest newReq = new ContainerRequest(orig.attemptID, orig.capability, in getFilteredContainerRequest()
|
/dports/devel/spark/spark-2.1.1/yarn/src/main/scala/org/apache/spark/deploy/yarn/ |
H A D | YarnAllocator.scala | 31 import org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest 64 amClient: AMRMClient[ContainerRequest], 150 Some(classOf[ContainerRequest].getConstructor(classOf[Resource], 327 val newLocalityRequests = new mutable.ArrayBuffer[ContainerRequest] 378 private def hostStr(request: ContainerRequest): String = { 392 racks: Array[String]): ContainerRequest = { 684 pendingAllocations: Seq[ContainerRequest] 685 ): (Seq[ContainerRequest], Seq[ContainerRequest], Seq[ContainerRequest]) = { 686 val localityMatched = ArrayBuffer[ContainerRequest]() 687 val localityUnMatched = ArrayBuffer[ContainerRequest]() [all …]
|
H A D | LocalityPreferredContainerPlacementStrategy.scala | 25 import org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest 107 localityMatchedPendingAllocations: Seq[ContainerRequest] 179 localityMatchedPendingAllocations: Seq[ContainerRequest] 210 localityMatchedPendingAllocations: Seq[ContainerRequest]): Map[String, Double] = {
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/async/impl/ |
H A D | TestAMRMClientAsync.java | 52 import org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest; 117 AMRMClientAsync<ContainerRequest> asyncClient = in testAMRMClientAsync() 181 AMRMClient<ContainerRequest> client = mock(AMRMClientImpl.class); 184 AMRMClientAsync<ContainerRequest> asyncClient = 212 AMRMClient<ContainerRequest> client = mock(AMRMClientImpl.class); 219 AMRMClientAsync<ContainerRequest> asyncClient = 237 AMRMClient<ContainerRequest> client = mock(AMRMClientImpl.class); 241 AMRMClientAsync<ContainerRequest> asyncClient = 280 AMRMClientAsync<ContainerRequest> asyncClient = 314 AMRMClientAsync<ContainerRequest> asyncClient = [all …]
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/ |
H A D | AMRMClient.java | 47 public abstract class AMRMClient<T extends AMRMClient.ContainerRequest> extends 61 public static <T extends ContainerRequest> AMRMClient<T> createAMRMClient() { in createAMRMClient() 102 public static class ContainerRequest { class in AMRMClient 126 public ContainerRequest(Resource capability, String[] nodes, in ContainerRequest() method in AMRMClient.ContainerRequest 149 public ContainerRequest(Resource capability, String[] nodes, in ContainerRequest() method in AMRMClient.ContainerRequest 175 public ContainerRequest(Resource capability, String[] nodes, in ContainerRequest() method in AMRMClient.ContainerRequest
|
/dports/net-mgmt/promscale/promscale-0.6.2/vendor/github.com/testcontainers/testcontainers-go/wait/ |
H A D | http_test.go | 25 req := testcontainers.ContainerRequest{ 32 ContainerRequest: req, 65 dockerReq := testcontainers.ContainerRequest{ 80 testcontainers.GenericContainerRequest{ContainerRequest: dockerReq, Started: true})
|
/dports/devel/hadoop/hadoop-1.2.1/src/hdfs/org/apache/hadoop/hdfs/web/ |
H A D | ParamFilter.java | 27 import com.sun.jersey.spi.container.ContainerRequest; 40 public ContainerRequest filter(final ContainerRequest request) {
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-hdfs-project/hadoop-hdfs/src/main/java/org/apache/hadoop/hdfs/web/ |
H A D | ParamFilter.java | 27 import com.sun.jersey.spi.container.ContainerRequest; 41 public ContainerRequest filter(final ContainerRequest request) {
|
/dports/misc/py-tvm/incubator-tvm-0.6.1/3rdparty/dmlc-core/tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ |
H A D | TaskRecord.java | 4 import org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest; 17 public ContainerRequest containerRequest = null;
|
/dports/devel/dmlc-core/dmlc-core-0.3-123-gb3a4c71/tracker/yarn/src/main/java/org/apache/hadoop/yarn/dmlc/ |
H A D | TaskRecord.java | 4 import org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest; 17 public ContainerRequest containerRequest = null;
|