manifoldcf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kwri...@apache.org
Subject svn commit: r1545904 - in /manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler: bins/BinManager.java interfaces/IBinManager.java
Date Wed, 27 Nov 2013 01:52:45 GMT
Author: kwright
Date: Wed Nov 27 01:52:45 2013
New Revision: 1545904

URL: http://svn.apache.org/r1545904
Log:
Bins are double values in current implementation; do the same thing in new implementation.

Modified:
    manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/bins/BinManager.java
    manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IBinManager.java

Modified: manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/bins/BinManager.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/bins/BinManager.java?rev=1545904&r1=1545903&r2=1545904&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/bins/BinManager.java
(original)
+++ manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/bins/BinManager.java
Wed Nov 27 01:52:45 2013
@@ -70,7 +70,7 @@ public class BinManager extends org.apac
       {
         HashMap map = new HashMap();
         map.put(binNameField,new ColumnDescription("VARCHAR(255)",true,true,null,null,false));
-        map.put(binCounterField,new ColumnDescription("BIGINT",false,false,null,null,false));
+        map.put(binCounterField,new ColumnDescription("FLOAT",false,false,null,null,false));
         performCreate(map,null);
       }
       else
@@ -109,7 +109,7 @@ public class BinManager extends org.apac
   *@return the counter value.
   */
   @Override
-  public long getIncrementBinValue(String binName, long newBinValue)
+  public double getIncrementBinValue(String binName, double newBinValue)
     throws ManifoldCFException
   {
     // SELECT FOR UPDATE/MODIFY is the most common path
@@ -120,10 +120,10 @@ public class BinManager extends org.apac
     if (result.getRowCount() > 0)
     {
       IResultRow row = result.getRow(0);
-      Long value = (Long)row.getValue(binCounterField);
-      long rval = value.longValue();
+      Double value = (Double)row.getValue(binCounterField);
+      double rval = value.doubleValue();
       HashMap map = new HashMap();
-      map.put(binCounterField,new Long(rval+1L));
+      map.put(binCounterField,new Double(rval+1.0));
       performUpdate(map," WHERE "+query,params,null);
       return rval;
     }
@@ -131,7 +131,7 @@ public class BinManager extends org.apac
     {
       HashMap map = new HashMap();
       map.put(binNameField,binName);
-      map.put(binCounterField,new Long(newBinValue+1L));
+      map.put(binCounterField,new Double(newBinValue+1.0));
       performInsert(map,null);
       return newBinValue;
     }

Modified: manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IBinManager.java
URL: http://svn.apache.org/viewvc/manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IBinManager.java?rev=1545904&r1=1545903&r2=1545904&view=diff
==============================================================================
--- manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IBinManager.java
(original)
+++ manifoldcf/branches/CONNECTORS-781/framework/pull-agent/src/main/java/org/apache/manifoldcf/crawler/interfaces/IBinManager.java
Wed Nov 27 01:52:45 2013
@@ -48,7 +48,7 @@ public interface IBinManager
   * returned; what will be stored will be that value + 1.
   *@return the counter value.
   */
-  public long getIncrementBinValue(String binName, long newBinValue)
+  public double getIncrementBinValue(String binName, double newBinValue)
     throws ManifoldCFException;
 
 }



Mime
View raw message