abdullah alamoudi has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2101
Change subject: [NO ISSUE][COMP] Set Default dataverse in MetadataProvider
......................................................................
[NO ISSUE][COMP] Set Default dataverse in MetadataProvider
- user model changes: no
- storage format changes: no
- interface changes: no
Details:
- If MetadataProvider is created with null as the default
dataverse, set it to the Builtin Default dataverse.
Change-Id: I652669c03f28fce84509c02c05374e2c39104d38
---
M
asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/MetadataProvider.java
1 file changed, 7 insertions(+), 3 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/01/2101/1
diff --git
a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/MetadataProvider.java
b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/MetadataProvider.java
index d6a3f21..9271f332 100644
---
a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/MetadataProvider.java
+++
b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/declared/MetadataProvider.java
@@ -62,6 +62,7 @@
import org.apache.asterix.formats.nontagged.TypeTraitProvider;
import org.apache.asterix.metadata.MetadataManager;
import org.apache.asterix.metadata.MetadataTransactionContext;
+import org.apache.asterix.metadata.bootstrap.MetadataBuiltinEntities;
import
org.apache.asterix.metadata.dataset.hints.DatasetHints.DatasetCardinalityHint;
import org.apache.asterix.metadata.entities.Dataset;
import org.apache.asterix.metadata.entities.DatasourceAdapter;
@@ -160,7 +161,7 @@
public MetadataProvider(ICcApplicationContext appCtx, Dataverse
defaultDataverse) {
this.appCtx = appCtx;
- this.defaultDataverse = defaultDataverse;
+ this.defaultDataverse = defaultDataverse == null ?
MetadataBuiltinEntities.DEFAULT_DATAVERSE : defaultDataverse;
this.storageComponentProvider = appCtx.getStorageComponentProvider();
storageProperties = appCtx.getStorageProperties();
locks = new LockList();
@@ -433,8 +434,11 @@
if (primaryIndex != null && (dataset.getDatasetType() !=
DatasetType.EXTERNAL)) {
isSecondary = !indexName.equals(primaryIndex.getIndexName());
}
- Index theIndex = isSecondary ?
MetadataManager.INSTANCE.getIndex(mdTxnCtx, dataset.getDataverseName(),
- dataset.getDatasetName(), indexName) : primaryIndex;
+ Index theIndex =
+ isSecondary
+ ? MetadataManager.INSTANCE.getIndex(mdTxnCtx,
dataset.getDataverseName(),
+ dataset.getDatasetName(), indexName)
+ : primaryIndex;
int numPrimaryKeys = dataset.getPrimaryKeys().size();
RecordDescriptor outputRecDesc =
JobGenHelper.mkRecordDescriptor(typeEnv, opSchema, context);
Pair<IFileSplitProvider, AlgebricksPartitionConstraint> spPc =
--
To view, visit https://asterix-gerrit.ics.uci.edu/2101
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: I652669c03f28fce84509c02c05374e2c39104d38
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <[email protected]>