Author: degenaro
Date: Fri Oct 31 20:06:36 2014
New Revision: 1635850
URL: http://svn.apache.org/r1635850
Log:
UIMA-4078 DUCC Job Driver (JD) report users should employ interface, rather
than class directly
Added:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverStatusReport.java
(with props)
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/JdStateDuccEvent.java
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/JdStateDuccEvent.java
URL:
http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/JdStateDuccEvent.java?rev=1635850&r1=1635849&r2=1635850&view=diff
==============================================================================
---
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/JdStateDuccEvent.java
(original)
+++
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/JdStateDuccEvent.java
Fri Oct 31 20:06:36 2014
@@ -18,23 +18,23 @@
*/
package org.apache.uima.ducc.transport.event;
-import org.apache.uima.ducc.transport.event.jd.DriverStatusReport;
+import org.apache.uima.ducc.transport.event.jd.IDriverStatusReport;
public class JdStateDuccEvent extends AbstractDuccEvent {
private static final long serialVersionUID = 5344338331069768338L;
- private DriverStatusReport driverStatusReport = null;
+ private IDriverStatusReport driverStatusReport = null;
public JdStateDuccEvent() {
super(EventType.JD_STATE);
}
- public void setState(DriverStatusReport driverStatusReport) {
+ public void setState(IDriverStatusReport driverStatusReport) {
this.driverStatusReport = driverStatusReport;
}
- public DriverStatusReport getState() {
+ public IDriverStatusReport getState() {
return this.driverStatusReport;
}
}
Modified:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java
URL:
http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java?rev=1635850&r1=1635849&r2=1635850&view=diff
==============================================================================
---
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java
(original)
+++
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/DriverStatusReport.java
Fri Oct 31 20:06:36 2014
@@ -42,7 +42,7 @@ import org.apache.uima.ducc.transport.ev
@SuppressWarnings("serial")
-public class DriverStatusReport implements Serializable {
+public class DriverStatusReport implements Serializable, IDriverStatusReport {
private static DuccLogger duccOut =
DuccLoggerComponents.getJdOut(DriverStatusReport.class.getName());
private static DuccId jobid = null;
Added:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverStatusReport.java
URL:
http://svn.apache.org/viewvc/uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverStatusReport.java?rev=1635850&view=auto
==============================================================================
---
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverStatusReport.java
(added)
+++
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverStatusReport.java
Fri Oct 31 20:06:36 2014
@@ -0,0 +1,81 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+*/
+package org.apache.uima.ducc.transport.event.jd;
+
+import java.util.Iterator;
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.apache.uima.ducc.common.jd.files.workitem.RemoteLocation;
+import org.apache.uima.ducc.common.utils.id.DuccId;
+import
org.apache.uima.ducc.transport.event.common.IDuccCompletionType.JobCompletionType;
+import org.apache.uima.ducc.transport.event.common.IDuccPerWorkItemStatistics;
+import
org.apache.uima.ducc.transport.event.common.IDuccUimaDeploymentDescriptor;
+import org.apache.uima.ducc.transport.event.common.IRationale;
+import org.apache.uima.ducc.transport.event.jd.IDriverState.DriverState;
+
+public interface IDriverStatusReport {
+
+ public DuccId getDuccId();
+ public String getLogReport();
+
+ public long getWorkItemsTotal();
+
+ public int getWorkItemsProcessingCompleted();
+ public int getWorkItemsProcessingError();
+ public int getWorkItemsRetry();
+ public int getWorkItemsDispatched();
+ public int getWorkItemsPreempted();
+ public int getWorkItemsLost();
+
+ public int getWorkItemPendingProcessAssignmentCount();
+
+ public long getWiMillisMin();
+ public long getWiMillisMax();
+ public long getWiMillisAvg();
+
+ public long getWiMillisOperatingLeast();
+ public long getWiMillisCompletedMost();
+
+ public long getMostRecentStart();
+
+ public boolean isPending();
+ public boolean isWorkItemPendingProcessAssignment();
+ public boolean isKillJob();
+
+ public boolean isOperating(String nodeIP, String PID);
+
+ public String getJdJmxUrl();
+
+ public IDuccUimaDeploymentDescriptor getUimaDeploymentDescriptor();
+
+ public Iterator<DuccId> getKillDuccIds();
+
+ public DriverState getDriverState();
+
+ public JobCompletionType getJobCompletionType();
+ public IRationale getJobCompletionRationale();
+
+ public IDuccPerWorkItemStatistics getPerWorkItemStatistics();
+
+ public DuccProcessWorkItemsMap getDuccProcessWorkItemsMap();
+
+ public ConcurrentHashMap<RemoteLocation, Long>getOperatingMillisMap();
+ public ConcurrentHashMap<Integer,DuccId> getLimboMap();
+ public ConcurrentHashMap<String,DuccId> getCasQueuedMap();
+}
Propchange:
uima/sandbox/uima-ducc/trunk/uima-ducc-transport/src/main/java/org/apache/uima/ducc/transport/event/jd/IDriverStatusReport.java
------------------------------------------------------------------------------
svn:eol-style = native
