Home
last modified time | relevance | path

Searched refs:ContainerRequest (Results 1 – 25 of 52) sorted by relevance

123

/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 DTestAMRMClientContainerRequest.java50 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 DTestAMRMClient.java244 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 DTestAMRMClientOnRMRestart.java45 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 Ddocker_test.go37 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 Dcontainer_test.go23 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 Dcontainer.go27 …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 Dnetwork_test.go24 ContainerRequest: ContainerRequest{
51 dbContainerRequest := ContainerRequest{
71 ContainerRequest: dbContainerRequest,
86 amqpRequest := ContainerRequest{
95 ContainerRequest: amqpRequest,
H A Dlogconsumer_test.go38 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 Dcontainer_test.go22 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 Ddocker_test.go33 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 Dcontainer.go25 …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 Dlogconsumer_test.go38 req := ContainerRequest{
48 ContainerRequest: req,
115 req := ContainerRequest{
125 ContainerRequest: req,
H A Dnetwork_test.go10 ContainerRequest: ContainerRequest{
H A Dgeneric.go11 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 DRMContainerAllocator.java140 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 DRMContainerRequestor.java117 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 DYarnAllocator.scala31 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 DLocalityPreferredContainerPlacementStrategy.scala25 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 DTestAMRMClientAsync.java52 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 DAMRMClient.java47 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 Dhttp_test.go25 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 DParamFilter.java27 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 DParamFilter.java27 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 DTaskRecord.java4 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 DTaskRecord.java4 import org.apache.hadoop.yarn.client.api.AMRMClient.ContainerRequest;
17 public ContainerRequest containerRequest = null;

123