[284307] Add support for streaming of large byte arrays / BLOB

https://bugs.eclipse.org/bugs/show_bug.cgi?id=284307

1 files changed, 6 insertions, 12 deletions

diff --git a/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/mem/MEMStoreAccessor.java b/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/mem/MEMStoreAccessor.java
index cd9f8d0e46..9d33e7d35f 100644
--- a/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/mem/MEMStoreAccessor.java
+++ b/plugins/org.eclipse.emf.cdo.server/src/org/eclipse/emf/cdo/internal/server/mem/MEMStoreAccessor.java
@@ -345,41 +345,35 @@ public class MEMStoreAccessor extends LongIDStoreAccessor
   public void rawExport(CDODataOutput out, int fromBranchID, int toBranchID, long fromCommitTime, long toCommitTime)
       throws IOException
   {
-    // TODO: implement MEMStoreAccessor.rawExport(out, lastReplicatedBranchID, lastReplicatedCommitTime)
-    throw new UnsupportedOperationException();
+    getStore().rawExport(out, fromBranchID, toBranchID, fromCommitTime, toCommitTime);
   }
 
   public void rawImport(CDODataInput in, int fromBranchID, int toBranchID, long fromCommitTime, long toCommitTime,
       OMMonitor monitor) throws IOException
   {
-    // TODO: implement MEMStoreAccessor.rawImport(in, fromBranchID, toBranchID, fromCommitTime, toCommitTime)
-    throw new UnsupportedOperationException();
+    getStore().rawImport(in, fromBranchID, toBranchID, fromCommitTime, toCommitTime, monitor);
   }
 
   public void queryLobs(List<byte[]> ids)
   {
-    // TODO: implement MEMStoreAccessor.queryLobs(ids)
-    throw new UnsupportedOperationException();
+    getStore().queryLobs(ids);
   }
 
   public void loadLob(byte[] id, OutputStream out) throws IOException
   {
-    // TODO: implement MEMStoreAccessor.loadLob(id, out)
-    throw new UnsupportedOperationException();
+    getStore().loadLob(id, out);
   }
 
   @Override
   protected void writeBlob(byte[] id, long size, InputStream inputStream) throws IOException
   {
-    // TODO: implement MEMStoreAccessor.writeBlob(id, size, in)
-    throw new UnsupportedOperationException();
+    getStore().writeBlob(id, size, inputStream);
   }
 
   @Override
   protected void writeClob(byte[] id, long size, Reader reader) throws IOException
   {
-    // TODO: implement MEMStoreAccessor.writeClob(id, size, reader)
-    throw new UnsupportedOperationException();
+    getStore().writeClob(id, size, reader);
   }
 
   @Override