>From Janhavi Tripurwar <[email protected]>:
Janhavi Tripurwar has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20209 )
Change subject: [NO ISSUE]: add datasetName for index
......................................................................
[NO ISSUE]: add datasetName for index
- user model changes: no
- storage format changes: no
- interface changes: no
Ext-ref: MB-68042
Change-Id: I4269a893b433d620807d1c1b0108107f2ae43d36
---
M
asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java
M
asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/EntityDetails.java
2 files changed, 34 insertions(+), 3 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/09/20209/1
diff --git
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java
index 30c1b8b..a3c771c 100644
---
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java
+++
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java
@@ -1674,7 +1674,7 @@
stmtCreateIndex.isEnforced(), false,
MetadataUtil.PENDING_ADD_OP, creator);
bActiveTxn = false; // doCreateIndexImpl() takes over the current
transaction
- EntityDetails entityDetails = EntityDetails.newIndex(databaseName,
dataverseName, indexName);
+ EntityDetails entityDetails = EntityDetails.newIndex(databaseName,
dataverseName, datasetName, indexName);
doCreateIndexImpl(hcc, metadataProvider, ds, newIndex, jobFlags,
sourceLoc, creator, entityDetails);
} catch (Exception e) {
diff --git
a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/EntityDetails.java
b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/EntityDetails.java
index 068fb20..b934519 100644
---
a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/EntityDetails.java
+++
b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/EntityDetails.java
@@ -46,6 +46,8 @@
private final DataverseName dataverseName;
private final String entityName;
private final EntityType entityType;
+ // The name of the dataset, only applicable for index and synonym entities.
+ private String datasetName;
// The number of arguments that the function accepts. Relevant only for
function entity.
private int functionArity;
@@ -65,6 +67,15 @@
this.functionArity = functionArity;
}
+ private EntityDetails(String databaseName, DataverseName dataverseName,
String datasetName, String entityName,
+ EntityType entityType) {
+ this.databaseName = databaseName;
+ this.dataverseName = dataverseName;
+ this.datasetName = datasetName;
+ this.entityName = entityName;
+ this.entityType = entityType;
+ }
+
public static EntityDetails newDatabase(String databaseName) {
return new EntityDetails(databaseName, null, null,
EntityType.DATABASE);
}
@@ -100,8 +111,9 @@
return new EntityDetails(databaseName, dataverseName, synonymName,
EntityType.SYNONYM);
}
- public static EntityDetails newIndex(String databaseName, DataverseName
dataverseName, String indexName) {
- return new EntityDetails(databaseName, dataverseName, indexName,
EntityType.INDEX);
+ public static EntityDetails newIndex(String databaseName, DataverseName
dataverseName, String datasetName,
+ String indexName) {
+ return new EntityDetails(databaseName, dataverseName, datasetName,
indexName, EntityType.INDEX);
}
public static EntityDetails newExtension(String extensionName) {
@@ -128,6 +140,10 @@
return functionArity;
}
+ public String getDatasetName() {
+ return datasetName;
+ }
+
public static boolean isBuiltinFunctionSignature(FunctionSignature fs) {
return
isBuiltinFunctionDataverse(Objects.requireNonNull(fs.getDataverseName()))
||
BuiltinFunctions.getBuiltinFunctionInfo(fs.createFunctionIdentifier()) != null;
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20209
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: phoenix
Gerrit-Change-Id: I4269a893b433d620807d1c1b0108107f2ae43d36
Gerrit-Change-Number: 20209
Gerrit-PatchSet: 1
Gerrit-Owner: Janhavi Tripurwar <[email protected]>
Gerrit-MessageType: newchange