Skip to content
Permalink
Browse files
Coordinated Change for Specify Node Group in Dataset WITH Record
Change-Id: I90eb7f81c15805269ddd120a0a9885ffe1a549ee
  • Loading branch information
idleft committed Aug 26, 2020
1 parent 9d26e07 commit d1df64d1c54e668e50daaddb86471bae01565894
Showing 2 changed files with 2 additions and 5 deletions.
@@ -140,7 +140,7 @@ private void createDatasets(IStatementExecutor statementExecutor, MetadataProvid
TypeExpression subItemType = new TypeReferenceExpression(
new Pair<>(MetadataConstants.METADATA_DATAVERSE_NAME, subscriptionsTypeName));
DatasetDecl createSubscriptionsDataset = new DatasetDecl(dataverseName, new Identifier(subscriptionsTableName),
subItemType, null, null, new HashMap<>(), DatasetType.INTERNAL, idd, null, true);
subItemType, null, new HashMap<>(), DatasetType.INTERNAL, idd, null, true);

((QueryTranslator) statementExecutor).handleCreateDatasetStatement(metadataProvider, createSubscriptionsDataset,
hcc, null);
@@ -155,7 +155,7 @@ private void createDatasets(IStatementExecutor statementExecutor, MetadataProvid
TypeExpression resultItemType =
new TypeReferenceExpression(new Pair<>(MetadataConstants.METADATA_DATAVERSE_NAME, resultsTypeName));
DatasetDecl createResultsDataset = new DatasetDecl(dataverseName, new Identifier(resultsTableName),
resultItemType, null, null, new HashMap<>(), DatasetType.INTERNAL, idd, null, true);
resultItemType, null, new HashMap<>(), DatasetType.INTERNAL, idd, null, true);

//Create an index on timestamp for results
CreateIndexStatement createTimeIndex = new CreateIndexStatement();
@@ -129,7 +129,6 @@ DatasetDecl ActiveDatasetSpecification(Token startStmtToken) throws ParseExcepti
boolean ifNotExists = false;
Map<String,String> properties = null;
Pair<List<Integer>, List<List<String>>> primaryKeyFields = null;
String nodeGroupName = null;
Map<String,String> hints = new HashMap<String,String>();
DatasetDecl stmt = null;
boolean autogenerated = false;
@@ -142,7 +141,6 @@ DatasetDecl ActiveDatasetSpecification(Token startStmtToken) throws ParseExcepti
ifNotExists = IfNotExists()
primaryKeyFields = PrimaryKey()
(<AUTOGENERATED> { autogenerated = true; } )?
(<ON> nodeGroupName = Identifier() )?
( <HINTS> hints = Properties() )?
( <WITH> withRecord = RecordConstructor() )?
{
@@ -156,7 +154,6 @@ DatasetDecl ActiveDatasetSpecification(Token startStmtToken) throws ParseExcepti
nameComponents.second,
datasetTypeExpr,
activeRecordTypeExpr,
nodeGroupName != null ? new Identifier(nodeGroupName) : null,
hints,
DatasetType.INTERNAL,
idd,

0 comments on commit d1df64d

Please sign in to comment.