Permalink
Browse files

Upgrade krati to 3.4.

  • Loading branch information...
1 parent dfb6348 commit 5e537b5fba3bce4a0b410d93521feff8dfa4cad4 @jkreps jkreps committed Jul 10, 2010
View
@@ -48,7 +48,7 @@
<classpathentry kind="lib" path="lib/jackson-mapper-asl-1.4.0.jar"/>
<classpathentry kind="lib" path="lib/jackson-core-asl-1.4.0.jar"/>
<classpathentry kind="lib" path="lib/avro-modified-jdk5-1.3.0.jar"/>
- <classpathentry kind="lib" path="contrib/krati/lib/krati-0.3.3.jar"/>
<classpathentry kind="lib" path="contrib/hadoop/lib/pig-0.7.1-dev-core.jar"/>
+ <classpathentry kind="lib" path="contrib/krati/lib/krati-0.3.4.jar"/>
<classpathentry kind="output" path="classes"/>
</classpath>
@@ -34,7 +34,7 @@ do
CLASSPATH=$CLASSPATH:$file
done
-for file in $base_dir/contrib/hadoop-store-builder/lib/*.jar;
+for file in $base_dir/contrib/hadoop-store-builder/lib/*.jar $base_dir/contrib/krati/lib/*.jar;
do
CLASSPATH=$CLASSPATH:$file
done
Binary file not shown.
Binary file not shown.
@@ -13,9 +13,10 @@
import java.util.Map;
import krati.cds.array.DataArray;
-import krati.cds.impl.segment.MemorySegmentFactory;
+import krati.cds.impl.segment.ChannelSegmentFactory;
import krati.cds.impl.segment.SegmentFactory;
import krati.cds.impl.store.DynamicDataStore;
+import krati.util.FnvHashFunction;
import org.apache.log4j.Logger;
@@ -47,14 +48,15 @@ public KratiStorageEngine(String name,
int initLevel,
File dataDirectory) {
this.name = Utils.notNull(name);
- SegmentFactory segmentFactory = new MemorySegmentFactory();
+ SegmentFactory segmentFactory = new ChannelSegmentFactory();
try {
datastore = new DynamicDataStore(dataDirectory,
initLevel,
segmentFileSizeMB,
segmentFactory,
- hashLoadFactor);
+ hashLoadFactor,
+ new FnvHashFunction());
} catch(Exception e) {
logger.error("Failed to initialize datastore");
datastore = null;

0 comments on commit 5e537b5

Please sign in to comment.