cool-core/src/main/java/com/nus/cool/loader/DataLoader.java
private DataOutputStream newCublet() throws IOException  {
        String file_name = Long.toHexString(System.currentTimeMillis()) + ".dz";
        System.out.println("[*] A new cublet "+ file_name + " is created!");
        File cublet = new File(outputDir, file_name);
        DataOutputStream out = new DataOutputStream(new FileOutputStream(cublet));
        offset = new MetaChunkWS(tableSchema, 0, metaFields).writeTo(out);
        chunkOffsets.clear();
        chunkOffsets.add(offset - Ints.BYTES);
        return out;
    }
/**
     * Create a new cublet
     * @return output stream to write data into new cublet
     * @throws IOException
     */
Create a new cublet
@return output stream to write data into new cublet
@throws IOException
Create a new cublet @return output stream to write data into new cublet @throws IOException
private DataOutputStream newCublet() throws IOException  {
        String file_name = Long.toHexString(System.currentTimeMillis()) + ".dz";
        System.out.println("[*] A new cublet "+ file_name + " is created!");
        File cublet = new File(outputDir, file_name);
        DataOutputStream out = new DataOutputStream(new FileOutputStream(cublet));
        offset = new MetaChunkWS(tableSchema, 0, metaFields).writeTo(out);
        chunkOffsets.clear();
        chunkOffsets.add(offset - Ints.BYTES);
        return out;
    }
private DataOutputStream newCublet ( ) throws IOException { String file_name = Long . toHexString ( System . currentTimeMillis ( ) ) + ".dz" ; System . out . println ( "[*] A new cublet " + file_name + " is created!" ) ; File cublet = new File ( outputDir , file_name ) ; DataOutputStream out = new DataOutputStream ( new FileOutputStream ( cublet ) ) ; offset = new MetaChunkWS ( tableSchema , 0 , metaFields ) . writeTo ( out ) ; chunkOffsets . clear ( ) ; chunkOffsets . add ( offset - Ints . BYTES ) ; return out ; }
Create a new cublet
 @return output stream to write data into new cublet
 @throws IOException
Create a new cublet @return output stream to write data into new cublet @throws IOException