commit | 77ecc432933b1d2f84815dc78d05b488116fd454 | [log] [tgz] |
---|---|---|
author | zheilbron <zheilbron@gmail.com> | Mon Jun 03 23:57:55 2013 -0700 |
committer | zheilbron <zheilbron@gmail.com> | Mon Jun 03 23:57:55 2013 -0700 |
tree | f1a53bfd7772ea53f77cb7a890344ba50ba2efdb | |
parent | 98b3c92dbd075b5d218d673c4588b45b9427aa65 [diff] |
use a provider rather than a factory for operationtrackers
diff --git a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/PrimaryIndexOperationTrackerProvider.java b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/PrimaryIndexOperationTrackerProvider.java index 7b7198e..74be361 100644 --- a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/PrimaryIndexOperationTrackerProvider.java +++ b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/PrimaryIndexOperationTrackerProvider.java
@@ -32,7 +32,7 @@ } @Override - public ILSMOperationTracker createOperationTracker(IHyracksTaskContext ctx) { + public ILSMOperationTracker getOperationTracker(IHyracksTaskContext ctx) { DatasetLifecycleManager dslcManager = (DatasetLifecycleManager) ((IAsterixAppRuntimeContext) ctx .getJobletContext().getApplicationContext().getApplicationObject()).getIndexLifecycleManager(); return dslcManager.getOperationTracker(datasetID);
diff --git a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/SecondaryIndexOperationTrackerFactory.java b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/SecondaryIndexOperationTrackerProvider.java similarity index 71% rename from asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/SecondaryIndexOperationTrackerFactory.java rename to asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/SecondaryIndexOperationTrackerProvider.java index 4703875..4024836 100644 --- a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/SecondaryIndexOperationTrackerFactory.java +++ b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/opcallbacks/SecondaryIndexOperationTrackerProvider.java
@@ -6,18 +6,18 @@ import edu.uci.ics.hyracks.storage.am.lsm.common.api.ILSMOperationTracker; import edu.uci.ics.hyracks.storage.am.lsm.common.api.ILSMOperationTrackerProvider; -public class SecondaryIndexOperationTrackerFactory implements ILSMOperationTrackerProvider { +public class SecondaryIndexOperationTrackerProvider implements ILSMOperationTrackerProvider { private static final long serialVersionUID = 1L; private final ILSMIOOperationCallbackFactory ioOpCallbackFactory; - public SecondaryIndexOperationTrackerFactory(ILSMIOOperationCallbackFactory ioOpCallbackFactory) { + public SecondaryIndexOperationTrackerProvider(ILSMIOOperationCallbackFactory ioOpCallbackFactory) { this.ioOpCallbackFactory = ioOpCallbackFactory; } @Override - public ILSMOperationTracker createOperationTracker(IHyracksTaskContext ctx) { + public ILSMOperationTracker getOperationTracker(IHyracksTaskContext ctx) { return new BaseOperationTracker(ioOpCallbackFactory); }
diff --git a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/transaction/AsterixRuntimeComponentsProvider.java b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/transaction/AsterixRuntimeComponentsProvider.java index cf623a1..1a9716f 100644 --- a/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/transaction/AsterixRuntimeComponentsProvider.java +++ b/asterix-transactions/src/main/java/edu/uci/ics/asterix/transaction/management/service/transaction/AsterixRuntimeComponentsProvider.java
@@ -49,7 +49,7 @@ } @Override - public ILSMOperationTracker createOperationTracker(IHyracksTaskContext ctx) { + public ILSMOperationTracker getOperationTracker(IHyracksTaskContext ctx) { assert isSecondary; return new BaseOperationTracker(ioOpCallbackFactory); }