You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oozie.apache.org by an...@apache.org on 2018/06/01 13:40:15 UTC
[2/3] oozie git commit: OOZIE-2097 Get rid of non-Javadoc comments
(Jan Hentschel via andras.piros)
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)