incubator-connectors-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kwri...@apache.org
Subject svn commit: r1220353 [4/11] - in /incubator/lcf/branches/CONNECTORS-286/warthog-reimport: ./ src/main/java/org/apache/warthog/api/ src/main/java/org/apache/warthog/bytekeyvalue/ src/main/java/org/apache/warthog/common/ src/main/java/org/apache/warthog/...
Date Sun, 18 Dec 2011 08:36:56 GMT
Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHTable.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHTable.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHTableStore.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHTableStore.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHTableStore.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHTableStore.java Sun Dec 18 08:36:52 2011
@@ -1,65 +1,65 @@
-/* $Id: WHTableStore.java -1   $ */
-
-/**
-* 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.warthog.api;
-
-/** This interface describes a table-based store built on top of a transactional
-* key-value store.  The basic representation is similar to SQL in that there are
-* tables and indexes; the difference is that the API used to manipulate and query
-* these constructs is not SQL based, but is rather a general Java API.
-*/
-public interface WHTableStore
-{
-  /** Begin a transaction */
-  public void beginTransaction()
-    throws WHException;
-  
-  /** Commit a transaction */
-  public void commitTransaction()
-    throws WHException;
-  
-  /** Abandon any transaction in progress */
-  public void abandonTransaction()
-    throws WHException;
-  
-  /** Lookup table */
-  public WHTable lookupTable(String name)
-    throws WHException;
-  
-  /** Create a table */
-  public WHTable createTable(String name, String[] columnNames)
-    throws WHException;
-  
-  /** Drop a table */
-  public void dropTable(String name)
-    throws WHException;
-  
-  /** Find an index */
-  public WHIndex lookupIndex(String name)
-    throws WHException;
-    
-  /** Create an index */
-  public WHIndex createIndex(String name, WHTable table, String[] columnNames, String[] comparatorClasses, boolean unique)
-    throws WHException;
-    
-  /** Drop an index */
-  public void dropIndex(String name)
-    throws WHException;
-    
-}
+/* $Id$ */
+
+/**
+* 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.warthog.api;
+
+/** This interface describes a table-based store built on top of a transactional
+* key-value store.  The basic representation is similar to SQL in that there are
+* tables and indexes; the difference is that the API used to manipulate and query
+* these constructs is not SQL based, but is rather a general Java API.
+*/
+public interface WHTableStore
+{
+  /** Begin a transaction */
+  public void beginTransaction()
+    throws WHException;
+  
+  /** Commit a transaction */
+  public void commitTransaction()
+    throws WHException;
+  
+  /** Abandon any transaction in progress */
+  public void abandonTransaction()
+    throws WHException;
+  
+  /** Lookup table */
+  public WHTable lookupTable(String name)
+    throws WHException;
+  
+  /** Create a table */
+  public WHTable createTable(String name, String[] columnNames)
+    throws WHException;
+  
+  /** Drop a table */
+  public void dropTable(String name)
+    throws WHException;
+  
+  /** Find an index */
+  public WHIndex lookupIndex(String name)
+    throws WHException;
+    
+  /** Create an index */
+  public WHIndex createIndex(String name, WHTable table, String[] columnNames, String[] comparatorClasses, boolean unique)
+    throws WHException;
+    
+  /** Drop an index */
+  public void dropIndex(String name)
+    throws WHException;
+    
+}

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHTableStore.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHTableStore.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHUniqueConstraintViolationException.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHUniqueConstraintViolationException.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHUniqueConstraintViolationException.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHUniqueConstraintViolationException.java Sun Dec 18 08:36:52 2011
@@ -1,36 +1,36 @@
-/* $Id: WHUniqueConstraintViolationException.java -1   $ */
-
-/**
-* 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.warthog.api;
-
-/** This exception signals a constraint violation, which usually indicates deadlock.
-*/
-public class WHUniqueConstraintViolationException extends WHConcurrencyException
-{
-  public WHUniqueConstraintViolationException()
-  {
-    super();
-  }
-
-  public WHUniqueConstraintViolationException(String msg)
-  {
-    super(msg);
-  }
-  
-}
+/* $Id$ */
+
+/**
+* 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.warthog.api;
+
+/** This exception signals a constraint violation, which usually indicates deadlock.
+*/
+public class WHUniqueConstraintViolationException extends WHConcurrencyException
+{
+  public WHUniqueConstraintViolationException()
+  {
+    super();
+  }
+
+  public WHUniqueConstraintViolationException(String msg)
+  {
+    super(msg);
+  }
+  
+}

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHUniqueConstraintViolationException.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHUniqueConstraintViolationException.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHValue.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHValue.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHValue.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHValue.java Sun Dec 18 08:36:52 2011
@@ -1,30 +1,30 @@
-/* $Id: WHValue.java -1   $ */
-
-/**
-* 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.warthog.api;
-
-/** This object represents a value in a transaction key/value store.
-* Pretty much anything can be a value, provided it can be serialized.
-* Reconstitution will consist of calling the constructor for the object class
-* with the object's serialized byte array as the sole argument.
-*/
-public interface WHValue
-{
-  // Nothing needed right now
-}
+/* $Id$ */
+
+/**
+* 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.warthog.api;
+
+/** This object represents a value in a transaction key/value store.
+* Pretty much anything can be a value, provided it can be serialized.
+* Reconstitution will consist of calling the constructor for the object class
+* with the object's serialized byte array as the sole argument.
+*/
+public interface WHValue
+{
+  // Nothing needed right now
+}

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHValue.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/api/WHValue.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHAtomicByteKeyValueStore.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHAtomicByteKeyValueStore.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHAtomicByteKeyValueStore.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHAtomicByteKeyValueStore.java Sun Dec 18 08:36:52 2011
@@ -1,51 +1,51 @@
-/* $Id: WHAtomicByteKeyValueStore.java -1   $ */
-
-/**
-* 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.warthog.bytekeyvalue;
-
-import org.apache.warthog.api.*;
-import java.util.*;
-
-/** Describes the general functionality requirements of an underlying (distributed?)
-* byte-array-based key value store, which use conflict detection as its mechanism for handling transactional
-* integrity.
-*/
-public interface WHAtomicByteKeyValueStore
-{
-  /** Get a value */
-  public byte[] get(byte[] key)
-    throws WHException;
-  
-  /** Check a bunch of values atomically for consistency.
-  *@param checkValues is a map of keys/values that must be unchanged.  If any value is
-  * changed, a WHConcurrencyException is thrown.
-  */
-  public void check(WHByteKeyMap checkValues)
-    throws WHException;
-  
-  /** Set a bunch of values atomically.
-  *@param checkValues is a map of keys/values that must be unchanged in order for the
-  * commit to proceed.  If these values are detected to have been changed, a WHConcurrencyException
-  * will be thrown.  Null values are permitted.
-  *@param setValues is a map of keys to set to specified new values.  A null value implies removal of
-  * the key.
-  */
-  public void setAll(WHByteKeyMap checkValues, WHByteKeyMap setValues)
-    throws WHException;
-}
+/* $Id$ */
+
+/**
+* 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.warthog.bytekeyvalue;
+
+import org.apache.warthog.api.*;
+import java.util.*;
+
+/** Describes the general functionality requirements of an underlying (distributed?)
+* byte-array-based key value store, which use conflict detection as its mechanism for handling transactional
+* integrity.
+*/
+public interface WHAtomicByteKeyValueStore
+{
+  /** Get a value */
+  public byte[] get(byte[] key)
+    throws WHException;
+  
+  /** Check a bunch of values atomically for consistency.
+  *@param checkValues is a map of keys/values that must be unchanged.  If any value is
+  * changed, a WHConcurrencyException is thrown.
+  */
+  public void check(WHByteKeyMap checkValues)
+    throws WHException;
+  
+  /** Set a bunch of values atomically.
+  *@param checkValues is a map of keys/values that must be unchanged in order for the
+  * commit to proceed.  If these values are detected to have been changed, a WHConcurrencyException
+  * will be thrown.  Null values are permitted.
+  *@param setValues is a map of keys to set to specified new values.  A null value implies removal of
+  * the key.
+  */
+  public void setAll(WHByteKeyMap checkValues, WHByteKeyMap setValues)
+    throws WHException;
+}

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHAtomicByteKeyValueStore.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHAtomicByteKeyValueStore.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyIterator.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyIterator.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyIterator.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyIterator.java Sun Dec 18 08:36:52 2011
@@ -1,37 +1,37 @@
-/* $Id: WHByteKeyIterator.java -1   $ */
-
-/**
-* 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.warthog.bytekeyvalue;
-
-import org.apache.warthog.api.*;
-
-/** This interface describes an iterator over a set of byte-based keys.  WHException
-* is possible on every iterator step.
-*/
-public interface WHByteKeyIterator
-{
-  /** Check if there is another value */
-  public boolean hasNext()
-    throws WHException;
-  
-  /** Get the next value */
-  public byte[] next()
-    throws WHException;
-}
-
+/* $Id$ */
+
+/**
+* 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.warthog.bytekeyvalue;
+
+import org.apache.warthog.api.*;
+
+/** This interface describes an iterator over a set of byte-based keys.  WHException
+* is possible on every iterator step.
+*/
+public interface WHByteKeyIterator
+{
+  /** Check if there is another value */
+  public boolean hasNext()
+    throws WHException;
+  
+  /** Get the next value */
+  public byte[] next()
+    throws WHException;
+}
+

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyIterator.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyIterator.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyMap.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyMap.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyMap.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyMap.java Sun Dec 18 08:36:52 2011
@@ -1,46 +1,46 @@
-/* $Id: WHByteKeyMap.java -1   $ */
-
-/**
-* 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.warthog.bytekeyvalue;
-
-import org.apache.warthog.api.*;
-import java.util.*;
-
-/** This interface describes a set of byte-array-based key/value pairs that
-* is maintained locally.
-*/
-public interface WHByteKeyMap
-{
-  /** Get a value from the map.
-  */
-  public byte[] get(byte[] key)
-    throws WHException;
-  
-  /** Iterate over the keys in the map.
-  */
-  public WHByteKeyIterator iterator()
-    throws WHException;
-
-  /** Get the size of the map.
-  */
-  public long size()
-    throws WHException;
-
-}
-
+/* $Id$ */
+
+/**
+* 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.warthog.bytekeyvalue;
+
+import org.apache.warthog.api.*;
+import java.util.*;
+
+/** This interface describes a set of byte-array-based key/value pairs that
+* is maintained locally.
+*/
+public interface WHByteKeyMap
+{
+  /** Get a value from the map.
+  */
+  public byte[] get(byte[] key)
+    throws WHException;
+  
+  /** Iterate over the keys in the map.
+  */
+  public WHByteKeyIterator iterator()
+    throws WHException;
+
+  /** Get the size of the map.
+  */
+  public long size()
+    throws WHException;
+
+}
+

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyMap.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/bytekeyvalue/WHByteKeyMap.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BooleanValue.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BooleanValue.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BooleanValue.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BooleanValue.java Sun Dec 18 08:36:52 2011
@@ -1,87 +1,87 @@
-/* $Id: BooleanValue.java 1207794 2011-11-29 08:57:22Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-import org.apache.warthog.api.*;
-import org.apache.warthog.transactionalkeyvaluestore.*;
-
-/** Boolean value, serializable.
-*/
-public class BooleanValue implements WHValue,WHKeyValue
-{
-  boolean value;
-  
-  public BooleanValue(boolean value)
-  {
-    this.value = value;
-  }
-  
-  public BooleanValue(byte[] bytes)
-  {
-    value = readObject(new BufferPointer(bytes));
-  }
-  
-  public byte[] serializeObject()
-  {
-    byte[] rval = new byte[sizeObject()];
-    writeObject(new BufferPointer(rval),value);
-    return rval;
-  }
-  
-  public boolean getValue()
-  {
-    return value;
-  }
-
-  public boolean isEquals(WHKeyValue value)
-  {
-    return this.value == ((BooleanValue)value).value;
-  }
-
-  public int hashCode()
-  {
-    return value?101:97;
-  }
-  
-  public boolean equals(Object o)
-  {
-    if (this.getClass() != o.getClass())
-      return false;
-    return ((BooleanValue)o).value == value;
-  }
-
-  public static boolean readObject(BufferPointer bp)
-  {
-    return ((((int)bp.readValue()) & 0xff) == 0)?false:true;
-  }
-  
-  public static int sizeObject()
-  {
-    return 1;
-  }
-  
-  public static void writeObject(BufferPointer bp, boolean value)
-  {
-    bp.writeValue((byte)(value?1:0));
-  }
-  
-}
-
-
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+import org.apache.warthog.api.*;
+import org.apache.warthog.transactionalkeyvaluestore.*;
+
+/** Boolean value, serializable.
+*/
+public class BooleanValue implements WHValue,WHKeyValue
+{
+  boolean value;
+  
+  public BooleanValue(boolean value)
+  {
+    this.value = value;
+  }
+  
+  public BooleanValue(byte[] bytes)
+  {
+    value = readObject(new BufferPointer(bytes));
+  }
+  
+  public byte[] serializeObject()
+  {
+    byte[] rval = new byte[sizeObject()];
+    writeObject(new BufferPointer(rval),value);
+    return rval;
+  }
+  
+  public boolean getValue()
+  {
+    return value;
+  }
+
+  public boolean isEquals(WHKeyValue value)
+  {
+    return this.value == ((BooleanValue)value).value;
+  }
+
+  public int hashCode()
+  {
+    return value?101:97;
+  }
+  
+  public boolean equals(Object o)
+  {
+    if (this.getClass() != o.getClass())
+      return false;
+    return ((BooleanValue)o).value == value;
+  }
+
+  public static boolean readObject(BufferPointer bp)
+  {
+    return ((((int)bp.readValue()) & 0xff) == 0)?false:true;
+  }
+  
+  public static int sizeObject()
+  {
+    return 1;
+  }
+  
+  public static void writeObject(BufferPointer bp, boolean value)
+  {
+    bp.writeValue((byte)(value?1:0));
+  }
+  
+}
+
+

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BooleanValue.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BooleanValue.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BufferPointer.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BufferPointer.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BufferPointer.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BufferPointer.java Sun Dec 18 08:36:52 2011
@@ -1,48 +1,48 @@
-/* $Id: BufferPointer.java 1202068 2011-11-15 06:57:24Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-/** A byte buffer and offset, for serialization. */
-public class BufferPointer
-{
-  /** The buffer */
-  protected byte[] buffer;
-  /** The pointer */
-  protected int pointer = 0;
-  
-  /** Constructor */
-  public BufferPointer(byte[] buffer)
-  {
-    this.buffer = buffer;
-  }
-  
-  /** Get the value at the current pointer and advance */
-  public byte readValue()
-  {
-    return buffer[pointer++];
-  }
-  
-  /** Write a value to the current pointer and advance */
-  public void writeValue(byte value)
-  {
-    buffer[pointer++] = value;
-  }
-  
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+/** A byte buffer and offset, for serialization. */
+public class BufferPointer
+{
+  /** The buffer */
+  protected byte[] buffer;
+  /** The pointer */
+  protected int pointer = 0;
+  
+  /** Constructor */
+  public BufferPointer(byte[] buffer)
+  {
+    this.buffer = buffer;
+  }
+  
+  /** Get the value at the current pointer and advance */
+  public byte readValue()
+  {
+    return buffer[pointer++];
+  }
+  
+  /** Write a value to the current pointer and advance */
+  public void writeValue(byte value)
+  {
+    buffer[pointer++] = value;
+  }
+  
 }
\ No newline at end of file

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BufferPointer.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/BufferPointer.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterArray.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterArray.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterArray.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterArray.java Sun Dec 18 08:36:52 2011
@@ -1,128 +1,128 @@
-/* $Id: CharacterArray.java 1207794 2011-11-29 08:57:22Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-import org.apache.warthog.api.*;
-import org.apache.warthog.transactionalkeyvaluestore.*;
-
-/** Character array, serializable.
-*/
-public class CharacterArray implements WHValue,WHKeyValue
-{
-  char[] value;
-  
-  public CharacterArray(char[] value)
-  {
-    this.value = value;
-  }
-  
-  public CharacterArray()
-  {
-  }
-  
-  public CharacterArray(byte[] bytes)
-  {
-    value = readObject(new BufferPointer(bytes));
-  }
-  
-  public byte[] serializeObject()
-  {
-    byte[] rval = new byte[sizeObject(value.length)];
-    writeObject(new BufferPointer(rval),value);
-    return rval;
-  }
-  
-  public char[] getValue()
-  {
-    return value;
-  }
-
-  /** Check if equals (classes must already agree) */
-  public boolean isEquals(WHKeyValue value)
-  {
-    char[] otherValue = ((CharacterArray)value).value;
-    return compareObject(this.value,otherValue);
-  }
-
-  public int hashCode()
-  {
-    int rval = 0;
-    for (int i = 0 ; i < value.length ; i++)
-    {
-      rval += (((int)value[i]) << 5) ^ (((int)value[i]) >> 3);
-    }
-    return rval;
-  }
-  
-  public boolean equals(Object o)
-  {
-    if (this.getClass() != o.getClass())
-      return false;
-    CharacterArray sa = (CharacterArray)o;
-    if (sa.value.length != value.length)
-      return false;
-    for (int i = 0 ; i < value.length ; i++)
-    {
-      if (sa.value[i] != value[i])
-        return false;
-    }
-    return true;
-  }
-
-  public static char[] readObject(BufferPointer bp)
-  {
-    int size = IntegerValue.readObject(bp);
-    char[] rval = new char[size];
-    for (int i = 0 ; i < size ; i++)
-    {
-      rval[i] = CharacterValue.readObject(bp);
-    }
-    return rval;
-  }
-  
-  public static int sizeObject(int size)
-  {
-    return IntegerValue.sizeObject() + CharacterValue.sizeObject() * size;
-  }
-  
-  public static void writeObject(BufferPointer bp, char[] value)
-  {
-    IntegerValue.writeObject(bp,value.length);
-    for (int i = 0 ; i < value.length ; i++)
-    {
-      CharacterValue.writeObject(bp,value[i]);
-    }
-  }
-  
-  public static boolean compareObject(char[] value, char[] otherValue)
-  {
-    if (otherValue.length != value.length)
-      return false;
-    for (int i = 0 ; i < otherValue.length ; i++)
-    {
-      if (otherValue[i] != value[i])
-        return false;
-    }
-    return true;
-  }
-  
-}
-
-
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+import org.apache.warthog.api.*;
+import org.apache.warthog.transactionalkeyvaluestore.*;
+
+/** Character array, serializable.
+*/
+public class CharacterArray implements WHValue,WHKeyValue
+{
+  char[] value;
+  
+  public CharacterArray(char[] value)
+  {
+    this.value = value;
+  }
+  
+  public CharacterArray()
+  {
+  }
+  
+  public CharacterArray(byte[] bytes)
+  {
+    value = readObject(new BufferPointer(bytes));
+  }
+  
+  public byte[] serializeObject()
+  {
+    byte[] rval = new byte[sizeObject(value.length)];
+    writeObject(new BufferPointer(rval),value);
+    return rval;
+  }
+  
+  public char[] getValue()
+  {
+    return value;
+  }
+
+  /** Check if equals (classes must already agree) */
+  public boolean isEquals(WHKeyValue value)
+  {
+    char[] otherValue = ((CharacterArray)value).value;
+    return compareObject(this.value,otherValue);
+  }
+
+  public int hashCode()
+  {
+    int rval = 0;
+    for (int i = 0 ; i < value.length ; i++)
+    {
+      rval += (((int)value[i]) << 5) ^ (((int)value[i]) >> 3);
+    }
+    return rval;
+  }
+  
+  public boolean equals(Object o)
+  {
+    if (this.getClass() != o.getClass())
+      return false;
+    CharacterArray sa = (CharacterArray)o;
+    if (sa.value.length != value.length)
+      return false;
+    for (int i = 0 ; i < value.length ; i++)
+    {
+      if (sa.value[i] != value[i])
+        return false;
+    }
+    return true;
+  }
+
+  public static char[] readObject(BufferPointer bp)
+  {
+    int size = IntegerValue.readObject(bp);
+    char[] rval = new char[size];
+    for (int i = 0 ; i < size ; i++)
+    {
+      rval[i] = CharacterValue.readObject(bp);
+    }
+    return rval;
+  }
+  
+  public static int sizeObject(int size)
+  {
+    return IntegerValue.sizeObject() + CharacterValue.sizeObject() * size;
+  }
+  
+  public static void writeObject(BufferPointer bp, char[] value)
+  {
+    IntegerValue.writeObject(bp,value.length);
+    for (int i = 0 ; i < value.length ; i++)
+    {
+      CharacterValue.writeObject(bp,value[i]);
+    }
+  }
+  
+  public static boolean compareObject(char[] value, char[] otherValue)
+  {
+    if (otherValue.length != value.length)
+      return false;
+    for (int i = 0 ; i < otherValue.length ; i++)
+    {
+      if (otherValue[i] != value[i])
+        return false;
+    }
+    return true;
+  }
+  
+}
+
+

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterArray.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterArray.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterValue.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterValue.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterValue.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterValue.java Sun Dec 18 08:36:52 2011
@@ -1,90 +1,90 @@
-/* $Id: CharacterValue.java 1207794 2011-11-29 08:57:22Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-import org.apache.warthog.api.*;
-import org.apache.warthog.transactionalkeyvaluestore.*;
-
-/** Character value, serializable.
-*/
-public class CharacterValue implements WHValue,WHKeyValue
-{
-  char value;
-  
-  public CharacterValue(char value)
-  {
-    this.value = value;
-  }
-  
-  public CharacterValue(byte[] bytes)
-  {
-    value = readObject(new BufferPointer(bytes));
-  }
-  
-  public byte[] serializeObject()
-  {
-    byte[] rval = new byte[sizeObject()];
-    writeObject(new BufferPointer(rval),value);
-    return rval;
-  }
-  
-  /** Check if equals (classes must already agree) */
-  public boolean isEquals(WHKeyValue value)
-  {
-    return this.value == ((CharacterValue)value).value;
-  }
-
-  public char getValue()
-  {
-    return value;
-  }
-  
-  public int hashCode()
-  {
-    return (((int)value) << 5) ^ (((int)value) >> 3);
-  }
-  
-  public boolean equals(Object o)
-  {
-    if (this.getClass() != o.getClass())
-      return false;
-    return ((CharacterValue)o).value == value;
-  }
-
-  public static char readObject(BufferPointer bp)
-  {
-    int value = (((int)bp.readValue()) & 0xff);
-    value += ((((int)bp.readValue()) << 8) & 0xff00);
-    return (char)value;
-  }
-  
-  public static int sizeObject()
-  {
-    return 2;
-  }
-  
-  public static void writeObject(BufferPointer bp, char value)
-  {
-    bp.writeValue((byte)(((int)value) & 0xff));
-    bp.writeValue((byte)((((int)value) >> 8) & 0xff));
-  }
-}
-
-
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+import org.apache.warthog.api.*;
+import org.apache.warthog.transactionalkeyvaluestore.*;
+
+/** Character value, serializable.
+*/
+public class CharacterValue implements WHValue,WHKeyValue
+{
+  char value;
+  
+  public CharacterValue(char value)
+  {
+    this.value = value;
+  }
+  
+  public CharacterValue(byte[] bytes)
+  {
+    value = readObject(new BufferPointer(bytes));
+  }
+  
+  public byte[] serializeObject()
+  {
+    byte[] rval = new byte[sizeObject()];
+    writeObject(new BufferPointer(rval),value);
+    return rval;
+  }
+  
+  /** Check if equals (classes must already agree) */
+  public boolean isEquals(WHKeyValue value)
+  {
+    return this.value == ((CharacterValue)value).value;
+  }
+
+  public char getValue()
+  {
+    return value;
+  }
+  
+  public int hashCode()
+  {
+    return (((int)value) << 5) ^ (((int)value) >> 3);
+  }
+  
+  public boolean equals(Object o)
+  {
+    if (this.getClass() != o.getClass())
+      return false;
+    return ((CharacterValue)o).value == value;
+  }
+
+  public static char readObject(BufferPointer bp)
+  {
+    int value = (((int)bp.readValue()) & 0xff);
+    value += ((((int)bp.readValue()) << 8) & 0xff00);
+    return (char)value;
+  }
+  
+  public static int sizeObject()
+  {
+    return 2;
+  }
+  
+  public static void writeObject(BufferPointer bp, char value)
+  {
+    bp.writeValue((byte)(((int)value) & 0xff));
+    bp.writeValue((byte)((((int)value) >> 8) & 0xff));
+  }
+}
+
+

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterValue.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/CharacterValue.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnCount.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnCount.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnCount.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnCount.java Sun Dec 18 08:36:52 2011
@@ -1,102 +1,102 @@
-/* $Id: ColumnCount.java 1210225 2011-12-04 21:09:35Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-import org.apache.warthog.api.*;
-
-/** This class is used to count the rows found.
-*/
-public class ColumnCount implements WHColumnDescription
-{
-  protected String returnColumnName;
-  
-  /** Constructor */
-  public ColumnCount(String returnColumnName)
-  {
-    this.returnColumnName = returnColumnName;
-  }
-  
-  /** Get the name of the return column */
-  public String getReturnColumnName()
-    throws WHException
-  {
-    return returnColumnName;
-  }
-  
-  /** Create a return column calculator for this column.
-  */
-  public WHColumnCalculator createCalculator()
-    throws WHException
-  {
-    return new CountCalculator();
-  }
-  
-  protected static class CountCalculator implements WHColumnCalculator
-  {
-    protected long counter = 0L;
-    
-    public CountCalculator()
-    {
-    }
-
-    /** Check whether a row can be added to to the column calculator.
-    * Does NOT actually change the result of the calculator!
-    *@return true if the row can be added and false if a tally should be done immediately.
-    */
-    public boolean canProcessRowValue(WHAccessor accessor)
-      throws WHException
-    {
-      return true;
-    }
-
-    /** Check whether this calculator is capable of generating a final summary row value.
-    *@return true if it is capable.  tally() will only be called at the end for the summary
-    *     row if all columns are capable of generating a summary value.
-    */
-    public boolean canGenerateSummaryValue()
-      throws WHException
-    {
-      return true;
-    }
-
-    /** Feed a row to the column calculator.
-    */
-    public void processRowValue(WHAccessor accessor)
-      throws WHException
-    {
-      counter++;
-    }
-    
-    /** Tally a final result, obtaining whatever current aggregate value there is.
-    * Also resets the calculator in preparation for another set of rows.
-    */
-    public WHValue tally()
-      throws WHException
-    {
-      WHValue rval = new LongValue(counter);
-      counter = 0L;
-      return rval;
-    }
-
-  }
-    
-}
-  
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+import org.apache.warthog.api.*;
+
+/** This class is used to count the rows found.
+*/
+public class ColumnCount implements WHColumnDescription
+{
+  protected String returnColumnName;
+  
+  /** Constructor */
+  public ColumnCount(String returnColumnName)
+  {
+    this.returnColumnName = returnColumnName;
+  }
+  
+  /** Get the name of the return column */
+  public String getReturnColumnName()
+    throws WHException
+  {
+    return returnColumnName;
+  }
+  
+  /** Create a return column calculator for this column.
+  */
+  public WHColumnCalculator createCalculator()
+    throws WHException
+  {
+    return new CountCalculator();
+  }
+  
+  protected static class CountCalculator implements WHColumnCalculator
+  {
+    protected long counter = 0L;
+    
+    public CountCalculator()
+    {
+    }
+
+    /** Check whether a row can be added to to the column calculator.
+    * Does NOT actually change the result of the calculator!
+    *@return true if the row can be added and false if a tally should be done immediately.
+    */
+    public boolean canProcessRowValue(WHAccessor accessor)
+      throws WHException
+    {
+      return true;
+    }
+
+    /** Check whether this calculator is capable of generating a final summary row value.
+    *@return true if it is capable.  tally() will only be called at the end for the summary
+    *     row if all columns are capable of generating a summary value.
+    */
+    public boolean canGenerateSummaryValue()
+      throws WHException
+    {
+      return true;
+    }
+
+    /** Feed a row to the column calculator.
+    */
+    public void processRowValue(WHAccessor accessor)
+      throws WHException
+    {
+      counter++;
+    }
+    
+    /** Tally a final result, obtaining whatever current aggregate value there is.
+    * Also resets the calculator in preparation for another set of rows.
+    */
+    public WHValue tally()
+      throws WHException
+    {
+      WHValue rval = new LongValue(counter);
+      counter = 0L;
+      return rval;
+    }
+
+  }
+    
+}
+  
   
\ No newline at end of file

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnCount.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnCount.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnSumLong.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnSumLong.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnSumLong.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnSumLong.java Sun Dec 18 08:36:52 2011
@@ -1,116 +1,116 @@
-/* $Id: ColumnSumLong.java 1210225 2011-12-04 21:09:35Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-import org.apache.warthog.api.*;
-
-/** This class is used to create a column which sums long values found in the specified
-* base column.
-*/
-public class ColumnSumLong implements WHColumnDescription
-{
-  protected String baseColumnName;
-  protected String returnColumnName;
-  
-  /** Constructor */
-  public ColumnSumLong(String baseColumnName, String returnColumnName)
-  {
-    this.baseColumnName = baseColumnName;
-    this.returnColumnName = returnColumnName;
-  }
-  
-  /** Get the name of the return column */
-  public String getReturnColumnName()
-    throws WHException
-  {
-    return returnColumnName;
-  }
-  
-  /** Create a return column calculator for this column.
-  */
-  public WHColumnCalculator createCalculator()
-    throws WHException
-  {
-    return new SumLongCalculator(baseColumnName);
-  }
-  
-  protected static class SumLongCalculator implements WHColumnCalculator
-  {
-    protected String baseColumnName;
-    
-    protected long sum = 0L;
-    
-    public SumLongCalculator(String baseColumnName)
-    {
-      this.baseColumnName = baseColumnName;
-    }
-
-    /** Check whether a row can be added to to the column calculator.
-    * Does NOT actually change the result of the calculator!
-    *@return true if the row can be added and false if a tally should be done immediately.
-    */
-    public boolean canProcessRowValue(WHAccessor accessor)
-      throws WHException
-    {
-      // This calculator can always accept new values
-      return true;
-    }
-
-    /** Check whether this calculator is capable of generating a final summary row value.
-    *@return true if it is capable.  tally() will only be called at the end for the summary
-    *     row if all columns are capable of generating a summary value.
-    */
-    public boolean canGenerateSummaryValue()
-      throws WHException
-    {
-      // This calculator can always generate a summary value
-      return true;
-    }
-
-    /** Feed a row to the column calculator.
-    */
-    public void processRowValue(WHAccessor accessor)
-      throws WHException
-    {
-      WHValue value = accessor.getValue(baseColumnName);
-      if (value != null)
-      {
-        if (!(value instanceof LongValue))
-          throw new WHException("ColumnSumLong can only be used with values of LongValue type");
-        sum += ((LongValue)value).getValue();
-      }
-    }
-    
-    /** Tally a final result, obtaining whatever current aggregate value there is.
-    * Also resets the calculator in preparation for another set of rows.
-    */
-    public WHValue tally()
-      throws WHException
-    {
-      WHValue rval = new LongValue(sum);
-      sum = 0L;
-      return rval;
-    }
-
-  }
-    
-}
-  
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+import org.apache.warthog.api.*;
+
+/** This class is used to create a column which sums long values found in the specified
+* base column.
+*/
+public class ColumnSumLong implements WHColumnDescription
+{
+  protected String baseColumnName;
+  protected String returnColumnName;
+  
+  /** Constructor */
+  public ColumnSumLong(String baseColumnName, String returnColumnName)
+  {
+    this.baseColumnName = baseColumnName;
+    this.returnColumnName = returnColumnName;
+  }
+  
+  /** Get the name of the return column */
+  public String getReturnColumnName()
+    throws WHException
+  {
+    return returnColumnName;
+  }
+  
+  /** Create a return column calculator for this column.
+  */
+  public WHColumnCalculator createCalculator()
+    throws WHException
+  {
+    return new SumLongCalculator(baseColumnName);
+  }
+  
+  protected static class SumLongCalculator implements WHColumnCalculator
+  {
+    protected String baseColumnName;
+    
+    protected long sum = 0L;
+    
+    public SumLongCalculator(String baseColumnName)
+    {
+      this.baseColumnName = baseColumnName;
+    }
+
+    /** Check whether a row can be added to to the column calculator.
+    * Does NOT actually change the result of the calculator!
+    *@return true if the row can be added and false if a tally should be done immediately.
+    */
+    public boolean canProcessRowValue(WHAccessor accessor)
+      throws WHException
+    {
+      // This calculator can always accept new values
+      return true;
+    }
+
+    /** Check whether this calculator is capable of generating a final summary row value.
+    *@return true if it is capable.  tally() will only be called at the end for the summary
+    *     row if all columns are capable of generating a summary value.
+    */
+    public boolean canGenerateSummaryValue()
+      throws WHException
+    {
+      // This calculator can always generate a summary value
+      return true;
+    }
+
+    /** Feed a row to the column calculator.
+    */
+    public void processRowValue(WHAccessor accessor)
+      throws WHException
+    {
+      WHValue value = accessor.getValue(baseColumnName);
+      if (value != null)
+      {
+        if (!(value instanceof LongValue))
+          throw new WHException("ColumnSumLong can only be used with values of LongValue type");
+        sum += ((LongValue)value).getValue();
+      }
+    }
+    
+    /** Tally a final result, obtaining whatever current aggregate value there is.
+    * Also resets the calculator in preparation for another set of rows.
+    */
+    public WHValue tally()
+      throws WHException
+    {
+      WHValue rval = new LongValue(sum);
+      sum = 0L;
+      return rval;
+    }
+
+  }
+    
+}
+  
   
\ No newline at end of file

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnSumLong.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/ColumnSumLong.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerKey.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerKey.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerKey.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerKey.java Sun Dec 18 08:36:52 2011
@@ -1,53 +1,53 @@
-/* $Id: IntegerKey.java 1205831 2011-11-24 13:57:15Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-import org.apache.warthog.api.*;
-import org.apache.warthog.transactionalkeyvaluestore.*;
-
-/** Integer key.
-*/
-public class IntegerKey extends IntegerValue implements WHKey
-{
-  public IntegerKey(int value)
-  {
-    super(value);
-  }
-  
-  public IntegerKey(byte[] bytes)
-  {
-    super(bytes);
-  }
-
-  /** Calculate the hash function. */
-  public long getHashCode()
-  {
-    return calculateHashCode(value);
-  }
-  
-  public static long calculateHashCode(int value)
-  {
-    long x = (long)value;
-    return (x << 5) ^ (x >> 3);
-  }
-  
-}
-
-
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+import org.apache.warthog.api.*;
+import org.apache.warthog.transactionalkeyvaluestore.*;
+
+/** Integer key.
+*/
+public class IntegerKey extends IntegerValue implements WHKey
+{
+  public IntegerKey(int value)
+  {
+    super(value);
+  }
+  
+  public IntegerKey(byte[] bytes)
+  {
+    super(bytes);
+  }
+
+  /** Calculate the hash function. */
+  public long getHashCode()
+  {
+    return calculateHashCode(value);
+  }
+  
+  public static long calculateHashCode(int value)
+  {
+    long x = (long)value;
+    return (x << 5) ^ (x >> 3);
+  }
+  
+}
+
+

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerKey.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerKey.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerValue.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerValue.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerValue.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerValue.java Sun Dec 18 08:36:52 2011
@@ -1,96 +1,96 @@
-/* $Id: IntegerValue.java 1207794 2011-11-29 08:57:22Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-import org.apache.warthog.api.*;
-import org.apache.warthog.transactionalkeyvaluestore.*;
-
-/** Integer value, serializable.
-*/
-public class IntegerValue implements WHValue,WHKeyValue
-{
-  int value;
-  
-  public IntegerValue(int value)
-  {
-    this.value = value;
-  }
-  
-  public IntegerValue(byte[] bytes)
-  {
-    value = readObject(new BufferPointer(bytes));
-  }
-  
-  public byte[] serializeObject()
-  {
-    byte[] rval = new byte[sizeObject()];
-    writeObject(new BufferPointer(rval),value);
-    return rval;
-  }
-
-  /** Check if equals (classes must already agree) */
-  public boolean isEquals(WHKeyValue value)
-  {
-    IntegerValue x = (IntegerValue)value;
-    return x.value == this.value;
-  }
-
-  public int getValue()
-  {
-    return value;
-  }
-  
-  public int hashCode()
-  {
-    return (value << 5) ^ (value >> 3);
-  }
-  
-  public boolean equals(Object o)
-  {
-    if (this.getClass() != o.getClass())
-      return false;
-    return ((IntegerValue)o).value == value;
-  }
-
-  public static int readObject(BufferPointer bp)
-  {
-    int value = (((int)bp.readValue()) & 0xff);
-    value += ((((int)bp.readValue()) << 8) & 0xff00);
-    value += ((((int)bp.readValue()) << 16) & 0xff0000);
-    value += ((((int)bp.readValue()) << 24) & 0xff000000);
-    return value;
-  }
-  
-  public static int sizeObject()
-  {
-    return 4;
-  }
-  
-  public static void writeObject(BufferPointer bp, int value)
-  {
-    bp.writeValue((byte)(value & 0xff));
-    bp.writeValue((byte)((value >> 8) & 0xff));
-    bp.writeValue((byte)((value >> 16) & 0xff));
-    bp.writeValue((byte)((value >> 24) & 0xff));
-  }
-  
-}
-
-
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+import org.apache.warthog.api.*;
+import org.apache.warthog.transactionalkeyvaluestore.*;
+
+/** Integer value, serializable.
+*/
+public class IntegerValue implements WHValue,WHKeyValue
+{
+  int value;
+  
+  public IntegerValue(int value)
+  {
+    this.value = value;
+  }
+  
+  public IntegerValue(byte[] bytes)
+  {
+    value = readObject(new BufferPointer(bytes));
+  }
+  
+  public byte[] serializeObject()
+  {
+    byte[] rval = new byte[sizeObject()];
+    writeObject(new BufferPointer(rval),value);
+    return rval;
+  }
+
+  /** Check if equals (classes must already agree) */
+  public boolean isEquals(WHKeyValue value)
+  {
+    IntegerValue x = (IntegerValue)value;
+    return x.value == this.value;
+  }
+
+  public int getValue()
+  {
+    return value;
+  }
+  
+  public int hashCode()
+  {
+    return (value << 5) ^ (value >> 3);
+  }
+  
+  public boolean equals(Object o)
+  {
+    if (this.getClass() != o.getClass())
+      return false;
+    return ((IntegerValue)o).value == value;
+  }
+
+  public static int readObject(BufferPointer bp)
+  {
+    int value = (((int)bp.readValue()) & 0xff);
+    value += ((((int)bp.readValue()) << 8) & 0xff00);
+    value += ((((int)bp.readValue()) << 16) & 0xff0000);
+    value += ((((int)bp.readValue()) << 24) & 0xff000000);
+    return value;
+  }
+  
+  public static int sizeObject()
+  {
+    return 4;
+  }
+  
+  public static void writeObject(BufferPointer bp, int value)
+  {
+    bp.writeValue((byte)(value & 0xff));
+    bp.writeValue((byte)((value >> 8) & 0xff));
+    bp.writeValue((byte)((value >> 16) & 0xff));
+    bp.writeValue((byte)((value >> 24) & 0xff));
+  }
+  
+}
+
+

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerValue.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/IntegerValue.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongArray.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongArray.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongArray.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongArray.java Sun Dec 18 08:36:52 2011
@@ -1,128 +1,128 @@
-/* $Id: LongArray.java 1207794 2011-11-29 08:57:22Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-import org.apache.warthog.api.*;
-import org.apache.warthog.transactionalkeyvaluestore.*;
-
-/** Long array, serializable.
-*/
-public class LongArray implements WHKeyValue
-{
-  long[] value;
-  
-  public LongArray(long[] value)
-  {
-    this.value = value;
-  }
-  
-  public LongArray()
-  {
-  }
-  
-  public LongArray(byte[] bytes)
-  {
-    value = readObject(new BufferPointer(bytes));
-  }
-  
-  public byte[] serializeObject()
-  {
-    byte[] rval = new byte[sizeObject(value.length)];
-    writeObject(new BufferPointer(rval),value);
-    return rval;
-  }
-  
-  public long[] getValue()
-  {
-    return value;
-  }
-
-  /** Check if equals (classes must already agree) */
-  public boolean isEquals(WHKeyValue value)
-  {
-    long[] otherValue = ((LongArray)value).value;
-    return compareObject(this.value,otherValue);
-  }
-
-  public int hashCode()
-  {
-    int rval = 0;
-    for (int i = 0 ; i < value.length ; i++)
-    {
-      rval += (((int)value[i]) << 5) ^ (((int)value[i]) >> 3);
-    }
-    return rval;
-  }
-  
-  public boolean equals(Object o)
-  {
-    if (this.getClass() != o.getClass())
-      return false;
-    LongArray sa = (LongArray)o;
-    if (sa.value.length != value.length)
-      return false;
-    for (int i = 0 ; i < value.length ; i++)
-    {
-      if (sa.value[i] != value[i])
-        return false;
-    }
-    return true;
-  }
-
-  public static long[] readObject(BufferPointer bp)
-  {
-    int size = IntegerValue.readObject(bp);
-    long[] rval = new long[size];
-    for (int i = 0 ; i < size ; i++)
-    {
-      rval[i] = LongValue.readObject(bp);
-    }
-    return rval;
-  }
-  
-  public static int sizeObject(int size)
-  {
-    return IntegerValue.sizeObject() + LongValue.sizeObject() * size;
-  }
-  
-  public static void writeObject(BufferPointer bp, long[] value)
-  {
-    IntegerValue.writeObject(bp,value.length);
-    for (int i = 0 ; i < value.length ; i++)
-    {
-      LongValue.writeObject(bp,value[i]);
-    }
-  }
-  
-  public static boolean compareObject(long[] value, long[] otherValue)
-  {
-    if (otherValue.length != value.length)
-      return false;
-    for (int i = 0 ; i < otherValue.length ; i++)
-    {
-      if (otherValue[i] != value[i])
-        return false;
-    }
-    return true;
-  }
-  
-}
-
-
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+import org.apache.warthog.api.*;
+import org.apache.warthog.transactionalkeyvaluestore.*;
+
+/** Long array, serializable.
+*/
+public class LongArray implements WHKeyValue
+{
+  long[] value;
+  
+  public LongArray(long[] value)
+  {
+    this.value = value;
+  }
+  
+  public LongArray()
+  {
+  }
+  
+  public LongArray(byte[] bytes)
+  {
+    value = readObject(new BufferPointer(bytes));
+  }
+  
+  public byte[] serializeObject()
+  {
+    byte[] rval = new byte[sizeObject(value.length)];
+    writeObject(new BufferPointer(rval),value);
+    return rval;
+  }
+  
+  public long[] getValue()
+  {
+    return value;
+  }
+
+  /** Check if equals (classes must already agree) */
+  public boolean isEquals(WHKeyValue value)
+  {
+    long[] otherValue = ((LongArray)value).value;
+    return compareObject(this.value,otherValue);
+  }
+
+  public int hashCode()
+  {
+    int rval = 0;
+    for (int i = 0 ; i < value.length ; i++)
+    {
+      rval += (((int)value[i]) << 5) ^ (((int)value[i]) >> 3);
+    }
+    return rval;
+  }
+  
+  public boolean equals(Object o)
+  {
+    if (this.getClass() != o.getClass())
+      return false;
+    LongArray sa = (LongArray)o;
+    if (sa.value.length != value.length)
+      return false;
+    for (int i = 0 ; i < value.length ; i++)
+    {
+      if (sa.value[i] != value[i])
+        return false;
+    }
+    return true;
+  }
+
+  public static long[] readObject(BufferPointer bp)
+  {
+    int size = IntegerValue.readObject(bp);
+    long[] rval = new long[size];
+    for (int i = 0 ; i < size ; i++)
+    {
+      rval[i] = LongValue.readObject(bp);
+    }
+    return rval;
+  }
+  
+  public static int sizeObject(int size)
+  {
+    return IntegerValue.sizeObject() + LongValue.sizeObject() * size;
+  }
+  
+  public static void writeObject(BufferPointer bp, long[] value)
+  {
+    IntegerValue.writeObject(bp,value.length);
+    for (int i = 0 ; i < value.length ; i++)
+    {
+      LongValue.writeObject(bp,value[i]);
+    }
+  }
+  
+  public static boolean compareObject(long[] value, long[] otherValue)
+  {
+    if (otherValue.length != value.length)
+      return false;
+    for (int i = 0 ; i < otherValue.length ; i++)
+    {
+      if (otherValue[i] != value[i])
+        return false;
+    }
+    return true;
+  }
+  
+}
+
+

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongArray.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongArray.java
------------------------------------------------------------------------------
    svn:keywords = Id

Modified: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongComparatorAscending.java
URL: http://svn.apache.org/viewvc/incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongComparatorAscending.java?rev=1220353&r1=1220352&r2=1220353&view=diff
==============================================================================
--- incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongComparatorAscending.java (original)
+++ incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongComparatorAscending.java Sun Dec 18 08:36:52 2011
@@ -1,50 +1,50 @@
-/* $Id: LongComparatorAscending.java 1206460 2011-11-26 15:27:37Z kwright $ */
-
-/**
-* 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.warthog.common;
-
-import org.apache.warthog.api.*;
-
-/** Class that compares long values, and sorts in ascending order.
-*/
-public class LongComparatorAscending implements WHComparator
-{
-  /** Comparison method.
-  * This is only ever used to compare values; it cannot be used to compare null vs. non-null.
-  */
-  public int compare(WHValue leftValue, WHValue rightValue)
-    throws WHException
-  {
-    if (leftValue == null && rightValue == null)
-      return RESULT_EQUALS;
-    // Sort null values to the end
-    if (leftValue == null)
-      return RESULT_LESS;
-    if (rightValue == null)
-      return RESULT_GREATER;
-    if (!(leftValue instanceof LongValue) || !(rightValue instanceof LongValue))
-      throw new WHException("Cannot compare anything other than LongValues here");
-    long leftLongValue = ((LongValue)leftValue).getValue();
-    long rightLongValue = ((LongValue)rightValue).getValue();
-    if (leftLongValue == rightLongValue)
-      return RESULT_EQUALS;
-    return (leftLongValue < rightLongValue)?RESULT_GREATER:RESULT_LESS;
-  }
-  
+/* $Id$ */
+
+/**
+* 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.warthog.common;
+
+import org.apache.warthog.api.*;
+
+/** Class that compares long values, and sorts in ascending order.
+*/
+public class LongComparatorAscending implements WHComparator
+{
+  /** Comparison method.
+  * This is only ever used to compare values; it cannot be used to compare null vs. non-null.
+  */
+  public int compare(WHValue leftValue, WHValue rightValue)
+    throws WHException
+  {
+    if (leftValue == null && rightValue == null)
+      return RESULT_EQUALS;
+    // Sort null values to the end
+    if (leftValue == null)
+      return RESULT_LESS;
+    if (rightValue == null)
+      return RESULT_GREATER;
+    if (!(leftValue instanceof LongValue) || !(rightValue instanceof LongValue))
+      throw new WHException("Cannot compare anything other than LongValues here");
+    long leftLongValue = ((LongValue)leftValue).getValue();
+    long rightLongValue = ((LongValue)rightValue).getValue();
+    if (leftLongValue == rightLongValue)
+      return RESULT_EQUALS;
+    return (leftLongValue < rightLongValue)?RESULT_GREATER:RESULT_LESS;
+  }
+  
 }
\ No newline at end of file

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongComparatorAscending.java
------------------------------------------------------------------------------
    svn:eol-style = native

Propchange: incubator/lcf/branches/CONNECTORS-286/warthog-reimport/src/main/java/org/apache/warthog/common/LongComparatorAscending.java
------------------------------------------------------------------------------
    svn:keywords = Id



Mime
View raw message