abdullah alamoudi has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2102
Change subject: [NO ISSUE][STO] Make compact use the index io operation callback
......................................................................
[NO ISSUE][STO] Make compact use the index io operation callback
- user model changes: no
- storage format changes: no
- interface changes: no
Change-Id: Ie06f480d729448de99dcce1912b72449940e4ea3
---
M
hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/dataflow/LSMIndexCompactOperatorNodePushable.java
1 file changed, 1 insertion(+), 2 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/02/2102/1
diff --git
a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/dataflow/LSMIndexCompactOperatorNodePushable.java
b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/dataflow/LSMIndexCompactOperatorNodePushable.java
index 5ff3308..69fd482 100644
---
a/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/dataflow/LSMIndexCompactOperatorNodePushable.java
+++
b/hyracks-fullstack/hyracks/hyracks-storage-am-lsm-common/src/main/java/org/apache/hyracks/storage/am/lsm/common/dataflow/LSMIndexCompactOperatorNodePushable.java
@@ -28,7 +28,6 @@
import org.apache.hyracks.storage.am.common.impls.NoOpOperationCallback;
import org.apache.hyracks.storage.am.lsm.common.api.ILSMIndex;
import org.apache.hyracks.storage.am.lsm.common.api.ILSMIndexAccessor;
-import
org.apache.hyracks.storage.am.lsm.common.impls.NoOpIOOperationCallbackFactory;
public class LSMIndexCompactOperatorNodePushable extends
AbstractOperatorNodePushable {
private final IIndexDataflowHelper indexHelper;
@@ -60,7 +59,7 @@
ILSMIndexAccessor accessor =
index.createAccessor(NoOpOperationCallback.INSTANCE,
NoOpOperationCallback.INSTANCE);
try {
-
accessor.scheduleFullMerge(NoOpIOOperationCallbackFactory.INSTANCE.createIoOpCallback());
+ accessor.scheduleFullMerge(index.getIOOperationCallback());
} catch (Exception e) {
indexHelper.close();
throw new HyracksDataException(e);
--
To view, visit https://asterix-gerrit.ics.uci.edu/2102
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Ie06f480d729448de99dcce1912b72449940e4ea3
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <[email protected]>
