[Mulgara-svn] r272 - branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed/rmi

[pag at mulgara.org]

Author: pag
Date: 2007-05-14 13:09:11 -0500 (Mon, 14 May 2007)
New Revision: 272

Modified:
   branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed/rmi/StatementSetFactory.java
Log:
Initial code for Serial and RMI Set implementations for remote insertions

Modified: branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed/rmi/StatementSetFactory.java
===================================================================
--- branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed/rmi/StatementSetFactory.java	2007-05-14 18:07:21 UTC (rev 271)
+++ branches/blank_nodes/src/jar/resolver-distributed/java/org/mulgara/resolver/distributed/rmi/StatementSetFactory.java	2007-05-14 18:09:11 UTC (rev 272)
@@ -15,6 +15,9 @@
 
 import java.util.Set;
 
+import org.mulgara.query.TuplesException;
+import org.mulgara.resolver.spi.GlobalizeException;
+import org.mulgara.resolver.spi.ResolverSession;
 import org.mulgara.resolver.spi.Statements;
 
 /**
@@ -26,8 +29,15 @@
  * @licence <a href="{@docRoot}/../../LICENCE.txt">Open Software License v3.0</a>
  */
 public class StatementSetFactory {
+  
+  /** The size for transitioning between a serializable set and a remote set. */
+  static final long WATER_MARK = 2048L;
 
-  public static Set newStatementSet(Statements statements) {
+  public static Set newStatementSet(Statements statements, ResolverSession session) throws TuplesException, GlobalizeException {
+    // make sure the WATER_MARK refers to a set that is indexable by integer
+    assert (long)(int)WATER_MARK == WATER_MARK;
+    if (statements.getRowUpperBound() < WATER_MARK) return new ShortGlobalStatementSet(statements, session);
+    // TODO return a remote set
     return null;
   }
 }