http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java b/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java index 2226b46..8bfa634 100644 --- a/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/coord/CoordSubmitXCommand.java @@ -197,9 +197,6 @@ public class CoordSubmitXCommand extends SubmitTransitionXCommand { this.dryrun = dryrun; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#execute() - */ @Override protected String submit() throws CommandException { LOG.info("STARTED Coordinator Submit"); @@ -1294,25 +1291,16 @@ public class CoordSubmitXCommand extends SubmitTransitionXCommand { } } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#getEntityKey() - */ @Override public String getEntityKey() { return null; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#isLockRequired() - */ @Override protected boolean isLockRequired() { return false; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#loadState() - */ @Override protected void loadState() throws CommandException { jpaService = Services.get().get(JPAService.class); @@ -1334,17 +1322,11 @@ public class CoordSubmitXCommand extends SubmitTransitionXCommand { } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#verifyPrecondition() - */ @Override protected void verifyPrecondition() throws CommandException { } - /* (non-Javadoc) - * @see org.apache.oozie.command.TransitionXCommand#notifyParent() - */ @Override public void notifyParent() throws CommandException { // update bundle action @@ -1355,16 +1337,10 @@ public class CoordSubmitXCommand extends SubmitTransitionXCommand { } } - /* (non-Javadoc) - * @see org.apache.oozie.command.TransitionXCommand#updateJob() - */ @Override public void updateJob() throws CommandException { } - /* (non-Javadoc) - * @see org.apache.oozie.command.TransitionXCommand#getJob() - */ @Override public Job getJob() { return coordJob;
http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/coord/CoordUnpauseXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/coord/CoordUnpauseXCommand.java b/core/src/main/java/org/apache/oozie/command/coord/CoordUnpauseXCommand.java index a651f27..873ee7b 100644 --- a/core/src/main/java/org/apache/oozie/command/coord/CoordUnpauseXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/coord/CoordUnpauseXCommand.java @@ -43,51 +43,26 @@ public class CoordUnpauseXCommand extends UnpauseTransitionXCommand { this.coordJob = coordJob; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#getEntityKey() - */ @Override public String getEntityKey() { return coordJob.getId(); } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#isLockRequired() - */ @Override protected boolean isLockRequired() { return true; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#loadState() - */ @Override public void loadState() throws CommandException { prevStatus = coordJob.getStatus(); LogUtils.setLogInfo(coordJob); } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#verifyPrecondition() - */ @Override protected void verifyPrecondition() throws CommandException, PreconditionException { } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.TransitionXCommand#notifyParent() - */ @Override public void notifyParent() throws CommandException { // update bundle action @@ -97,21 +72,11 @@ public class CoordUnpauseXCommand extends UnpauseTransitionXCommand { } } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.TransitionXCommand#getJob() - */ @Override public Job getJob() { return coordJob; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.TransitionXCommand#updateJob() - */ @Override public void updateJob() throws CommandException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/coord/CoordWfActionInfoXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/coord/CoordWfActionInfoXCommand.java b/core/src/main/java/org/apache/oozie/command/coord/CoordWfActionInfoXCommand.java index 8536ed9..f8d6a6a 100644 --- a/core/src/main/java/org/apache/oozie/command/coord/CoordWfActionInfoXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/coord/CoordWfActionInfoXCommand.java @@ -93,10 +93,6 @@ public class CoordWfActionInfoXCommand extends CoordinatorXCommand<List<Coordina return coordWfActions; } - /** - * (non-Javadoc) - * @see org.apache.oozie.command.XCommand#loadState() - **/ @Override protected void loadState() throws CommandException { jpaService = Services.get().get(JPAService.class); @@ -114,31 +110,17 @@ public class CoordWfActionInfoXCommand extends CoordinatorXCommand<List<Coordina } } - /** - * (non-Javadoc) - * @see org.apache.oozie.command.XCommand#verifyPrecondition() - * no-op - **/ @Override protected void verifyPrecondition() throws CommandException, PreconditionException { } - /** - * (non-Javadoc) - * @see org.apache.oozie.command.XCommand#isLockRequired() - **/ @Override protected boolean isLockRequired() { return false; } - /** - * (non-Javadoc) - * @see org.apache.oozie.command.XCommand#getEntityKey() - **/ @Override public String getEntityKey() { return null; } - } http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/wf/ActionStartXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/wf/ActionStartXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/ActionStartXCommand.java index ab40c6e..ea61e22 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/ActionStartXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/ActionStartXCommand.java @@ -391,9 +391,6 @@ public class ActionStartXCommand extends ActionXCommand<org.apache.oozie.command return; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#getKey() - */ @Override public String getKey(){ return getName() + "_" + actionId; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java index 7e328b7..290a07b 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/ActionXCommand.java @@ -322,26 +322,14 @@ public abstract class ActionXCommand<T> extends WorkflowXCommand<T> { this(workflow, action, false, false); } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#getCallbackUrl(java.lang.String) - */ public String getCallbackUrl(String externalStatusVar) { return Services.get().get(CallbackService.class).createCallBackUrl(action.getId(), externalStatusVar); } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#getProtoActionConf() - */ public Configuration getProtoActionConf() { return protoConf; } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#getWorkflow() - */ public WorkflowJob getWorkflow() { return workflow; } @@ -355,20 +343,12 @@ public abstract class ActionXCommand<T> extends WorkflowXCommand<T> { return action; } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#getELEvaluator() - */ public ELEvaluator getELEvaluator() { ELEvaluator evaluator = Services.get().get(ELService.class).createEvaluator("workflow"); DagELFunctions.configureEvaluator(evaluator, workflow, action); return evaluator; } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#setVar(java.lang.String, java.lang.String) - */ public void setVar(String name, String value) { setVarToWorkflow(name, value); } @@ -385,19 +365,11 @@ public abstract class ActionXCommand<T> extends WorkflowXCommand<T> { workflow.setWorkflowInstance(wfInstance); } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#getVar(java.lang.String) - */ public String getVar(String name) { name = action.getName() + WorkflowInstance.NODE_VAR_SEPARATOR + name; return workflow.getWorkflowInstance().getVar(name); } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#setStartData(java.lang.String, java.lang.String, java.lang.String) - */ public void setStartData(String externalId, String trackerUri, String consoleUrl) { setVar(JobUtils.getRetryKey(action, JsonTags.WORKFLOW_ACTION_CONSOLE_URL), consoleUrl); action.setStartData(externalId, trackerUri, consoleUrl); @@ -412,48 +384,27 @@ public abstract class ActionXCommand<T> extends WorkflowXCommand<T> { action.setStartTime(now); } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#setExecutionData(java.lang.String, java.util.Properties) - */ public void setExecutionData(String externalStatus, Properties actionData) { action.setExecutionData(externalStatus, actionData); executed = true; } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#setExecutionStats(java.lang.String) - */ public void setExecutionStats(String jsonStats) { action.setExecutionStats(jsonStats); executed = true; } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#setExternalChildIDs(java.lang.String) - */ public void setExternalChildIDs(String externalChildIDs) { setVar(JobUtils.getRetryKey(action, JsonTags.WORKFLOW_ACTION_EXTERNAL_CHILD_IDS), externalChildIDs); action.setExternalChildIDs(externalChildIDs); executed = true; } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#setEndData(org.apache.oozie.client.WorkflowAction.Status, - * java.lang.String) - */ public void setEndData(WorkflowAction.Status status, String signalValue) { action.setEndData(status, signalValue); ended = true; } - /* - * (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#isRetry() - */ public boolean isRetry() { return isRetry; } @@ -503,9 +454,6 @@ public abstract class ActionXCommand<T> extends WorkflowXCommand<T> { return action.getId() + RECOVERY_ID_SEPARATOR + workflow.getRun(); } - /* (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#getActionDir() - */ public Path getActionDir() throws HadoopAccessorException, IOException, URISyntaxException { String name = getWorkflow().getId() + "/" + action.getName() + "--" + action.getType(); FileSystem fs = getAppFileSystem(); @@ -514,9 +462,6 @@ public abstract class ActionXCommand<T> extends WorkflowXCommand<T> { return fqActionDir; } - /* (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#getAppFileSystem() - */ public FileSystem getAppFileSystem() throws HadoopAccessorException, IOException, URISyntaxException { WorkflowJob workflow = getWorkflow(); URI uri = new URI(getWorkflow().getAppPath()); @@ -526,9 +471,6 @@ public abstract class ActionXCommand<T> extends WorkflowXCommand<T> { } - /* (non-Javadoc) - * @see org.apache.oozie.action.ActionExecutor.Context#setErrorInfo(java.lang.String, java.lang.String) - */ @Override public void setErrorInfo(String str, String exMsg) { action.setErrorInfo(str, exMsg); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/wf/BulkWorkflowXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/wf/BulkWorkflowXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/BulkWorkflowXCommand.java index 4e0b606..74dfd52 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/BulkWorkflowXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/BulkWorkflowXCommand.java @@ -54,9 +54,6 @@ public class BulkWorkflowXCommand extends WorkflowXCommand<WorkflowsInfo> { this.operation = operation; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#execute() - */ @Override protected WorkflowsInfo execute() throws CommandException { try { @@ -93,33 +90,21 @@ public class BulkWorkflowXCommand extends WorkflowXCommand<WorkflowsInfo> { } } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#getEntityKey() - */ @Override public String getEntityKey() { return null; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#isLockRequired() - */ @Override protected boolean isLockRequired() { return false; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#loadState() - */ @Override protected void loadState() throws CommandException { loadJobs(); } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#verifyPrecondition() - */ @Override protected void verifyPrecondition() throws CommandException, PreconditionException { } http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java index 26397e0..69de432 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/CompletedActionXCommand.java @@ -63,11 +63,6 @@ public class CompletedActionXCommand extends WorkflowXCommand<Void> { LogUtils.setLogInfo(actionId); } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#eagerLoadState() - */ @Override protected void eagerLoadState() throws CommandException { try { @@ -80,11 +75,6 @@ public class CompletedActionXCommand extends WorkflowXCommand<Void> { LogUtils.setLogInfo(this.wfactionBean); } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#eagerVerifyPrecondition() - */ @Override protected void eagerVerifyPrecondition() throws CommandException, PreconditionException { if (this.wfactionBean.getStatus() != WorkflowActionBean.Status.RUNNING @@ -93,11 +83,6 @@ public class CompletedActionXCommand extends WorkflowXCommand<Void> { } } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#execute() - */ @Override protected Void execute() throws CommandException { // If the action is still in PREP, we probably received a callback before Oozie was able to update from PREP to RUNNING; @@ -124,41 +109,21 @@ public class CompletedActionXCommand extends WorkflowXCommand<Void> { return null; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#getEntityKey() - */ @Override public String getEntityKey() { return null; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#isLockRequired() - */ @Override protected boolean isLockRequired() { return false; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#loadState() - */ @Override protected void loadState() throws CommandException { eagerLoadState(); } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.command.XCommand#verifyPrecondition() - */ @Override protected void verifyPrecondition() throws CommandException, PreconditionException { eagerVerifyPrecondition(); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java index 3b6cb35..347b28d 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/JobXCommand.java @@ -57,9 +57,6 @@ public class JobXCommand extends WorkflowXCommand<WorkflowJobBean> { this.len = length; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#execute() - */ @Override protected WorkflowJobBean execute() throws CommandException { try { @@ -92,32 +89,20 @@ public class JobXCommand extends WorkflowXCommand<WorkflowJobBean> { return (consoleUrl != null) ? consoleUrl + jobId : null; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#getEntityKey() - */ @Override public String getEntityKey() { return this.id; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#isLockRequired() - */ @Override protected boolean isLockRequired() { return false; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#loadState() - */ @Override protected void loadState() throws CommandException { } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#verifyPrecondition() - */ @Override protected void verifyPrecondition() throws CommandException, PreconditionException { } http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java index 29ac8ad..a82b03b 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/JobsXCommand.java @@ -51,9 +51,6 @@ public class JobsXCommand extends WorkflowXCommand<WorkflowsInfo> { this.len = length; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#execute() - */ @Override protected WorkflowsInfo execute() throws CommandException { try { @@ -74,32 +71,20 @@ public class JobsXCommand extends WorkflowXCommand<WorkflowsInfo> { } } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#getEntityKey() - */ @Override public String getEntityKey() { return null; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#isLockRequired() - */ @Override protected boolean isLockRequired() { return false; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#loadState() - */ @Override protected void loadState() throws CommandException { } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#verifyPrecondition() - */ @Override protected void verifyPrecondition() throws CommandException, PreconditionException { } http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java index 178ae27..f4497c5 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/ReRunXCommand.java @@ -120,9 +120,6 @@ public class ReRunXCommand extends WorkflowXCommand<Void> { LogUtils.setLogInfo(jobId); } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#execute() - */ @Override protected Void execute() throws CommandException { setupReRun(); @@ -398,25 +395,16 @@ public class ReRunXCommand extends WorkflowXCommand<Void> { newWfInstance.setAllVars(newVars); } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#getEntityKey() - */ @Override public String getEntityKey() { return this.jobId; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#isLockRequired() - */ @Override protected boolean isLockRequired() { return true; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#loadState() - */ @Override protected void loadState() throws CommandException { try { @@ -429,9 +417,6 @@ public class ReRunXCommand extends WorkflowXCommand<Void> { } } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#verifyPrecondition() - */ @Override protected void verifyPrecondition() throws CommandException, PreconditionException { eagerVerifyPrecondition(); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java index 98d0f3c..1762800 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/SubmitHttpXCommand.java @@ -175,9 +175,6 @@ public abstract class SubmitHttpXCommand extends WorkflowXCommand<String> { return configuration; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#execute() - */ @Override protected String execute() throws CommandException { InstrumentUtils.incrJobCounter(getName(), 1, getInstrumentation()); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/command/wf/WorkflowActionInfoXCommand.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/command/wf/WorkflowActionInfoXCommand.java b/core/src/main/java/org/apache/oozie/command/wf/WorkflowActionInfoXCommand.java index 895d549..8ce2c84 100644 --- a/core/src/main/java/org/apache/oozie/command/wf/WorkflowActionInfoXCommand.java +++ b/core/src/main/java/org/apache/oozie/command/wf/WorkflowActionInfoXCommand.java @@ -56,25 +56,16 @@ public class WorkflowActionInfoXCommand extends WorkflowXCommand<WorkflowActionB } } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#getEntityKey() - */ @Override public String getEntityKey() { return null; } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#loadState() - */ @Override protected void loadState() { } - /* (non-Javadoc) - * @see org.apache.oozie.command.XCommand#verifyPrecondition() - */ @Override protected void verifyPrecondition() throws CommandException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java index 3701a3e..3293efd 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionGetJPAExecutor.java @@ -46,17 +46,11 @@ public class BundleActionGetJPAExecutor implements JPAExecutor<BundleActionBean> this.bundleActionId = bundleId + "_" + coordName; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "BundleActionGetJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public BundleActionBean execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionInsertJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionInsertJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionInsertJPAExecutor.java index 02522a1..4b99c1a 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionInsertJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleActionInsertJPAExecutor.java @@ -40,17 +40,11 @@ public class BundleActionInsertJPAExecutor implements JPAExecutor<Void> { this.bundleAction = bundleAction; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "BundleActionInsertJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public Void execute(EntityManager em) throws JPAExecutorException { em.persist(bundleAction); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java index 579cd5c..2f4665e 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetCoordinatorsJPAExecutor.java @@ -38,17 +38,11 @@ public class BundleJobGetCoordinatorsJPAExecutor implements JPAExecutor<List<Coo this.bundleId = bundleId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "BundleJobGetCoordinatorsJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public List<CoordinatorJobBean> execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetForUserJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetForUserJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetForUserJPAExecutor.java index e14f8ae..aef9eb7 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetForUserJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetForUserJPAExecutor.java @@ -37,21 +37,10 @@ public class BundleJobGetForUserJPAExecutor implements JPAExecutor<String> { this.bundleJobId = bundleJobId; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ public String getName() { return "BundleJobGetForUserJPAExecutor"; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence. - * EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java index 14699e3..7f98cd2 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobGetJPAExecutor.java @@ -39,17 +39,11 @@ public class BundleJobGetJPAExecutor implements JPAExecutor<BundleJobBean> { this.bundleJobId = bundleJobId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "BundleJobGetJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public BundleJobBean execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInfoGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInfoGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInfoGetJPAExecutor.java index f4fe0ef..6e1ea3e 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInfoGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInfoGetJPAExecutor.java @@ -64,17 +64,11 @@ public class BundleJobInfoGetJPAExecutor implements JPAExecutor<BundleJobInfo> { this.len = len; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "BundleJobInfoGetJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public BundleJobInfo execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInsertJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInsertJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInsertJPAExecutor.java index cb253f1..e7373d6 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInsertJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobInsertJPAExecutor.java @@ -35,18 +35,12 @@ public class BundleJobInsertJPAExecutor implements JPAExecutor<String> { this.bundleJob = bundleJob; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { em.persist(this.bundleJob); return null; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "BundleJobInsertJPAExecutor"; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsDeleteJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsDeleteJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsDeleteJPAExecutor.java index c651d85..afd7903 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsDeleteJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsDeleteJPAExecutor.java @@ -52,22 +52,11 @@ public class BundleJobsDeleteJPAExecutor implements JPAExecutor<Integer> { this.deleteList = deleteList; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "BundleJobsDeleteJPAExecutor"; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence. - * EntityManager) - */ @Override public Integer execute(EntityManager em) throws JPAExecutorException { int actionsDeleted = 0; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java index f986c22..8a59458 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetForPurgeJPAExecutor.java @@ -46,17 +46,11 @@ public class BundleJobsGetForPurgeJPAExecutor implements JPAExecutor<List<String this.limit = limit; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "BundleJobsGetForPurgeJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public List<String> execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java index bfb0b84..1ae13db 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/BundleJobsGetRunningOrPendingJPAExecutor.java @@ -38,17 +38,11 @@ public class BundleJobsGetRunningOrPendingJPAExecutor implements JPAExecutor<Lis this.limit = limit; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "BundleJobsGetRunningOrPendingJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public List<BundleJobBean> execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java index 7e217b4..9e8b331 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForCheckJPAExecutor.java @@ -43,17 +43,11 @@ public class CoordActionGetForCheckJPAExecutor implements JPAExecutor<Coordinato this.coordActionId = coordActionId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionGetForCheckJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public CoordinatorActionBean execute(EntityManager em) throws JPAExecutorException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java index 31c4715..61614e9 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForExternalIdJPAExecutor.java @@ -43,17 +43,11 @@ public class CoordActionGetForExternalIdJPAExecutor implements JPAExecutor<Coord this.externalId = externalId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionGetForExternalIdJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public CoordinatorActionBean execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java index a9cf0ff..211d594 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInfoJPAExecutor.java @@ -46,17 +46,11 @@ public class CoordActionGetForInfoJPAExecutor implements JPAExecutor<Coordinator this.coordActionId = coordActionId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionGetForInfoJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public CoordinatorActionBean execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java index 2023678..484ff93 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForInputCheckJPAExecutor.java @@ -41,17 +41,11 @@ public class CoordActionGetForInputCheckJPAExecutor implements JPAExecutor<Coord this.coordActionId = coordActionId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionGetForInputCheckJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public CoordinatorActionBean execute(EntityManager em) throws JPAExecutorException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java index a2a846e..14b831d 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForStartJPAExecutor.java @@ -42,17 +42,11 @@ public class CoordActionGetForStartJPAExecutor implements JPAExecutor<Coordinato this.coordActionId = coordActionId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionGetForStartJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public CoordinatorActionBean execute(EntityManager em) throws JPAExecutorException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java index ba309eb..c720be9 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetForTimeoutJPAExecutor.java @@ -42,17 +42,11 @@ public class CoordActionGetForTimeoutJPAExecutor implements JPAExecutor<Coordina this.coordActionId = coordActionId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionGetForTimeoutJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public CoordinatorActionBean execute(EntityManager em) throws JPAExecutorException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java index 864ee63..53214ea 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionGetJPAExecutor.java @@ -39,17 +39,11 @@ public class CoordActionGetJPAExecutor implements JPAExecutor<CoordinatorActionB this.coordActionId = coordActionId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionGetJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public CoordinatorActionBean execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionInsertJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionInsertJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionInsertJPAExecutor.java index eb061c2..09e8857 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionInsertJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionInsertJPAExecutor.java @@ -35,17 +35,11 @@ public class CoordActionInsertJPAExecutor implements JPAExecutor<String> { this.coordAction = coordAction; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionInsertJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { em.persist(coordAction); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java index bedff49..25b8f36 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionRemoveJPAExecutor.java @@ -42,9 +42,6 @@ public class CoordActionRemoveJPAExecutor implements JPAExecutor<Void> { this.coordActionId = coordActionId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public Void execute(EntityManager em) throws JPAExecutorException { Query g = em.createNamedQuery("DELETE_UNSCHEDULED_ACTION"); @@ -62,9 +59,6 @@ public class CoordActionRemoveJPAExecutor implements JPAExecutor<Void> { return null; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionRemoveJPAExecutor"; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsDeleteJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsDeleteJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsDeleteJPAExecutor.java index 8dd20cc..97584e8 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsDeleteJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsDeleteJPAExecutor.java @@ -50,22 +50,11 @@ public class CoordActionsDeleteJPAExecutor implements JPAExecutor<Integer> { this.deleteList = deleteList; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionsDeleteJPAExecutor"; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence. - * EntityManager) - */ @Override public Integer execute(EntityManager em) throws JPAExecutorException { int actionsDeleted = 0; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java index b444f05..a0ebdd3 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordActionsRunningGetJPAExecutor.java @@ -39,17 +39,11 @@ public class CoordActionsRunningGetJPAExecutor implements JPAExecutor<List<Strin this.checkAgeSecs = checkAgeSecs; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordActionsRunningGetJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public List<String> execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java index 68c0b75..49eb158 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetActionByActionNumberJPAExecutor.java @@ -38,17 +38,11 @@ public class CoordJobGetActionByActionNumberJPAExecutor implements JPAExecutor<S this.actionNumber = actionNumber; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordJobGetActionByActionNumberJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetJPAExecutor.java index 7dd3597..2c21057 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobGetJPAExecutor.java @@ -39,17 +39,11 @@ public class CoordJobGetJPAExecutor implements JPAExecutor<CoordinatorJobBean> { this.coordJobId = coordJobId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordJobGetJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public CoordinatorJobBean execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobInsertJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobInsertJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobInsertJPAExecutor.java index 1af83d9..c26bc69 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobInsertJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobInsertJPAExecutor.java @@ -35,17 +35,11 @@ public class CoordJobInsertJPAExecutor implements JPAExecutor<String> { this.coordJob = coordJob; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordJobInsertJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { em.persist(coordJob); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsCountNotForPurgeFromParentIdJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsCountNotForPurgeFromParentIdJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsCountNotForPurgeFromParentIdJPAExecutor.java index 15d56f9..82ac8fc 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsCountNotForPurgeFromParentIdJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsCountNotForPurgeFromParentIdJPAExecutor.java @@ -39,17 +39,11 @@ public class CoordJobsCountNotForPurgeFromParentIdJPAExecutor implements JPAExec this.parentId = parentId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordJobsCountNotForPurgeFromParentIdJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public Long execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsDeleteJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsDeleteJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsDeleteJPAExecutor.java index cbebef3..0a8eb9a 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsDeleteJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsDeleteJPAExecutor.java @@ -52,22 +52,11 @@ public class CoordJobsDeleteJPAExecutor implements JPAExecutor<Integer> { this.deleteList = deleteList; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordJobsDeleteJPAExecutor"; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence. - * EntityManager) - */ @Override public Integer execute(EntityManager em) throws JPAExecutorException { int actionsDeleted = 0; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetFromParentIdJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetFromParentIdJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetFromParentIdJPAExecutor.java index 13e270b..062845b 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetFromParentIdJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetFromParentIdJPAExecutor.java @@ -44,17 +44,11 @@ public class CoordJobsGetFromParentIdJPAExecutor implements JPAExecutor<List<Str this.limit = limit; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordJobsGetFromParentIdJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public List<String> execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetPendingJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetPendingJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetPendingJPAExecutor.java index 08781ad..24a3ea0 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetPendingJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsGetPendingJPAExecutor.java @@ -37,17 +37,11 @@ public class CoordJobsGetPendingJPAExecutor implements JPAExecutor<List<Coordina this.limit = limit; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordJobsGetPendingJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public List<CoordinatorJobBean> execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsToBeMaterializedJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsToBeMaterializedJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsToBeMaterializedJPAExecutor.java index 6d13ed1..6f30a42 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsToBeMaterializedJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordJobsToBeMaterializedJPAExecutor.java @@ -48,9 +48,6 @@ public class CoordJobsToBeMaterializedJPAExecutor implements JPAExecutor<List<Co this.limit = limit; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @SuppressWarnings("unchecked") @Override public List<CoordinatorJobBean> execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserAppnameJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserAppnameJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserAppnameJPAExecutor.java index 5520ab5..42505ea 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserAppnameJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserAppnameJPAExecutor.java @@ -38,22 +38,11 @@ public class CoordinatorJobGetForUserAppnameJPAExecutor implements JPAExecutor<C this.coordJobId = coordJobId; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordinatorJobGetForUserAppnameJPAExecutor"; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence. - * EntityManager) - */ @Override public CoordinatorJobBean execute(EntityManager em) throws JPAExecutorException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserJPAExecutor.java index 1f2c688..58f5393 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/CoordinatorJobGetForUserJPAExecutor.java @@ -37,22 +37,11 @@ public class CoordinatorJobGetForUserJPAExecutor implements JPAExecutor<String> this.wfJobId = wfJobId; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "CoordinatorJobGetForUserJPAExecutor"; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence. - * EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/SLAEventInsertJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/SLAEventInsertJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/SLAEventInsertJPAExecutor.java index bda1e48..8955419 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/SLAEventInsertJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/SLAEventInsertJPAExecutor.java @@ -36,17 +36,11 @@ public class SLAEventInsertJPAExecutor implements JPAExecutor<String> { this.slaEvent = slaEvent; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "SLAEventInsertJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { em.persist(slaEvent); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionDeleteJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionDeleteJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionDeleteJPAExecutor.java index 14dc45d..810f0e6 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionDeleteJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionDeleteJPAExecutor.java @@ -35,9 +35,6 @@ public class WorkflowActionDeleteJPAExecutor implements JPAExecutor<Void> { this.wfActionId = wfActionId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public Void execute(EntityManager em) throws JPAExecutorException { WorkflowActionBean action = em.find(WorkflowActionBean.class, this.wfActionId); @@ -47,9 +44,6 @@ public class WorkflowActionDeleteJPAExecutor implements JPAExecutor<Void> { return null; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowActionDeleteJPAExecutor"; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionGetJPAExecutor.java index f8ac11e..1c7a14b 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionGetJPAExecutor.java @@ -48,17 +48,11 @@ public class WorkflowActionGetJPAExecutor implements JPAExecutor<WorkflowActionB this.isNullAcceptable = isNullAcceptable; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowActionGetJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public WorkflowActionBean execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionInsertJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionInsertJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionInsertJPAExecutor.java index f52af61..637f2e0 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionInsertJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionInsertJPAExecutor.java @@ -35,17 +35,11 @@ public class WorkflowActionInsertJPAExecutor implements JPAExecutor<String> { this.wfAction = wfAction; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowActionInsertJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { em.persist(wfAction); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionRetryManualGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionRetryManualGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionRetryManualGetJPAExecutor.java index 606c9b7..ed2400b 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionRetryManualGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionRetryManualGetJPAExecutor.java @@ -43,9 +43,6 @@ public class WorkflowActionRetryManualGetJPAExecutor implements JPAExecutor<List this.actions = null; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public List<WorkflowActionBean> execute(EntityManager em) throws JPAExecutorException { try { @@ -59,9 +56,6 @@ public class WorkflowActionRetryManualGetJPAExecutor implements JPAExecutor<List return actions; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowActionRetryManualGetJPAExecutor"; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionSubsetGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionSubsetGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionSubsetGetJPAExecutor.java index 6647a99..9ae3646 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionSubsetGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionSubsetGetJPAExecutor.java @@ -54,9 +54,6 @@ public class WorkflowActionSubsetGetJPAExecutor implements JPAExecutor<List<Work this.length = length; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public List<WorkflowActionBean> execute(EntityManager em) throws JPAExecutorException { @@ -76,9 +73,6 @@ public class WorkflowActionSubsetGetJPAExecutor implements JPAExecutor<List<Work return actions; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowActionSubsetGetJPAExecutor"; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionsGetForJobJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionsGetForJobJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionsGetForJobJPAExecutor.java index c333c0f..2f012a4 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionsGetForJobJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowActionsGetForJobJPAExecutor.java @@ -41,17 +41,11 @@ public class WorkflowActionsGetForJobJPAExecutor implements JPAExecutor<List<Wor this.wfJobId = wfJobId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowActionsGetForJobJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public List<WorkflowActionBean> execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowIdGetForExternalIdJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowIdGetForExternalIdJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowIdGetForExternalIdJPAExecutor.java index c077cd8..b0c9259 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowIdGetForExternalIdJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowIdGetForExternalIdJPAExecutor.java @@ -37,17 +37,11 @@ public class WorkflowIdGetForExternalIdJPAExecutor implements JPAExecutor<String this.externalId = externalId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowIdGetForExternalIdJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public String execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowInfoWithActionsSubsetGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowInfoWithActionsSubsetGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowInfoWithActionsSubsetGetJPAExecutor.java index 5f12b4d..3ceda38 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowInfoWithActionsSubsetGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowInfoWithActionsSubsetGetJPAExecutor.java @@ -55,9 +55,6 @@ public class WorkflowInfoWithActionsSubsetGetJPAExecutor implements JPAExecutor< this.len = len; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public WorkflowJobBean execute(EntityManager em) throws JPAExecutorException { try { @@ -96,9 +93,6 @@ public class WorkflowInfoWithActionsSubsetGetJPAExecutor implements JPAExecutor< return this.workflow; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowInfoWithActionsSubsetGetJPAExecutor"; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobDeleteJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobDeleteJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobDeleteJPAExecutor.java index 6623f02..07581e3 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobDeleteJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobDeleteJPAExecutor.java @@ -36,9 +36,6 @@ public class WorkflowJobDeleteJPAExecutor implements JPAExecutor<Void>{ this.wfJobId = wfJobId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public Void execute(EntityManager em) throws JPAExecutorException { WorkflowJobBean job = em.find(WorkflowJobBean.class, this.wfJobId); @@ -48,9 +45,6 @@ public class WorkflowJobDeleteJPAExecutor implements JPAExecutor<Void>{ return null; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowJobDeleteJPAExecutor"; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetForUserJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetForUserJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetForUserJPAExecutor.java index 58890d1..7233bca 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetForUserJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetForUserJPAExecutor.java @@ -37,22 +37,11 @@ public class WorkflowJobGetForUserJPAExecutor implements JPAExecutor<String> { this.wfJobId = wfJobId; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowJobGetForUserJPAExecutor"; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence. - * EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { try { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetJPAExecutor.java index 2f7f17c..54350f4 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobGetJPAExecutor.java @@ -39,17 +39,11 @@ public class WorkflowJobGetJPAExecutor implements JPAExecutor<WorkflowJobBean> { this.wfJobId = wfJobId; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowJobGetJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public WorkflowJobBean execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobInsertJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobInsertJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobInsertJPAExecutor.java index 8416287..0816c27 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobInsertJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobInsertJPAExecutor.java @@ -35,17 +35,11 @@ public class WorkflowJobInsertJPAExecutor implements JPAExecutor<String> { this.wfJob = wfJob; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowJobInsertJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override public String execute(EntityManager em) throws JPAExecutorException { em.persist(wfJob); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsDeleteJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsDeleteJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsDeleteJPAExecutor.java index 8674aa2..01fe534 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsDeleteJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsDeleteJPAExecutor.java @@ -52,22 +52,11 @@ public class WorkflowJobsDeleteJPAExecutor implements JPAExecutor<Integer> { this.deleteList = deleteList; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowJobsDeleteJPAExecutor"; } - /* - * (non-Javadoc) - * - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence. - * EntityManager) - */ @Override public Integer execute(EntityManager em) throws JPAExecutorException { int actionsDeleted = 0; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsGetForPurgeJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsGetForPurgeJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsGetForPurgeJPAExecutor.java index 3e33c01..4b8b4d0 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsGetForPurgeJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowJobsGetForPurgeJPAExecutor.java @@ -46,17 +46,11 @@ public class WorkflowJobsGetForPurgeJPAExecutor implements JPAExecutor<List<Stri this.limit = limit; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowJobsGetForPurgeJPAExecutor"; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @Override @SuppressWarnings("unchecked") public List<String> execute(EntityManager em) throws JPAExecutorException { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowsJobGetJPAExecutor.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowsJobGetJPAExecutor.java b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowsJobGetJPAExecutor.java index f50c1a4..9e68f49 100644 --- a/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowsJobGetJPAExecutor.java +++ b/core/src/main/java/org/apache/oozie/executor/jpa/WorkflowsJobGetJPAExecutor.java @@ -66,9 +66,6 @@ public class WorkflowsJobGetJPAExecutor implements JPAExecutor<WorkflowsInfo> { this.len = len; } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#execute(javax.persistence.EntityManager) - */ @SuppressWarnings("unchecked") @Override public WorkflowsInfo execute(EntityManager em) throws JPAExecutorException { @@ -330,9 +327,6 @@ public class WorkflowsJobGetJPAExecutor implements JPAExecutor<WorkflowsInfo> { return new WorkflowsInfo(wfBeansList, start, len, realLen); } - /* (non-Javadoc) - * @see org.apache.oozie.executor.jpa.JPAExecutor#getName() - */ @Override public String getName() { return "WorkflowsJobGetJPAExecutor"; http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/jms/MessageReceiver.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/jms/MessageReceiver.java b/core/src/main/java/org/apache/oozie/jms/MessageReceiver.java index 87d0c5e..864f3cd 100644 --- a/core/src/main/java/org/apache/oozie/jms/MessageReceiver.java +++ b/core/src/main/java/org/apache/oozie/jms/MessageReceiver.java @@ -66,11 +66,6 @@ public class MessageReceiver implements MessageListener { return session; } - /* - * (non-Javadoc) - * - * @see javax.jms.MessageListener#onMessage(javax.jms.Message) - */ @Override public void onMessage(Message msg) { LOG.trace("Received a JMS message "); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/service/CallableQueueService.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/service/CallableQueueService.java b/core/src/main/java/org/apache/oozie/service/CallableQueueService.java index 7b89964..dace26c 100644 --- a/core/src/main/java/org/apache/oozie/service/CallableQueueService.java +++ b/core/src/main/java/org/apache/oozie/service/CallableQueueService.java @@ -347,11 +347,6 @@ public class CallableQueueService implements Service, Instrumentable { return null; } - /* - * (non-Javadoc) - * - * @see java.lang.Object#toString() - */ @Override public String toString() { if (callables.size() == 0) { http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/servlet/V0AdminServlet.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/servlet/V0AdminServlet.java b/core/src/main/java/org/apache/oozie/servlet/V0AdminServlet.java index b43ab99..6cb48c7 100644 --- a/core/src/main/java/org/apache/oozie/servlet/V0AdminServlet.java +++ b/core/src/main/java/org/apache/oozie/servlet/V0AdminServlet.java @@ -62,13 +62,6 @@ public class V0AdminServlet extends BaseAdminServlet { modeTag = RestConstants.ADMIN_SAFE_MODE_PARAM; } - /* - * (non-Javadoc) - * - * @see - * org.apache.oozie.servlet.BaseAdminServlet#populateOozieMode(org.json. - * simple.JSONObject) - */ @Override protected void populateOozieMode(JSONObject json) { if (Services.get().getSystemMode() != SYSTEM_MODE.NORMAL) { @@ -79,14 +72,6 @@ public class V0AdminServlet extends BaseAdminServlet { } } - /* - * (non-Javadoc) - * - * @see - * org.apache.oozie.servlet.BaseAdminServlet#setOozieMode(javax.servlet. - * http.HttpServletRequest, javax.servlet.http.HttpServletResponse, - * java.lang.String) - */ @Override protected void setOozieMode(HttpServletRequest request, HttpServletResponse response, String resourceName) throws XServletException { @@ -96,13 +81,6 @@ public class V0AdminServlet extends BaseAdminServlet { response.setStatus(HttpServletResponse.SC_OK); } - /* - * (non-Javadoc) - * - * @see - * org.apache.oozie.servlet.BaseAdminServlet#getQueueDump(org.json.simple - * .JSONObject) - */ @Override protected void getQueueDump(JSONObject json) throws XServletException { throw new XServletException(HttpServletResponse.SC_BAD_REQUEST, ErrorCode.E0301, "cannot get queue dump"); http://git-wip-us.apache.org/repos/asf/oozie/blob/b0f0dc1d/core/src/main/java/org/apache/oozie/servlet/V1AdminServlet.java ---------------------------------------------------------------------- diff --git a/core/src/main/java/org/apache/oozie/servlet/V1AdminServlet.java b/core/src/main/java/org/apache/oozie/servlet/V1AdminServlet.java index fc3a6bc..8eb6ee1 100644 --- a/core/src/main/java/org/apache/oozie/servlet/V1AdminServlet.java +++ b/core/src/main/java/org/apache/oozie/servlet/V1AdminServlet.java @@ -82,27 +82,12 @@ public class V1AdminServlet extends BaseAdminServlet { this(INSTRUMENTATION_NAME); } - /* - * (non-Javadoc) - * - * @see - * org.apache.oozie.servlet.BaseAdminServlet#populateOozieMode(org.json. - * simple.JSONObject) - */ @SuppressWarnings("unchecked") @Override protected void populateOozieMode(JSONObject json) { json.put(JsonTags.OOZIE_SYSTEM_MODE, Services.get().getSystemMode().toString()); } - /* - * (non-Javadoc) - * - * @see - * org.apache.oozie.servlet.BaseAdminServlet#setOozieMode(javax.servlet. - * http.HttpServletRequest, javax.servlet.http.HttpServletResponse, - * java.lang.String) - */ @Override protected void setOozieMode(HttpServletRequest request, HttpServletResponse response, String resourceName)
