diff --git a/core/src/main/java/com/orientechnologies/orient/core/db/document/ODatabaseDocumentTx.java b/core/src/main/java/com/orientechnologies/orient/core/db/document/ODatabaseDocumentTx.java index d3a60c5e8f2..dd0ff4fffe1 100755 --- a/core/src/main/java/com/orientechnologies/orient/core/db/document/ODatabaseDocumentTx.java +++ b/core/src/main/java/com/orientechnologies/orient/core/db/document/ODatabaseDocumentTx.java @@ -1645,7 +1645,7 @@ public Set executeReadRecords(final Set iRids, final boolean if (iRids == null || iRids.isEmpty()) return records; - final Set rids = new HashSet(iRids); + final Collection rids = new ArrayList(iRids); for (Iterator it = rids.iterator(); it.hasNext();) { final ORecordId rid = it.next(); @@ -1669,7 +1669,7 @@ record = getLocalCache().findRecord(rid); } } - final List> rawRecords = ((OAbstractPaginatedStorage) storage).readRecords(rids); + final Collection> rawRecords = ((OAbstractPaginatedStorage) storage).readRecords(rids); for (OPair entry : rawRecords) { // NO SAME RECORD TYPE: CAN'T REUSE OLD ONE BUT CREATE A NEW ONE FOR IT final ORecord record = Orient.instance().getRecordFactoryManager().newInstance(entry.value.recordType); diff --git a/core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/OAbstractPaginatedStorage.java b/core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/OAbstractPaginatedStorage.java index 7bf88f65e8d..b11ea08a5fb 100644 --- a/core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/OAbstractPaginatedStorage.java +++ b/core/src/main/java/com/orientechnologies/orient/core/storage/impl/local/OAbstractPaginatedStorage.java @@ -20,20 +20,6 @@ package com.orientechnologies.orient.core.storage.impl.local; -import java.io.*; -import java.nio.ByteBuffer; -import java.nio.channels.Channels; -import java.nio.channels.FileChannel; -import java.nio.charset.Charset; -import java.text.SimpleDateFormat; -import java.util.*; -import java.util.concurrent.Callable; -import java.util.concurrent.atomic.AtomicBoolean; -import java.util.concurrent.atomic.AtomicInteger; -import java.util.zip.ZipEntry; -import java.util.zip.ZipInputStream; -import java.util.zip.ZipOutputStream; - import com.orientechnologies.common.concur.lock.OLockManager; import com.orientechnologies.common.concur.lock.OModificationOperationProhibitedException; import com.orientechnologies.common.directmemory.ODirectMemoryPointer; @@ -127,6 +113,20 @@ import com.orientechnologies.orient.core.tx.OTxListener; import edu.umd.cs.findbugs.annotations.SuppressFBWarnings; +import java.io.*; +import java.nio.ByteBuffer; +import java.nio.channels.Channels; +import java.nio.channels.FileChannel; +import java.nio.charset.Charset; +import java.text.SimpleDateFormat; +import java.util.*; +import java.util.concurrent.Callable; +import java.util.concurrent.atomic.AtomicBoolean; +import java.util.concurrent.atomic.AtomicInteger; +import java.util.zip.ZipEntry; +import java.util.zip.ZipInputStream; +import java.util.zip.ZipOutputStream; + /** * @author Andrey Lomakin * @since 28.03.13 @@ -3221,7 +3221,7 @@ private ORawBuffer readRecord(final OCluster clusterSegment, final ORecordId rid * @param iRids * Set of rids to load in one shot */ - public List> readRecords(final Set iRids) { + public Collection> readRecords(final Collection iRids) { checkOpeness(); final List> records = new ArrayList>(); @@ -4394,7 +4394,7 @@ protected ORID getImmutableResourceId(ORID iResourceId) { } } - protected Map> getRidsGroupedByCluster(final Set iRids) { + protected Map> getRidsGroupedByCluster(final Collection iRids) { final Map> ridsPerCluster = new HashMap>(); for (ORecordId rid : iRids) { List rids = ridsPerCluster.get(rid.clusterId);