[NO ISSUE][OTH] Pass Request Parameters To Extensions
- user model changes: no
- storage format changes: no
- interface changes: no
Details:
- Pass request parameters to create/drop dataverse
statements to allow extensions to use optional
request parameters.
Change-Id: I284560ea3a7e3d1b36d73a8cfcdc85bf7b5a7f4e
Reviewed-on: https://asterix-gerrit.ics.uci.edu/3044
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Reviewed-by: Murtadha Hubail <mhubail@apache.org>
Reviewed-by: Till Westmann <tillw@apache.org>
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 8e86b9c..f619ab6 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
@@ -309,7 +309,7 @@
activeDataverse = handleUseDataverseStatement(metadataProvider, stmt);
break;
case CREATE_DATAVERSE:
- handleCreateDataverseStatement(metadataProvider, stmt);
+ handleCreateDataverseStatement(metadataProvider, stmt, requestParameters);
break;
case DATASET_DECL:
handleCreateDatasetStatement(metadataProvider, stmt, hcc, requestParameters);
@@ -324,7 +324,7 @@
handleCreateNodeGroupStatement(metadataProvider, stmt);
break;
case DATAVERSE_DROP:
- handleDataverseDropStatement(metadataProvider, stmt, hcc);
+ handleDataverseDropStatement(metadataProvider, stmt, hcc, requestParameters);
break;
case DATASET_DROP:
handleDatasetDropStatement(metadataProvider, stmt, hcc, requestParameters);
@@ -466,7 +466,8 @@
}
}
- protected void handleCreateDataverseStatement(MetadataProvider metadataProvider, Statement stmt) throws Exception {
+ protected void handleCreateDataverseStatement(MetadataProvider metadataProvider, Statement stmt,
+ IRequestParameters requestParameters) throws Exception {
CreateDataverseStatement stmtCreateDataverse = (CreateDataverseStatement) stmt;
String dvName = stmtCreateDataverse.getDataverseName().getValue();
MetadataTransactionContext mdTxnCtx = MetadataManager.INSTANCE.beginTransaction();
@@ -1227,7 +1228,7 @@
}
protected void handleDataverseDropStatement(MetadataProvider metadataProvider, Statement stmt,
- IHyracksClientConnection hcc) throws Exception {
+ IHyracksClientConnection hcc, IRequestParameters requestParameters) throws Exception {
DataverseDropStatement stmtDelete = (DataverseDropStatement) stmt;
SourceLocation sourceLoc = stmtDelete.getSourceLocation();
String dataverseName = stmtDelete.getDataverseName().getValue();