>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

Reply via email to