wip

Author: ebremer

src/main/java/com/ebremer/beakgraph/HDTish/BitPackedReader.java

@@ -12,6 +12,9 @@ public BitPackedReader(ByteBuffer buffer, int b) {
     }
 
     public int readNthValue(int n) {
+        if (n==27) {
+            int gg = 0;
+        }
         int bitPos = n * b;
         int byteIdx = bitPos / 8;
         if (byteIdx >= buffer.capacity()) {

src/main/java/com/ebremer/beakgraph/HDTish/BitPackedWriter.java

@@ -45,11 +45,7 @@ public byte[] getBuffer() {
         return os.toByteArray();
     }
 
-    // Write the least significant n bits of the integer to the buffer
     public void writeInteger(int value) throws IOException {        
-        //if (width < 0 || width > 32) {
-          //  throw new IllegalArgumentException("n must be between 0 and 32 ---> "+value);
-       // }
         entries++;
         // Extract the least significant n bits
         long bits = value & ((1L << width) - 1);
@@ -68,9 +64,6 @@ public void writeInteger(int value) throws IOException {
     }
 
     public void writeLong(long value) throws IOException {
-        //if (width < 0 || width > 64) {
-          //  throw new IllegalArgumentException("width must be between 0 and 64");
-       // }
         entries++;
         long bits = value & ((1L << width) - 1);
         bitBuffer = (bitBuffer << width) | bits;
@@ -99,7 +92,6 @@ public static BitPackedWriter forBuffer(Path path, long width) throws IOExceptio
         if (width < 0 || width > 64) {
             throw new IllegalArgumentException("n must be between 0 and 64 ---> "+width);
         }
-        System.out.println(path+" ---> "+width);
         ByteArrayOutputStream buffer = new ByteArrayOutputStream();
         ByteWriter fileWriter = new ByteWriter() {
             @Override

src/main/java/com/ebremer/beakgraph/HDTish/FiveSectionDictionaryWriter.java

@@ -298,15 +298,16 @@ public FiveSectionDictionaryWriter build() throws IOException {
                             c.co = o;
                             if (o.isLiteral()) {
                                 String dt = o.getLiteralDatatypeURI();
-                                Number n = (Number) o.getLiteralValue();
                                 if (dt.equals(XSD.xlong.getURI())) {
-                                        IO.println("ENTERING LONG =======================> "+n);
-                                        this.maxLong = Math.max(this.maxLong, n.longValue());
-                                        this.minLong = Math.min(this.minLong, n.longValue());
+                                    Number n = (Number) o.getLiteralValue();
+                                 //   IO.println("ENTERING LONG =======================> "+n);
+                                    this.maxLong = Math.max(this.maxLong, n.longValue());
+                                    this.minLong = Math.min(this.minLong, n.longValue());
                                 } else if (dt.equals(XSD.xint.getURI())) {
-                                        IO.println(o+" === ENTERING INTEGER ==== "+o.getLiteralDatatypeURI()+" ===================> "+n);
-                                        this.maxInteger = Math.max(this.maxInteger, n.intValue());
-                                        this.minInteger = Math.min(this.minInteger, n.intValue());
+                                    Number n = (Number) o.getLiteralValue();
+                                //    IO.println(o+" === ENTERING INTEGER ==== "+o.getLiteralDatatypeURI()+" ===================> "+n);
+                                    this.maxInteger = Math.max(this.maxInteger, n.intValue());
+                                    this.minInteger = Math.min(this.minInteger, n.intValue());
                                 }
                             }
                             if (subjects.contains(o)) {

src/main/java/com/ebremer/beakgraph/HDTish/HDF5Reader.java

@@ -16,10 +16,10 @@ public static void main(String[] args) {
         try (HdfFile hdfFile = new HdfFile(src.toPath())) {
             ContiguousDataset dataset = (ContiguousDataset) hdfFile.getDatasetByPath("/HDT/objects/integers");
             long width = (Long) dataset.getAttribute("width").getData();
+            System.out.println("CAPACITY :"+dataset.getBuffer().capacity());
             System.out.println("BIT WIDTH = "+width);
             BitPackedReader bpr = new BitPackedReader(dataset.getBuffer(), (int) width);
-            
-            IntStream.range(0, 27).forEach(i->{
+            IntStream.range(0, 28).forEach(i->{
                 System.out.println(i+" ==> "+bpr.readNthValue(i));
             });
 

src/main/java/com/ebremer/beakgraph/HDTish/HDF5Writer.java

@@ -4,7 +4,6 @@
 import static com.ebremer.beakgraph.HDTish.UTIL.putAttributes;
 import io.jhdf.HdfFile;
 import io.jhdf.WritableHdfFile;
-import io.jhdf.api.WritableDataset;
 import io.jhdf.api.WritableGroup;
 import java.io.File;
 import java.io.FileInputStream;
@@ -163,7 +162,19 @@ private HDF5Writer(Builder builder) throws IOException {
                         }
                     }
                 });
-        }        
+        }  
+        Bs.close();
+        Bp.close();
+        Bo.close();
+        Ss.close();
+        Sp.close();
+        So.close();
+        SBs.close();
+        SBp.close();
+        SBo.close();
+        BBs.close();
+        BBp.close();
+        BBo.close();
         try (WritableHdfFile hdfFile = HdfFile.write(builder.getDestination().toPath())) {
             WritableGroup ultra = hdfFile.putGroup(builder.getName());           
             WritableGroup group = null;