You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by ji...@apache.org on 2017/09/25 23:38:33 UTC
[34/86] [abbrv] hadoop git commit: YARN-7050. Post cleanup after
YARN-6903, removal of org.apache.slider package. Contributed by Jian He
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/ResourceKeys.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/ResourceKeys.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/ResourceKeys.java
deleted file mode 100644
index 2f71004..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/ResourceKeys.java
+++ /dev/null
@@ -1,210 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api;
-
-/**
- * These are the keys valid in resource options
- *
- /*
-
- Container failure window.
-
- The window is calculated in minutes as as (days * 24 *60 + hours* 24 + minutes)
-
- Every interval of this period after the AM is started/restarted becomes
- the time period in which the CONTAINER_FAILURE_THRESHOLD value is calculated.
-
- After the window limit is reached, the failure counts are reset. This
- is not a sliding window/moving average policy, simply a rule such as
- "every six hours the failure count is reset"
-
-
- <pre>
- ===========================================================================
- </pre>
-
- */
-public interface ResourceKeys {
-
-
- /**
- * #of instances of a component: {@value}
- *
- */
- String COMPONENT_INSTANCES = "yarn.component.instances";
-
- /**
- * Whether to use unique names for each instance of a component: {@value}
- */
- String UNIQUE_NAMES = "component.unique.names";
-
- /**
- * Amount of memory to ask YARN for in MB.
- * <i>Important:</i> this may be a hard limit on the
- * amount of RAM that the service can use
- * {@value}
- */
- String YARN_MEMORY = "yarn.memory";
-
- /** {@value} */
- int DEF_YARN_MEMORY = 256;
-
- /**
- * Number of cores/virtual cores to ask YARN for
- * {@value}
- */
- String YARN_CORES = "yarn.vcores";
-
- /**
- * If normalization is set to false, then if the resource (memory and/or
- * vcore) requested by a role is higher than YARN limits, then the resource
- * request is not normalized. If this causes failures at the YARN level then
- * applications are expecting that to happen. Default value is true.
- */
- String YARN_RESOURCE_NORMALIZATION_ENABLED =
- "yarn.resource.normalization.enabled";
-
- /**
- * Number of disks per instance to ask YARN for
- * {@value}
- */
- String YARN_DISKS = "yarn.disks.count-per-instance";
-
- /**
- * Disk size per disk to ask YARN for
- * {@value}
- */
- String YARN_DISK_SIZE = "yarn.disk.size";
-
- /** {@value} */
- int DEF_YARN_CORES = 1;
-
-
- /**
- * Label expression that this container must satisfy
- * {@value}
- */
- String YARN_LABEL_EXPRESSION = "yarn.label.expression";
-
- /** default label expression: */
- String DEF_YARN_LABEL_EXPRESSION = null;
-
-
- /**
- * Constant to indicate that the requirements of a YARN resource limit
- * (cores, memory, ...) should be set to the maximum allowed by
- * the queue into which the YARN container requests are placed.
- */
- String YARN_RESOURCE_MAX = "max";
-
- /**
- * Mandatory property for all roles
- * 1. this must be defined.
- * 2. this must be >= 1
- * 3. this must not match any other role priority in the cluster.
- */
- String COMPONENT_PRIORITY = "yarn.role.priority";
-
- /**
- * placement policy
- */
- String COMPONENT_PLACEMENT_POLICY = "yarn.component.placement.policy";
-
- /**
- * Maximum number of node failures that can be tolerated by a component on a specific node
- */
- String NODE_FAILURE_THRESHOLD =
- "yarn.node.failure.threshold";
-
- /**
- * maximum number of failed containers (in a single role)
- * before the cluster is deemed to have failed {@value}
- */
- String CONTAINER_FAILURE_THRESHOLD =
- "yarn.container.failure.threshold";
-
- /**
- * prefix for the time of the container failure reset window.
- * {@value}
- */
-
- String CONTAINER_FAILURE_WINDOW =
- "yarn.container.failure.window";
-
-
-
- long DEFAULT_CONTAINER_FAILURE_WINDOW_DAYS = 0;
- long DEFAULT_CONTAINER_FAILURE_WINDOW_HOURS = 6;
- long DEFAULT_CONTAINER_FAILURE_WINDOW_MINUTES = 0;
-
-
- /**
- * Default failure threshold: {@value}
- */
- int DEFAULT_CONTAINER_FAILURE_THRESHOLD = 5;
-
- /**
- * Default node failure threshold for a component instance: {@value}
- * Should to be lower than default component failure threshold to allow
- * the component to start elsewhere
- */
- int DEFAULT_NODE_FAILURE_THRESHOLD = 3;
-
- /**
- * Failure threshold is unlimited: {@value}
- */
- int NODE_FAILURE_THRESHOLD_UNLIMITED = -1;
-
- /**
- * Time in seconds to escalate placement delay
- */
- String PLACEMENT_ESCALATE_DELAY =
- "yarn.placement.escalate.seconds";
-
- /**
- * Time to have a strict placement policy outstanding before
- * downgrading to a lax placement (for those components which permit that).
- * <ol>
- * <li>For strictly placed components, there's no relaxation.</li>
- * <li>For components with no locality, there's no need to relax</li>
- * </ol>
- *
- */
- int DEFAULT_PLACEMENT_ESCALATE_DELAY_SECONDS = 30;
-
- /**
- * Log aggregation include, exclude patterns
- */
- String YARN_LOG_INCLUDE_PATTERNS = "yarn.log.include.patterns";
- String YARN_LOG_EXCLUDE_PATTERNS = "yarn.log.exclude.patterns";
-
- String YARN_PROFILE_NAME = "yarn.resource-profile-name";
-
- /**
- * Window of time where application master's failure count
- * can be reset to 0.
- */
- String YARN_RESOURCEMANAGER_AM_RETRY_COUNT_WINDOW_MS =
- "yarn.resourcemanager.am.retry-count-window-ms";
-
- /**
- * The default window for Slider.
- */
- long DEFAULT_AM_RETRY_COUNT_WINDOW_MS = 300000;
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/RoleKeys.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/RoleKeys.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/RoleKeys.java
deleted file mode 100644
index ce413ff..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/RoleKeys.java
+++ /dev/null
@@ -1,121 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api;
-
-/**
- * Standard options for roles
- */
-public interface RoleKeys {
-
-
- /**
- * The name of a role: {@value}
- */
- String ROLE_NAME = "role.name";
-
- /**
- * The group of a role: {@value}
- */
- String ROLE_GROUP = "role.group";
-
- /**
- * The prefix of a role: {@value}
- */
- String ROLE_PREFIX = "role.prefix";
-
- /**
- * Status report: number actually granted : {@value}
- */
- String ROLE_ACTUAL_INSTANCES = "role.actual.instances";
-
- /**
- * Status report: number currently requested: {@value}
- */
- String ROLE_REQUESTED_INSTANCES = "role.requested.instances";
-
- /**
- * Status report: number currently being released: {@value}
- */
- String ROLE_RELEASING_INSTANCES = "role.releasing.instances";
-
- /**
- * Status report: total number that have failed: {@value}
- */
- String ROLE_FAILED_INSTANCES = "role.failed.instances";
-
- /**
- * Status report: number that have failed recently: {@value}
- */
- String ROLE_FAILED_RECENTLY_INSTANCES = "role.failed.recently.instances";
-
- /**
- * Status report: number that have failed for node-related issues: {@value}
- */
- String ROLE_NODE_FAILED_INSTANCES = "role.failed.node.instances";
-
- /**
- * Status report: number that been pre-empted: {@value}
- */
- String ROLE_PREEMPTED_INSTANCES = "role.failed.preempted.instances";
-
- /**
- * Number of pending anti-affine instances: {@value}
- */
- String ROLE_PENDING_AA_INSTANCES = "role.pending.aa.instances";
-
- /**
- * Status report: number currently being released: {@value}
- */
- String ROLE_FAILED_STARTING_INSTANCES = "role.failed.starting.instances";
-
- /**
- * Extra arguments (non-JVM) to use when starting this role
- */
- String ROLE_ADDITIONAL_ARGS = "role.additional.args";
-
- /**
- * JVM heap size for Java applications in MB. Only relevant for Java applications.
- * This MUST be less than or equal to the {@link ResourceKeys#YARN_MEMORY} option
- * {@value}
- */
- String JVM_HEAP = "jvm.heapsize";
-
- /*
- * GC options for Java applications.
- */
- String GC_OPTS = "gc.opts";
-
- /**
- * JVM options other than heap size. Only relevant for Java applications.
- * {@value}
- */
- String JVM_OPTS = "jvm.opts";
-
-
- /**
- * All keys w/ env. are converted into env variables and passed down
- */
- String ENV_PREFIX = "env.";
-
- /**
- * Container service record attribute prefix.
- */
- String SERVICE_RECORD_ATTRIBUTE_PREFIX = "service.record.attribute";
-
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/ServiceApiConstants.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/ServiceApiConstants.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/ServiceApiConstants.java
deleted file mode 100644
index fa21211..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/ServiceApiConstants.java
+++ /dev/null
@@ -1,69 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api;
-
-import org.apache.hadoop.classification.InterfaceAudience;
-import org.apache.hadoop.classification.InterfaceStability;
-
-import static org.apache.hadoop.yarn.service.utils.ServiceApiUtil.$;
-
-/**
- * This class defines constants that can be used in input spec for
- * variable substitutions
- */
-@InterfaceAudience.Public
-@InterfaceStability.Unstable
-public interface ServiceApiConstants {
-
- // Constants for service
- String SERVICE_NAME = $("SERVICE_NAME");
-
- String SERVICE_NAME_LC = $("SERVICE_NAME.lc");
-
- String USER = $("USER");
-
- String DOMAIN = $("DOMAIN");
-
- // Constants for component
- String COMPONENT_NAME = $("COMPONENT_NAME");
-
- String COMPONENT_NAME_LC = $("COMPONENT_NAME.lc");
-
- String COMPONENT_INSTANCE_NAME = $("COMPONENT_INSTANCE_NAME");
-
- // Constants for component instance
- String COMPONENT_ID = $("COMPONENT_ID");
-
- String CONTAINER_ID = $("CONTAINER_ID");
-
- // Constants for default cluster ZK
- String CLUSTER_ZK_QUORUM = $("CLUSTER_ZK_QUORUM");
-
- // URI for the default cluster fs
- String CLUSTER_FS_URI = $("CLUSTER_FS_URI");
-
- // the host component of the cluster fs UI
- String CLUSTER_FS_HOST = $("CLUSTER_FS_HOST");
-
- // Path in zookeeper for a specific service
- String SERVICE_ZK_PATH = $("SERVICE_ZK_PATH");
-
- // Constants for service specific hdfs dir
- String SERVICE_HDFS_DIR = $("SERVICE_HDFS_DIR");
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/SliderClusterProtocol.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/SliderClusterProtocol.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/SliderClusterProtocol.java
deleted file mode 100644
index aaf2f88..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/SliderClusterProtocol.java
+++ /dev/null
@@ -1,152 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License") throws IOException, YarnException; you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api;
-
-import org.apache.hadoop.ipc.VersionedProtocol;
-import org.apache.hadoop.security.KerberosInfo;
-import org.apache.hadoop.yarn.exceptions.YarnException;
-import org.apache.slider.api.proto.Messages;
-import org.apache.hadoop.yarn.service.conf.SliderXmlConfKeys;
-
-import java.io.IOException;
-
-/**
- * Cluster protocol. This can currently act as a versioned IPC
- * endpoint or be relayed via protobuf
- */
-@KerberosInfo(serverPrincipal = SliderXmlConfKeys.KEY_KERBEROS_PRINCIPAL)
-public interface SliderClusterProtocol extends VersionedProtocol {
- long versionID = 0x01;
-
- /**
- * Stop the cluster
- */
-
- Messages.StopClusterResponseProto stopCluster(Messages.StopClusterRequestProto request) throws
- IOException, YarnException;
- /**
- * Upgrade the application containers
- *
- * @param request upgrade containers request object
- * @return upgrade containers response object
- * @throws IOException
- * @throws YarnException
- */
- Messages.UpgradeContainersResponseProto upgradeContainers(
- Messages.UpgradeContainersRequestProto request) throws IOException,
- YarnException;
-
-
- Messages.FlexComponentsResponseProto flexComponents(
- Messages.FlexComponentsRequestProto request) throws IOException;
-
- /**
- * Get the current cluster status
- */
- Messages.GetJSONClusterStatusResponseProto getJSONClusterStatus(Messages.GetJSONClusterStatusRequestProto request)
- throws IOException, YarnException;
-
-
- /**
- * List all running nodes in a role
- */
- Messages.ListNodeUUIDsByRoleResponseProto listNodeUUIDsByRole(Messages.ListNodeUUIDsByRoleRequestProto request)
- throws IOException, YarnException;
-
-
- /**
- * Get the details on a node
- */
- Messages.GetNodeResponseProto getNode(Messages.GetNodeRequestProto request)
- throws IOException, YarnException;
-
- /**
- * Get the
- * details on a list of nodes.
- * Unknown nodes are not returned
- * <i>Important: the order of the results are undefined</i>
- */
- Messages.GetClusterNodesResponseProto getClusterNodes(Messages.GetClusterNodesRequestProto request)
- throws IOException, YarnException;
-
- /**
- * Echo back the submitted text (after logging it).
- * Useful for adding information to the log, and for testing round trip
- * operations of the protocol
- * @param request request
- * @return response
- * @throws IOException
- * @throws YarnException
- */
- Messages.EchoResponseProto echo(Messages.EchoRequestProto request) throws IOException, YarnException;
-
- /**
- * Kill an identified container
- * @param request request containing the container to kill
- * @return the response
- * @throws IOException
- * @throws YarnException
- */
- Messages.KillContainerResponseProto killContainer(Messages.KillContainerRequestProto request)
- throws IOException, YarnException;
-
- /**
- * AM to commit suicide. If the Hadoop halt entry point has not been disabled,
- * this will fail rather than return with a response.
- * @param request request
- * @return response (this is not the expected outcome)
- * @throws IOException
- * @throws YarnException
- */
- Messages.AMSuicideResponseProto amSuicide(Messages.AMSuicideRequestProto request)
- throws IOException;
-
- /**
- * Get the application liveness
- * @return current liveness information
- * @throws IOException
- */
- Messages.ApplicationLivenessInformationProto getLivenessInformation(
- Messages.GetApplicationLivenessRequestProto request
- ) throws IOException;
-
- Messages.GetLiveContainersResponseProto getLiveContainers(
- Messages.GetLiveContainersRequestProto request
- ) throws IOException;
-
- Messages.ContainerInformationProto getLiveContainer(
- Messages.GetLiveContainerRequestProto request
- ) throws IOException;
-
- Messages.GetLiveComponentsResponseProto getLiveComponents(
- Messages.GetLiveComponentsRequestProto request
- ) throws IOException;
-
- Messages.ComponentInformationProto getLiveComponent(
- Messages.GetLiveComponentRequestProto request
- ) throws IOException;
-
- Messages.GetLiveNodesResponseProto getLiveNodes(
- Messages.GetLiveNodesRequestProto request
- ) throws IOException;
-
- Messages.NodeInformationProto getLiveNode(
- Messages.GetLiveNodeRequestProto request
- ) throws IOException;
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/StateValues.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/StateValues.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/StateValues.java
deleted file mode 100644
index ad66a97..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/StateValues.java
+++ /dev/null
@@ -1,63 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api;
-
-/**
- * Enumeration of state values.
- */
-public class StateValues {
-
- private StateValues() {}
-
- /**
- * Specification is incomplete & cannot
- * be used: {@value}.
- */
- public static final int STATE_INCOMPLETE = 0;
-
- /**
- * Spec has been submitted: {@value}
- */
- public static final int STATE_SUBMITTED = 1;
- /**
- * Cluster created: {@value}
- */
- public static final int STATE_CREATED = 2;
- /**
- * Live: {@value}
- */
- public static final int STATE_LIVE = 3;
- /**
- * Not ready.
- */
- public static final int STATE_NOT_READY = 4;
- /**
- * Ready.
- */
- public static final int STATE_READY = 5;
- /**
- * Stopped.
- */
- public static final int STATE_STOPPED = 99;
- /**
- * Destroyed.
- */
- public static final int STATE_DESTROYED = 100;
-
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/StatusKeys.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/StatusKeys.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/StatusKeys.java
deleted file mode 100644
index 8a2c4bb..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/StatusKeys.java
+++ /dev/null
@@ -1,117 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api;
-import static org.apache.slider.api.ResourceKeys.COMPONENT_INSTANCES;
-/**
- * Contains status and statistics keys
- */
-public interface StatusKeys {
-
- String STATISTICS_CONTAINERS_ACTIVE_REQUESTS = "containers.active.requests";
- String STATISTICS_CONTAINERS_COMPLETED = "containers.completed";
- String STATISTICS_CONTAINERS_DESIRED = "containers.desired";
- String STATISTICS_CONTAINERS_FAILED = "containers.failed";
- String STATISTICS_CONTAINERS_FAILED_RECENTLY = "containers.failed.recently";
- String STATISTICS_CONTAINERS_FAILED_NODE = "containers.failed.node";
- String STATISTICS_CONTAINERS_PREEMPTED = "containers.failed.preempted";
- String STATISTICS_CONTAINERS_LIVE = "containers.live";
- String STATISTICS_CONTAINERS_REQUESTED = "containers.requested";
- String STATISTICS_CONTAINERS_ANTI_AFFINE_PENDING = "containers.anti-affine.pending";
- String STATISTICS_CONTAINERS_STARTED = "containers.start.started";
- String STATISTICS_CONTAINERS_START_FAILED =
- "containers.start.failed";
- String STATISTICS_CONTAINERS_SURPLUS =
- "containers.surplus";
- String STATISTICS_CONTAINERS_UNKNOWN_COMPLETED =
- "containers.unknown.completed";
- /**
- * No of containers provided on AM restart
- */
- String INFO_CONTAINERS_AM_RESTART = "containers.at.am-restart";
-
- String INFO_CREATE_TIME_MILLIS = "create.time.millis";
- String INFO_CREATE_TIME_HUMAN = "create.time";
- String INFO_LIVE_TIME_MILLIS = "live.time.millis";
- String INFO_LIVE_TIME_HUMAN = "live.time";
- String INFO_FLEX_TIME_MILLIS = "flex.time.millis";
- String INFO_FLEX_TIME_HUMAN = "flex.time";
-
- String INFO_MASTER_ADDRESS = "info.master.address";
-
- /**
- * System time in millis when the status report was generated
- */
- String INFO_STATUS_TIME_MILLIS = "status.time.millis";
-
- /**
- * System time in human form when the status report was generated
- */
- String INFO_STATUS_TIME_HUMAN = "status.time";
-
- String INFO_AM_APP_ID = "info.am.app.id";
- String INFO_AM_ATTEMPT_ID = "info.am.attempt.id";
- String INFO_AM_CONTAINER_ID = "info.am.container.id";
- String INFO_AM_HOSTNAME = "info.am.hostname";
- String INFO_AM_RPC_PORT = "info.am.rpc.port";
- String INFO_AM_WEB_PORT = "info.am.web.port";
- String INFO_AM_WEB_URL = "info.am.web.url";
- String INFO_AM_AGENT_STATUS_PORT = "info.am.agent.status.port";
- String INFO_AM_AGENT_OPS_PORT = "info.am.agent.ops.port";
- String INFO_AM_AGENT_OPS_URL = "info.am.agent.ops.url";
- String INFO_AM_AGENT_STATUS_URL = "info.am.agent.status.url";
-
- /**
- * info: #of instances of a component requested: {@value}
- *
- */
- String COMPONENT_INSTANCES_ACTUAL = COMPONENT_INSTANCES + ".actual";
-
- /**
- * info: #of instances of a component requested: {@value}
- *
- */
- String COMPONENT_INSTANCES_REQUESTING = COMPONENT_INSTANCES + ".requesting";
-
- /**
- * info: #of instances of a component being released: {@value}
- *
- */
- String COMPONENT_INSTANCES_RELEASING = COMPONENT_INSTANCES + ".releasing";
-
- /**
- * info: #of instances of a component failed: {@value}
- *
- */
- String COMPONENT_INSTANCES_FAILED = COMPONENT_INSTANCES + ".failed";
-
- /**
- * info: #of instances of a component started: {@value}
- *
- */
- String COMPONENT_INSTANCES_STARTED = COMPONENT_INSTANCES + ".started";
-
-
- /**
- * info: #of instances of a component completed: {@value}
- *
- */
- String COMPONENT_INSTANCES_COMPLETED = COMPONENT_INSTANCES + ".completed";
-
-
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Application.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Application.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Application.java
deleted file mode 100644
index 626efb8..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Application.java
+++ /dev/null
@@ -1,463 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api.resource;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.annotation.JsonPropertyOrder;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-
-import javax.xml.bind.annotation.XmlElement;
-import javax.xml.bind.annotation.XmlRootElement;
-import java.util.ArrayList;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
-
-/**
- * An Application resource has the following attributes.
- **/
-
-@ApiModel(description = "An Application resource has the following attributes.")
-@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaClientCodegen", date = "2016-06-02T08:15:05.615-07:00")
-@XmlRootElement
-@JsonInclude(JsonInclude.Include.NON_NULL)
-@JsonPropertyOrder({ "name", "state", "resource", "number_of_containers",
- "lifetime", "containers" })
-public class Application extends BaseResource {
- private static final long serialVersionUID = -4491694636566094885L;
-
- private String name = null;
- private String id = null;
- private Artifact artifact = null;
- private Resource resource = null;
- private String launchCommand = null;
- private Date launchTime = null;
- private Long numberOfContainers = null;
- private Long numberOfRunningContainers = null;
- private Long lifetime = null;
- private PlacementPolicy placementPolicy = null;
- private List<Component> components = new ArrayList<>();
- private Configuration configuration = new Configuration();
- private List<Container> containers = new ArrayList<>();
- private ApplicationState state = null;
- private Map<String, String> quicklinks = new HashMap<>();
- private String queue = null;
-
- /**
- * A unique application name.
- **/
- public Application name(String name) {
- this.name = name;
- return this;
- }
-
- @ApiModelProperty(example = "null", required = true, value = "A unique application name.")
- @JsonProperty("name")
- public String getName() {
- return name;
- }
-
- public void setName(String name) {
- this.name = name;
- }
-
- /**
- * A unique application id.
- **/
- public Application id(String id) {
- this.id = id;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "A unique application id.")
- @JsonProperty("id")
- public String getId() {
- return id;
- }
-
- public void setId(String id) {
- this.id = id;
- }
-
- /**
- * Artifact of single-component applications. Mandatory if components
- * attribute is not specified.
- **/
- public Application artifact(Artifact artifact) {
- this.artifact = artifact;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Artifact of single-component applications. Mandatory if components attribute is not specified.")
- @JsonProperty("artifact")
- public Artifact getArtifact() {
- return artifact;
- }
-
- public void setArtifact(Artifact artifact) {
- this.artifact = artifact;
- }
-
- /**
- * Resource of single-component applications or the global default for
- * multi-component applications. Mandatory if it is a single-component
- * application and if cpus and memory are not specified at the Application
- * level.
- **/
- public Application resource(Resource resource) {
- this.resource = resource;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Resource of single-component applications or the global default for multi-component applications. Mandatory if it is a single-component application and if cpus and memory are not specified at the Application level.")
- @JsonProperty("resource")
- public Resource getResource() {
- return resource;
- }
-
- public void setResource(Resource resource) {
- this.resource = resource;
- }
-
- /**
- * The custom launch command of an application component (optional). If not
- * specified for applications with docker images say, it will default to the
- * default start command of the image. If there is a single component in this
- * application, you can specify this without the need to have a 'components'
- * section.
- **/
- public Application launchCommand(String launchCommand) {
- this.launchCommand = launchCommand;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "The custom launch command of an application component (optional). If not specified for applications with docker images say, it will default to the default start command of the image. If there is a single component in this application, you can specify this without the need to have a 'components' section.")
- @JsonProperty("launch_command")
- public String getLaunchCommand() {
- return launchCommand;
- }
-
- @XmlElement(name = "launch_command")
- public void setLaunchCommand(String launchCommand) {
- this.launchCommand = launchCommand;
- }
-
- /**
- * The time when the application was created, e.g. 2016-03-16T01:01:49.000Z.
- **/
- public Application launchTime(Date launchTime) {
- this.launchTime = launchTime == null ? null : (Date) launchTime.clone();
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "The time when the application was created, e.g. 2016-03-16T01:01:49.000Z.")
- @JsonProperty("launch_time")
- public Date getLaunchTime() {
- return launchTime == null ? null : (Date) launchTime.clone();
- }
-
- @XmlElement(name = "launch_time")
- public void setLaunchTime(Date launchTime) {
- this.launchTime = launchTime == null ? null : (Date) launchTime.clone();
- }
-
- /**
- * Number of containers for each app-component in the application. Each
- * app-component can further override this app-level global default.
- **/
- public Application numberOfContainers(Long numberOfContainers) {
- this.numberOfContainers = numberOfContainers;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Number of containers for each app-component in the application. Each app-component can further override this app-level global default.")
- @JsonProperty("number_of_containers")
- public Long getNumberOfContainers() {
- return numberOfContainers;
- }
-
- @XmlElement(name = "number_of_containers")
- public void setNumberOfContainers(Long numberOfContainers) {
- this.numberOfContainers = numberOfContainers;
- }
-
- /**
- * In get response this provides the total number of running containers for
- * this application (across all components) at the time of request. Note, a
- * subsequent request can return a different number as and when more
- * containers get allocated until it reaches the total number of containers or
- * if a flex request has been made between the two requests.
- **/
- public Application numberOfRunningContainers(Long numberOfRunningContainers) {
- this.numberOfRunningContainers = numberOfRunningContainers;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "In get response this provides the total number of running containers for this application (across all components) at the time of request. Note, a subsequent request can return a different number as and when more containers get allocated until it reaches the total number of containers or if a flex request has been made between the two requests.")
- @JsonProperty("number_of_running_containers")
- public Long getNumberOfRunningContainers() {
- return numberOfRunningContainers;
- }
-
- @XmlElement(name = "number_of_running_containers")
- public void setNumberOfRunningContainers(Long numberOfRunningContainers) {
- this.numberOfRunningContainers = numberOfRunningContainers;
- }
-
- /**
- * Life time (in seconds) of the application from the time it reaches the
- * RUNNING_BUT_UNREADY state (after which it is automatically destroyed by YARN). For
- * unlimited lifetime do not set a lifetime value.
- **/
- public Application lifetime(Long lifetime) {
- this.lifetime = lifetime;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Life time (in seconds) of the application from the time it reaches the RUNNING_BUT_UNREADY state (after which it is automatically destroyed by YARN). For unlimited lifetime do not set a lifetime value.")
- @JsonProperty("lifetime")
- public Long getLifetime() {
- return lifetime;
- }
-
- public void setLifetime(Long lifetime) {
- this.lifetime = lifetime;
- }
-
- /**
- * Advanced scheduling and placement policies (optional). If not specified, it
- * defaults to the default placement policy of the app owner. The design of
- * placement policies are in the works. It is not very clear at this point,
- * how policies in conjunction with labels be exposed to application owners.
- * This is a placeholder for now. The advanced structure of this attribute
- * will be determined by YARN-4902.
- **/
- public Application placementPolicy(PlacementPolicy placementPolicy) {
- this.placementPolicy = placementPolicy;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Advanced scheduling and placement policies (optional). If not specified, it defaults to the default placement policy of the app owner. The design of placement policies are in the works. It is not very clear at this point, how policies in conjunction with labels be exposed to application owners. This is a placeholder for now. The advanced structure of this attribute will be determined by YARN-4902.")
- @JsonProperty("placement_policy")
- public PlacementPolicy getPlacementPolicy() {
- return placementPolicy;
- }
-
- @XmlElement(name = "placement_policy")
- public void setPlacementPolicy(PlacementPolicy placementPolicy) {
- this.placementPolicy = placementPolicy;
- }
-
- /**
- * Components of an application.
- **/
- public Application components(List<Component> components) {
- this.components = components;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Components of an application.")
- @JsonProperty("components")
- public List<Component> getComponents() {
- return components;
- }
-
- public void setComponents(List<Component> components) {
- this.components = components;
- }
-
- public void addComponent(Component component) {
- components.add(component);
- }
-
- public Component getComponent(String name) {
- for (Component component : components) {
- if (component.getName().equals(name)) {
- return component;
- }
- }
- return null;
- }
-
- /**
- * Config properties of an application. Configurations provided at the
- * application/global level are available to all the components. Specific
- * properties can be overridden at the component level.
- **/
- public Application configuration(Configuration configuration) {
- this.configuration = configuration;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Config properties of an application. Configurations provided at the application/global level are available to all the components. Specific properties can be overridden at the component level.")
- @JsonProperty("configuration")
- public Configuration getConfiguration() {
- return configuration;
- }
-
- public void setConfiguration(Configuration configuration) {
- this.configuration = configuration;
- }
-
- /**
- * Containers of a started application. Specifying a value for this attribute
- * for the POST payload raises a validation error. This blob is available only
- * in the GET response of a started application.
- **/
- public Application containers(List<Container> containers) {
- this.containers = containers;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Containers of a started application. Specifying a value for this attribute for the POST payload raises a validation error. This blob is available only in the GET response of a started application.")
- @JsonProperty("containers")
- public List<Container> getContainers() {
- return containers;
- }
-
- public void setContainers(List<Container> containers) {
- this.containers = containers;
- }
-
- public void addContainer(Container container) {
- this.containers.add(container);
- }
-
- /**
- * State of the application. Specifying a value for this attribute for the
- * POST payload raises a validation error. This attribute is available only in
- * the GET response of a started application.
- **/
- public Application state(ApplicationState state) {
- this.state = state;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "State of the application. Specifying a value for this attribute for the POST payload raises a validation error. This attribute is available only in the GET response of a started application.")
- @JsonProperty("state")
- public ApplicationState getState() {
- return state;
- }
-
- public void setState(ApplicationState state) {
- this.state = state;
- }
-
- /**
- * A blob of key-value pairs of quicklinks to be exported for an application.
- **/
- public Application quicklinks(Map<String, String> quicklinks) {
- this.quicklinks = quicklinks;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "A blob of key-value pairs of quicklinks to be exported for an application.")
- @JsonProperty("quicklinks")
- public Map<String, String> getQuicklinks() {
- return quicklinks;
- }
-
- public void setQuicklinks(Map<String, String> quicklinks) {
- this.quicklinks = quicklinks;
- }
-
- /**
- * The YARN queue that this application should be submitted to.
- **/
- public Application queue(String queue) {
- this.queue = queue;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "The YARN queue that this application should be submitted to.")
- @JsonProperty("queue")
- public String getQueue() {
- return queue;
- }
-
- public void setQueue(String queue) {
- this.queue = queue;
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- Application application = (Application) o;
- return Objects.equals(this.name, application.name);
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(name);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append("class Application {\n");
-
- sb.append(" name: ").append(toIndentedString(name)).append("\n");
- sb.append(" id: ").append(toIndentedString(id)).append("\n");
- sb.append(" artifact: ").append(toIndentedString(artifact)).append("\n");
- sb.append(" resource: ").append(toIndentedString(resource)).append("\n");
- sb.append(" launchCommand: ").append(toIndentedString(launchCommand))
- .append("\n");
- sb.append(" launchTime: ").append(toIndentedString(launchTime))
- .append("\n");
- sb.append(" numberOfContainers: ")
- .append(toIndentedString(numberOfContainers)).append("\n");
- sb.append(" numberOfRunningContainers: ")
- .append(toIndentedString(numberOfRunningContainers)).append("\n");
- sb.append(" lifetime: ").append(toIndentedString(lifetime)).append("\n");
- sb.append(" placementPolicy: ").append(toIndentedString(placementPolicy))
- .append("\n");
- sb.append(" components: ").append(toIndentedString(components))
- .append("\n");
- sb.append(" configuration: ").append(toIndentedString(configuration))
- .append("\n");
- sb.append(" containers: ").append(toIndentedString(containers))
- .append("\n");
- sb.append(" state: ").append(toIndentedString(state)).append("\n");
- sb.append(" quicklinks: ").append(toIndentedString(quicklinks))
- .append("\n");
- sb.append(" queue: ").append(toIndentedString(queue)).append("\n");
- sb.append("}");
- return sb.toString();
- }
-
- /**
- * Convert the given object to string with each line indented by 4 spaces
- * (except the first line).
- */
- private String toIndentedString(java.lang.Object o) {
- if (o == null) {
- return "null";
- }
- return o.toString().replace("\n", "\n ");
- }
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ApplicationState.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ApplicationState.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ApplicationState.java
deleted file mode 100644
index 6827c16..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ApplicationState.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api.resource;
-
-import io.swagger.annotations.ApiModel;
-
-/**
- * The current state of an application.
- **/
-
-@ApiModel(description = "The current state of an application.")
-@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaClientCodegen", date = "2016-06-02T08:15:05.615-07:00")
-public enum ApplicationState {
- ACCEPTED, STARTED, READY, STOPPED, FAILED;
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ApplicationStatus.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ApplicationStatus.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ApplicationStatus.java
deleted file mode 100644
index 06960a8..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ApplicationStatus.java
+++ /dev/null
@@ -1,145 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api.resource;
-
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-
-import java.util.Objects;
-
-import javax.xml.bind.annotation.XmlRootElement;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-
-/**
- * The current status of a submitted application, returned as a response to the
- * GET API.
- **/
-
-@ApiModel(description = "The current status of a submitted application, returned as a response to the GET API.")
-@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaClientCodegen", date = "2016-06-02T08:15:05.615-07:00")
-@XmlRootElement
-@JsonInclude(JsonInclude.Include.NON_NULL)
-public class ApplicationStatus extends BaseResource {
- private static final long serialVersionUID = -3469885905347851034L;
-
- private String diagnostics = null;
- private ApplicationState state = null;
- private Integer code = null;
-
- /**
- * Diagnostic information (if any) for the reason of the current state of the
- * application. It typically has a non-null value, if the application is in a
- * non-running state.
- **/
- public ApplicationStatus diagnostics(String diagnostics) {
- this.diagnostics = diagnostics;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Diagnostic information (if any) for the reason of the current state of the application. It typically has a non-null value, if the application is in a non-running state.")
- @JsonProperty("diagnostics")
- public String getDiagnostics() {
- return diagnostics;
- }
-
- public void setDiagnostics(String diagnostics) {
- this.diagnostics = diagnostics;
- }
-
- /**
- * Application state.
- **/
- public ApplicationStatus state(ApplicationState state) {
- this.state = state;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Application state.")
- @JsonProperty("state")
- public ApplicationState getState() {
- return state;
- }
-
- public void setState(ApplicationState state) {
- this.state = state;
- }
-
- /**
- * An error code specific to a scenario which app owners should be able to use
- * to understand the failure in addition to the diagnostic information.
- **/
- public ApplicationStatus code(Integer code) {
- this.code = code;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "An error code specific to a scenario which app owners should be able to use to understand the failure in addition to the diagnostic information.")
- @JsonProperty("code")
- public Integer getCode() {
- return code;
- }
-
- public void setCode(Integer code) {
- this.code = code;
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- ApplicationStatus applicationStatus = (ApplicationStatus) o;
- return Objects.equals(this.diagnostics, applicationStatus.diagnostics)
- && Objects.equals(this.state, applicationStatus.state)
- && Objects.equals(this.code, applicationStatus.code);
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(diagnostics, state, code);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append("class ApplicationStatus {\n");
-
- sb.append(" diagnostics: ").append(toIndentedString(diagnostics))
- .append("\n");
- sb.append(" state: ").append(toIndentedString(state)).append("\n");
- sb.append(" code: ").append(toIndentedString(code)).append("\n");
- sb.append("}");
- return sb.toString();
- }
-
- /**
- * Convert the given object to string with each line indented by 4 spaces
- * (except the first line).
- */
- private String toIndentedString(java.lang.Object o) {
- if (o == null) {
- return "null";
- }
- return o.toString().replace("\n", "\n ");
- }
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Artifact.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Artifact.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Artifact.java
deleted file mode 100644
index f274d7d..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Artifact.java
+++ /dev/null
@@ -1,157 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api.resource;
-
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-
-import java.io.Serializable;
-import java.util.Objects;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.annotation.JsonValue;
-
-/**
- * Artifact of an application component.
- **/
-
-@ApiModel(description = "Artifact of an application component")
-@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaClientCodegen", date = "2016-06-02T08:15:05.615-07:00")
-@JsonInclude(JsonInclude.Include.NON_NULL)
-public class Artifact implements Serializable {
- private static final long serialVersionUID = 3608929500111099035L;
-
- private String id = null;
-
- public enum TypeEnum {
- DOCKER("DOCKER"), TARBALL("TARBALL"), APPLICATION("APPLICATION");
-
- private String value;
-
- TypeEnum(String value) {
- this.value = value;
- }
-
- @Override
- @JsonValue
- public String toString() {
- return value;
- }
- }
-
- private TypeEnum type = TypeEnum.DOCKER;
- private String uri = null;
-
- /**
- * Artifact id. Examples are package location uri for tarball based apps,
- * image name for docker, etc.
- **/
- public Artifact id(String id) {
- this.id = id;
- return this;
- }
-
- @ApiModelProperty(example = "null", required = true, value = "Artifact id. Examples are package location uri for tarball based apps, image name for docker, etc.")
- @JsonProperty("id")
- public String getId() {
- return id;
- }
-
- public void setId(String id) {
- this.id = id;
- }
-
- /**
- * Artifact type, like docker, tarball, etc. (optional).
- **/
- public Artifact type(TypeEnum type) {
- this.type = type;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Artifact type, like docker, tarball, etc. (optional).")
- @JsonProperty("type")
- public TypeEnum getType() {
- return type;
- }
-
- public void setType(TypeEnum type) {
- this.type = type;
- }
-
- /**
- * Artifact location to support multiple artifact stores (optional).
- **/
- public Artifact uri(String uri) {
- this.uri = uri;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Artifact location to support multiple artifact stores (optional).")
- @JsonProperty("uri")
- public String getUri() {
- return uri;
- }
-
- public void setUri(String uri) {
- this.uri = uri;
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- Artifact artifact = (Artifact) o;
- return Objects.equals(this.id, artifact.id)
- && Objects.equals(this.type, artifact.type)
- && Objects.equals(this.uri, artifact.uri);
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(id, type, uri);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append("class Artifact {\n");
-
- sb.append(" id: ").append(toIndentedString(id)).append("\n");
- sb.append(" type: ").append(toIndentedString(type)).append("\n");
- sb.append(" uri: ").append(toIndentedString(uri)).append("\n");
- sb.append("}");
- return sb.toString();
- }
-
- /**
- * Convert the given object to string with each line indented by 4 spaces
- * (except the first line).
- */
- private String toIndentedString(java.lang.Object o) {
- if (o == null) {
- return "null";
- }
- return o.toString().replace("\n", "\n ");
- }
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/BaseResource.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/BaseResource.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/BaseResource.java
deleted file mode 100644
index a23c1fb..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/BaseResource.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api.resource;
-
-import java.io.Serializable;
-
-public class BaseResource implements Serializable {
- private static final long serialVersionUID = 1492603053176889431L;
-
- private String uri;
-
- /**
- * Resource location, e.g. \
- * "/applications/helloworld/containers/container_e3751_1458061340047_0008_01_000002\
- * "
- **/
- public String getUri() {
- return uri;
- }
-
- public void setUri(String uri) {
- this.uri = uri;
- }
-
- @Override
- public String toString() {
- StringBuilder builder = new StringBuilder();
- builder.append("BaseResource [uri=");
- builder.append(uri);
- builder.append("]");
- return builder.toString();
- }
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Component.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Component.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Component.java
deleted file mode 100644
index c15f82c..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/Component.java
+++ /dev/null
@@ -1,449 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api.resource;
-
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-
-import java.io.Serializable;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.List;
-import java.util.Objects;
-
-import javax.xml.bind.annotation.XmlElement;
-import javax.xml.bind.annotation.XmlRootElement;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-
-/**
- * One or more components of the application. If the application is HBase say,
- * then the component can be a simple role like master or regionserver. If the
- * application is a complex business webapp then a component can be other
- * applications say Kafka or Storm. Thereby it opens up the support for complex
- * and nested applications.
- **/
-
-@ApiModel(description = "One or more components of the application. If the application is HBase say, then the component can be a simple role like master or regionserver. If the application is a complex business webapp then a component can be other applications say Kafka or Storm. Thereby it opens up the support for complex and nested applications.")
-@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaClientCodegen", date = "2016-06-02T08:15:05.615-07:00")
-@XmlRootElement
-@JsonInclude(JsonInclude.Include.NON_NULL)
-public class Component implements Serializable {
- private static final long serialVersionUID = -8430058381509087805L;
-
- private String name = null;
- private List<String> dependencies = new ArrayList<String>();
- private ReadinessCheck readinessCheck = null;
- private Artifact artifact = null;
- private String launchCommand = null;
- private Resource resource = null;
- private Long numberOfContainers = null;
- private Boolean uniqueComponentSupport = false;
- private Boolean runPrivilegedContainer = false;
- private PlacementPolicy placementPolicy = null;
- private Configuration configuration = new Configuration();
- private List<String> quicklinks = new ArrayList<String>();
- private List<Container> containers =
- Collections.synchronizedList(new ArrayList<Container>());
-
- /**
- * Name of the application component (mandatory).
- **/
- public Component name(String name) {
- this.name = name;
- return this;
- }
-
- @ApiModelProperty(example = "null", required = true, value = "Name of the application component (mandatory).")
- @JsonProperty("name")
- public String getName() {
- return name;
- }
-
- public void setName(String name) {
- this.name = name;
- }
-
- /**
- * An array of application components which should be in READY state (as
- * defined by readiness check), before this component can be started. The
- * dependencies across all components of an application should be represented
- * as a DAG.
- **/
- public Component dependencies(List<String> dependencies) {
- this.dependencies = dependencies;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "An array of application components which should be in READY state (as defined by readiness check), before this component can be started. The dependencies across all components of an application should be represented as a DAG.")
- @JsonProperty("dependencies")
- public List<String> getDependencies() {
- return dependencies;
- }
-
- public void setDependencies(List<String> dependencies) {
- this.dependencies = dependencies;
- }
-
- /**
- * Readiness check for this app-component.
- **/
- public Component readinessCheck(ReadinessCheck readinessCheck) {
- this.readinessCheck = readinessCheck;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Readiness check for this app-component.")
- @JsonProperty("readiness_check")
- public ReadinessCheck getReadinessCheck() {
- return readinessCheck;
- }
-
- @XmlElement(name = "readiness_check")
- public void setReadinessCheck(ReadinessCheck readinessCheck) {
- this.readinessCheck = readinessCheck;
- }
-
- /**
- * Artifact of the component (optional). If not specified, the application
- * level global artifact takes effect.
- **/
- public Component artifact(Artifact artifact) {
- this.artifact = artifact;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Artifact of the component (optional). If not specified, the application level global artifact takes effect.")
- @JsonProperty("artifact")
- public Artifact getArtifact() {
- return artifact;
- }
-
- public void setArtifact(Artifact artifact) {
- this.artifact = artifact;
- }
-
- /**
- * The custom launch command of this component (optional). When specified at
- * the component level, it overrides the value specified at the global level
- * (if any).
- **/
- public Component launchCommand(String launchCommand) {
- this.launchCommand = launchCommand;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "The custom launch command of this component (optional). When specified at the component level, it overrides the value specified at the global level (if any).")
- @JsonProperty("launch_command")
- public String getLaunchCommand() {
- return launchCommand;
- }
-
- @XmlElement(name = "launch_command")
- public void setLaunchCommand(String launchCommand) {
- this.launchCommand = launchCommand;
- }
-
- /**
- * Resource of this component (optional). If not specified, the application
- * level global resource takes effect.
- **/
- public Component resource(Resource resource) {
- this.resource = resource;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Resource of this component (optional). If not specified, the application level global resource takes effect.")
- @JsonProperty("resource")
- public Resource getResource() {
- return resource;
- }
-
- public void setResource(Resource resource) {
- this.resource = resource;
- }
-
- /**
- * Number of containers for this app-component (optional). If not specified,
- * the application level global number_of_containers takes effect.
- **/
- public Component numberOfContainers(Long numberOfContainers) {
- this.numberOfContainers = numberOfContainers;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Number of containers for this app-component (optional). If not specified, the application level global number_of_containers takes effect.")
- @JsonProperty("number_of_containers")
- public Long getNumberOfContainers() {
- return numberOfContainers;
- }
-
- @XmlElement(name = "number_of_containers")
- public void setNumberOfContainers(Long numberOfContainers) {
- this.numberOfContainers = numberOfContainers;
- }
-
- @ApiModelProperty(example = "null", value = "Containers of a started component. Specifying a value for this attribute for the POST payload raises a validation error. This blob is available only in the GET response of a started application.")
- @JsonProperty("containers")
- public List<Container> getContainers() {
- return containers;
- }
-
- public void setContainers(List<Container> containers) {
- this.containers = containers;
- }
-
- public void addContainer(Container container) {
- this.containers.add(container);
- }
-
- public void removeContainer(Container container) {
- containers.remove(container);
- }
- public Container getContainer(String id) {
- for (Container container : containers) {
- if (container.getId().equals(id)) {
- return container;
- }
- }
- return null;
- }
-
- /**
- * Certain applications need to define multiple components using the same
- * artifact and resource profile, differing only in configurations. In such
- * cases, this field helps app owners to avoid creating multiple component
- * definitions with repeated information. The number_of_containers field
- * dictates the initial number of components created. Component names
- * typically differ with a trailing id, but assumptions should not be made on
- * that, as the algorithm can change at any time. Configurations section will
- * be able to use placeholders like ${USER}, ${CLUSTER_NAME} and
- * ${COMPONENT_NAME} to be replaced at runtime with user the app is submitted
- * as, application name and application component name respectively. Launch
- * command can use placeholders like ${APP_COMPONENT_NAME} and ${APP_NAME} to
- * get its component name and app name respectively at runtime. The best part
- * of this feature is that when the component is flexed up, entirely new
- * components (with new trailing ids) are created.
- **/
- public Component uniqueComponentSupport(Boolean uniqueComponentSupport) {
- this.uniqueComponentSupport = uniqueComponentSupport;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Certain applications need to define multiple components using the same artifact and resource profile, differing only in configurations. In such cases, this field helps app owners to avoid creating multiple component definitions with repeated information. The number_of_containers field dictates the initial number of components created. Component names typically differ with a trailing id, but assumptions should not be made on that, as the algorithm can change at any time. Configurations section will be able to use placeholders like ${USER}, ${CLUSTER_NAME} and ${COMPONENT_NAME} to be replaced at runtime with user the app is submitted as, application name and application component name respectively. Launch command can use placeholders like ${APP_COMPONENT_NAME} and ${APP_NAME} to get its component name and app name respectively at runtime. The best part of this feature is that when the component is flexed up, entirely new components (with
new trailing ids) are created.")
- @JsonProperty("unique_component_support")
- public Boolean getUniqueComponentSupport() {
- return uniqueComponentSupport;
- }
-
- @XmlElement(name = "unique_component_support")
- public void setUniqueComponentSupport(Boolean uniqueComponentSupport) {
- this.uniqueComponentSupport = uniqueComponentSupport;
- }
-
- /**
- * Run all containers of this component in privileged mode (YARN-4262).
- **/
- public Component runPrivilegedContainer(Boolean runPrivilegedContainer) {
- this.runPrivilegedContainer = runPrivilegedContainer;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Run all containers of this component in privileged mode (YARN-4262).")
- @JsonProperty("run_privileged_container")
- public Boolean getRunPrivilegedContainer() {
- return runPrivilegedContainer;
- }
-
- @XmlElement(name = "run_privileged_container")
- public void setRunPrivilegedContainer(Boolean runPrivilegedContainer) {
- this.runPrivilegedContainer = runPrivilegedContainer;
- }
-
- /**
- * Advanced scheduling and placement policies for all containers of this
- * component (optional). If not specified, the app level placement_policy
- * takes effect. Refer to the description at the global level for more
- * details.
- **/
- public Component placementPolicy(PlacementPolicy placementPolicy) {
- this.placementPolicy = placementPolicy;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Advanced scheduling and placement policies for all containers of this component (optional). If not specified, the app level placement_policy takes effect. Refer to the description at the global level for more details.")
- @JsonProperty("placement_policy")
- public PlacementPolicy getPlacementPolicy() {
- return placementPolicy;
- }
-
- @XmlElement(name = "placement_policy")
- public void setPlacementPolicy(PlacementPolicy placementPolicy) {
- this.placementPolicy = placementPolicy;
- }
-
- /**
- * Config properties for this app-component.
- **/
- public Component configuration(Configuration configuration) {
- this.configuration = configuration;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Config properties for this app-component.")
- @JsonProperty("configuration")
- public Configuration getConfiguration() {
- return configuration;
- }
-
- public void setConfiguration(Configuration configuration) {
- this.configuration = configuration;
- }
-
- /**
- * A list of quicklink keys defined at the application level, and to be
- * resolved by this component.
- **/
- public Component quicklinks(List<String> quicklinks) {
- this.quicklinks = quicklinks;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "A list of quicklink keys defined at the application level, and to be resolved by this component.")
- @JsonProperty("quicklinks")
- public List<String> getQuicklinks() {
- return quicklinks;
- }
-
- public void setQuicklinks(List<String> quicklinks) {
- this.quicklinks = quicklinks;
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- Component component = (Component) o;
- return Objects.equals(this.name, component.name)
- && Objects.equals(this.dependencies, component.dependencies)
- && Objects.equals(this.readinessCheck, component.readinessCheck)
- && Objects.equals(this.artifact, component.artifact)
- && Objects.equals(this.launchCommand, component.launchCommand)
- && Objects.equals(this.resource, component.resource)
- && Objects.equals(this.numberOfContainers, component.numberOfContainers)
- && Objects.equals(this.uniqueComponentSupport,
- component.uniqueComponentSupport)
- && Objects.equals(this.runPrivilegedContainer,
- component.runPrivilegedContainer)
- && Objects.equals(this.placementPolicy, component.placementPolicy)
- && Objects.equals(this.configuration, component.configuration)
- && Objects.equals(this.quicklinks, component.quicklinks);
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(name, dependencies, readinessCheck, artifact,
- launchCommand, resource, numberOfContainers, uniqueComponentSupport,
- runPrivilegedContainer, placementPolicy, configuration, quicklinks);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append("class Component {\n");
-
- sb.append(" name: ").append(toIndentedString(name)).append("\n");
- sb.append(" dependencies: ").append(toIndentedString(dependencies))
- .append("\n");
- sb.append(" readinessCheck: ").append(toIndentedString(readinessCheck))
- .append("\n");
- sb.append(" artifact: ").append(toIndentedString(artifact)).append("\n");
- sb.append(" launchCommand: ").append(toIndentedString(launchCommand))
- .append("\n");
- sb.append(" resource: ").append(toIndentedString(resource)).append("\n");
- sb.append(" numberOfContainers: ")
- .append(toIndentedString(numberOfContainers)).append("\n");
- sb.append(" containers: ").append(toIndentedString(containers))
- .append("\n");
- sb.append(" uniqueComponentSupport: ")
- .append(toIndentedString(uniqueComponentSupport)).append("\n");
- sb.append(" runPrivilegedContainer: ")
- .append(toIndentedString(runPrivilegedContainer)).append("\n");
- sb.append(" placementPolicy: ").append(toIndentedString(placementPolicy))
- .append("\n");
- sb.append(" configuration: ").append(toIndentedString(configuration))
- .append("\n");
- sb.append(" quicklinks: ").append(toIndentedString(quicklinks))
- .append("\n");
- sb.append("}");
- return sb.toString();
- }
-
- /**
- * Convert the given object to string with each line indented by 4 spaces
- * (except the first line).
- */
- private String toIndentedString(java.lang.Object o) {
- if (o == null) {
- return "null";
- }
- return o.toString().replace("\n", "\n ");
- }
-
- /**
- * Merge from another component into this component without overwriting.
- */
- public void mergeFrom(Component that) {
- if (this.getArtifact() == null) {
- this.setArtifact(that.getArtifact());
- }
- if (this.getResource() == null) {
- this.setResource(that.getResource());
- }
- if (this.getNumberOfContainers() == null) {
- this.setNumberOfContainers(that.getNumberOfContainers());
- }
- if (this.getLaunchCommand() == null) {
- this.setLaunchCommand(that.getLaunchCommand());
- }
- this.getConfiguration().mergeFrom(that.getConfiguration());
- if (this.getQuicklinks() == null) {
- this.setQuicklinks(that.getQuicklinks());
- }
- if (this.getRunPrivilegedContainer() == null) {
- this.setRunPrivilegedContainer(that.getRunPrivilegedContainer());
- }
- if (this.getUniqueComponentSupport() == null) {
- this.setUniqueComponentSupport(that.getUniqueComponentSupport());
- }
- if (this.getDependencies() == null) {
- this.setDependencies(that.getDependencies());
- }
- if (this.getPlacementPolicy() == null) {
- this.setPlacementPolicy(that.getPlacementPolicy());
- }
- if (this.getReadinessCheck() == null) {
- this.setReadinessCheck(that.getReadinessCheck());
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/hadoop/blob/727e6d78/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ConfigFile.java
----------------------------------------------------------------------
diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ConfigFile.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ConfigFile.java
deleted file mode 100644
index b4040b6..0000000
--- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-slider/hadoop-yarn-slider-core/src/main/java/org/apache/slider/api/resource/ConfigFile.java
+++ /dev/null
@@ -1,222 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.slider.api.resource;
-
-import com.fasterxml.jackson.annotation.JsonInclude;
-import com.fasterxml.jackson.annotation.JsonProperty;
-import com.fasterxml.jackson.annotation.JsonValue;
-import io.swagger.annotations.ApiModel;
-import io.swagger.annotations.ApiModelProperty;
-
-import javax.xml.bind.annotation.XmlElement;
-import javax.xml.bind.annotation.XmlRootElement;
-import java.io.Serializable;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Objects;
-
-/**
- * A config file that needs to be created and made available as a volume in an
- * application component container.
- **/
-
-@ApiModel(description = "A config file that needs to be created and made available as a volume in an application component container.")
-@javax.annotation.Generated(value = "class io.swagger.codegen.languages.JavaClientCodegen", date = "2016-06-02T08:15:05.615-07:00")
-@XmlRootElement
-@JsonInclude(JsonInclude.Include.NON_NULL)
-public class ConfigFile implements Serializable {
- private static final long serialVersionUID = -7009402089417704612L;
-
- public enum TypeEnum {
- XML("XML"), PROPERTIES("PROPERTIES"), JSON("JSON"), YAML("YAML"), TEMPLATE(
- "TEMPLATE"), ENV("ENV"), HADOOP_XML("HADOOP_XML"),;
-
- private String value;
-
- TypeEnum(String value) {
- this.value = value;
- }
-
- @Override
- @JsonValue
- public String toString() {
- return value;
- }
- }
-
- private TypeEnum type = null;
- private String destFile = null;
- private String srcFile = null;
- private Map<String, String> props = new HashMap<>();
-
- public ConfigFile copy() {
- ConfigFile copy = new ConfigFile();
- copy.setType(this.getType());
- copy.setSrcFile(this.getSrcFile());
- copy.setDestFile(this.getDestFile());
- if (this.getProps() != null && !this.getProps().isEmpty()) {
- copy.getProps().putAll(this.getProps());
- }
- return copy;
- }
-
- /**
- * Config file in the standard format like xml, properties, json, yaml,
- * template.
- **/
- public ConfigFile type(TypeEnum type) {
- this.type = type;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "Config file in the standard format like xml, properties, json, yaml, template.")
- @JsonProperty("type")
- public TypeEnum getType() {
- return type;
- }
-
- public void setType(TypeEnum type) {
- this.type = type;
- }
-
- /**
- * The absolute path that this configuration file should be mounted as, in the
- * application container.
- **/
- public ConfigFile destFile(String destFile) {
- this.destFile = destFile;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "The absolute path that this configuration file should be mounted as, in the application container.")
- @JsonProperty("dest_file")
- public String getDestFile() {
- return destFile;
- }
-
- @XmlElement(name = "dest_file")
- public void setDestFile(String destFile) {
- this.destFile = destFile;
- }
-
- /**
- * This provides the source location of the configuration file, the content
- * of which is dumped to dest_file post property substitutions, in the format
- * as specified in type. Typically the src_file would point to a source
- * controlled network accessible file maintained by tools like puppet, chef,
- * or hdfs etc. Currently, only hdfs is supported.
- **/
- public ConfigFile srcFile(String srcFile) {
- this.srcFile = srcFile;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "This provides the source location of the configuration file, "
- + "the content of which is dumped to dest_file post property substitutions, in the format as specified in type. "
- + "Typically the src_file would point to a source controlled network accessible file maintained by tools like puppet, chef, or hdfs etc. Currently, only hdfs is supported.")
- @JsonProperty("src_file")
- public String getSrcFile() {
- return srcFile;
- }
-
- @XmlElement(name = "src_file")
- public void setSrcFile(String srcFile) {
- this.srcFile = srcFile;
- }
-
- /**
- A blob of key value pairs that will be dumped in the dest_file in the format
- as specified in type. If src_file is specified, src_file content are dumped
- in the dest_file and these properties will overwrite, if any, existing
- properties in src_file or be added as new properties in src_file.
- **/
- public ConfigFile props(Map<String, String> props) {
- this.props = props;
- return this;
- }
-
- @ApiModelProperty(example = "null", value = "A blob of key value pairs that will be dumped in the dest_file in the format as specified in type."
- + " If src_file is specified, src_file content are dumped in the dest_file and these properties will overwrite, if any,"
- + " existing properties in src_file or be added as new properties in src_file.")
- @JsonProperty("props")
- public Map<String, String> getProps() {
- return props;
- }
-
- public void setProps(Map<String, String> props) {
- this.props = props;
- }
-
- public long getLong(String name, long defaultValue) {
- if (name == null) {
- return defaultValue;
- }
- String value = props.get(name.trim());
- return Long.parseLong(value);
- }
-
- public boolean getBoolean(String name, boolean defaultValue) {
- if (name == null) {
- return defaultValue;
- }
- return Boolean.valueOf(props.get(name.trim()));
- }
-
- @Override
- public boolean equals(java.lang.Object o) {
- if (this == o) {
- return true;
- }
- if (o == null || getClass() != o.getClass()) {
- return false;
- }
- ConfigFile configFile = (ConfigFile) o;
- return Objects.equals(this.type, configFile.type)
- && Objects.equals(this.destFile, configFile.destFile)
- && Objects.equals(this.srcFile, configFile.srcFile);
- }
-
- @Override
- public int hashCode() {
- return Objects.hash(type, destFile, srcFile, props);
- }
-
- @Override
- public String toString() {
- StringBuilder sb = new StringBuilder();
- sb.append("class ConfigFile {\n");
-
- sb.append(" type: ").append(toIndentedString(type)).append("\n");
- sb.append(" destFile: ").append(toIndentedString(destFile)).append("\n");
- sb.append(" srcFile: ").append(toIndentedString(srcFile)).append("\n");
- sb.append(" props: ").append(toIndentedString(props)).append("\n");
- sb.append("}");
- return sb.toString();
- }
-
- /**
- * Convert the given object to string with each line indented by 4 spaces
- * (except the first line).
- */
- private String toIndentedString(java.lang.Object o) {
- if (o == null) {
- return "null";
- }
- return o.toString().replace("\n", "\n ");
- }
-}
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org