>From Ritik Raj <[email protected]>:
Ritik Raj has uploaded this change for review. (
https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17648 )
Change subject: [ASTERIXDB-3227][COMP] Extracted getDataset(..) function out
from doCreateDatasetStatement(..)
......................................................................
[ASTERIXDB-3227][COMP] Extracted getDataset(..) function out from
doCreateDatasetStatement(..)
- user model changes: no
- storage format changes: no
- interface changes: no
This small patch extracts dataset object creation in function getDataset(..)
Change-Id: I7da017d4bf1c56381033e5c07cb6f094bbd22aca
---
M
asterixdb/asterix-app/src/main/java/org/apache/asterix/app/translator/QueryTranslator.java
1 file changed, 31 insertions(+), 4 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/48/17648/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 dc165a0..f9d78f4 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
@@ -90,6 +90,7 @@
import org.apache.asterix.common.functions.FunctionSignature;
import org.apache.asterix.common.metadata.DatasetFullyQualifiedName;
import org.apache.asterix.common.metadata.DataverseName;
+import org.apache.asterix.common.metadata.IDataset;
import org.apache.asterix.common.metadata.IMetadataLockUtil;
import org.apache.asterix.common.utils.JobUtils;
import org.apache.asterix.common.utils.JobUtils.ProgressState;
@@ -886,10 +887,9 @@
}
// #. add a new dataset with PendingAddOp
- dataset = new Dataset(dataverseName, datasetName,
itemTypeDataverseName, itemTypeName,
- metaItemTypeDataverseName, metaItemTypeName, ngName,
compactionPolicy, compactionPolicyProperties,
- datasetDetails, dd.getHints(), dsType,
DatasetIdFactory.generateDatasetId(),
- MetadataUtil.PENDING_ADD_OP, compressionScheme,
datasetFormatInfo);
+ dataset = (Dataset) getDataset(dd, dataverseName, datasetName,
itemTypeDataverseName, itemTypeName,
+ metaItemTypeDataverseName, metaItemTypeName, dsType,
compactionPolicy, compactionPolicyProperties,
+ compressionScheme, datasetFormatInfo, datasetDetails,
ngName);
MetadataManager.INSTANCE.addDataset(metadataProvider.getMetadataTxnContext(),
dataset);
if (itemTypeIsInline) {
@@ -981,6 +981,18 @@
return Optional.of(dataset);
}
+ protected IDataset getDataset(DatasetDecl dd, DataverseName dataverseName,
String datasetName,
+ DataverseName itemTypeDataverseName, String itemTypeName,
DataverseName metaItemTypeDataverseName,
+ String metaItemTypeName, DatasetType dsType, String
compactionPolicy,
+ Map<String, String> compactionPolicyProperties, String
compressionScheme,
+ DatasetFormatInfo datasetFormatInfo, IDatasetDetails
datasetDetails, String ngName)
+ throws AlgebricksException {
+ return new Dataset(dataverseName, datasetName, itemTypeDataverseName,
itemTypeName, metaItemTypeDataverseName,
+ metaItemTypeName, ngName, compactionPolicy,
compactionPolicyProperties, datasetDetails, dd.getHints(),
+ dsType, DatasetIdFactory.generateDatasetId(),
MetadataUtil.PENDING_ADD_OP, compressionScheme,
+ datasetFormatInfo);
+ }
+
protected Triple<DataverseName, String, Boolean>
extractDatasetItemTypeName(DataverseName datasetDataverseName,
String datasetName, TypeExpression itemTypeExpr, boolean
isMetaItemType, SourceLocation sourceLoc)
throws CompilationException {
--
To view, visit https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/17648
To unsubscribe, or for help writing mail filters, visit
https://asterix-gerrit.ics.uci.edu/settings
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Change-Id: I7da017d4bf1c56381033e5c07cb6f094bbd22aca
Gerrit-Change-Number: 17648
Gerrit-PatchSet: 1
Gerrit-Owner: Ritik Raj <[email protected]>
Gerrit-MessageType: newchange
