Improving the FileHandle efficiency.

Author: anu3990

marklogic-client-api/src/main/java/com/marklogic/client/impl/OkHttpServices.java

@@ -5388,7 +5388,7 @@ private <T> T getEntity(ResponseBody body, Class<T> as) {
         }
         Path path = Files.createTempFile("tmp", suffix);
         if ( isBinary == true ) {
-          Files.write(path, body.bytes());
+            Utilities.write(body.byteStream(), path);
         } else {
           Writer out = Files.newBufferedWriter(path, Charset.forName("UTF-8"));
           try {

marklogic-client-api/src/main/java/com/marklogic/client/impl/Utilities.java

@@ -24,9 +24,14 @@
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.OutputStream;
+import java.io.OutputStreamWriter;
+import java.io.RandomAccessFile;
 import java.io.Reader;
 import java.io.StringReader;
+import java.nio.ByteBuffer;
+import java.nio.channels.FileChannel;
 import java.nio.charset.Charset;
+import java.nio.file.Path;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -60,6 +65,7 @@ public final class Utilities {
   private static DocumentBuilderFactory factory;
 
   private static DatatypeFactory datatypeFactory;
+  static private int BUFFER_SIZE = 8192;
 
   private static DocumentBuilderFactory getFactory()
     throws ParserConfigurationException {
@@ -669,4 +675,26 @@ static public DatatypeFactory getDatatypeFactory() {
     }
     return datatypeFactory;
   }
+  
+  static public void write(InputStream in, Path path) { 
+      try {
+      RandomAccessFile outFile = new RandomAccessFile(path.toString(), "rw");
+      FileChannel  inChannel = outFile.getChannel();
+      byte[] buf = new byte[BUFFER_SIZE * 2];
+      ByteBuffer byteBuf;
+      
+      while (in.read(buf) != -1) {
+        byteBuf = ByteBuffer.wrap(buf);
+        byteBuf.flip();
+        inChannel.write(byteBuf);
+        byteBuf.clear();
+      }
+      outFile.close();
+      } catch (IOException e) {
+          throw new MarkLogicIOException("Internal Exception occured.");
+      } 
+  }
+  
+  static public void write(Reader in, OutputStreamWriter out) { }
+  static public void write(Reader in, OutputStream out) {}
 }