This is an automated email from the ASF dual-hosted git repository.
preetham02 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git
The following commit(s) were added to refs/heads/master by this push:
new 6ac5bc316e [ASTERIXDB-3632]: Fix self-join query parsing in index
advisor
6ac5bc316e is described below
commit 6ac5bc316e7bcdc5a564deae3d60e0833397b1d6
Author: preetham0202 <[email protected]>
AuthorDate: Wed Nov 19 14:18:24 2025 +0530
[ASTERIXDB-3632]: Fix self-join query parsing in index advisor
- user model changes: no
- storage format changes: no
- interface changes: no
Ext-ref: MB-69430
Details:
Earlier, queries containing self joins were not processed properly by the
advisor. This update adds proper parsing and handling for self-join queries so
index recommendations are generated accurately.
Change-Id: Idf20b4c16d729c225798398e5985fc88f07e6bd0
Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/20589
Reviewed-by: Ali Alsuliman <[email protected]>
Tested-by: Ali Alsuliman <[email protected]>
---
.../asterix/optimizer/base/RuleCollections.java | 2 +-
.../optimizer/rules/am/BTreeAccessMethod.java | 6 ++--
.../rules/cbo/indexadvisor/FakeIndexProvider.java | 32 +++++++++++++---------
.../queries_sqlpp/cbo-join/CBOJoinQueries.xml | 5 ++++
.../self-join-advise/self-join-advise.1.ddl.sqlpp | 25 +++++++++++++++++
.../self-join-advise.2.update.sqlpp | 30 ++++++++++++++++++++
.../self-join-advise.3.update.sqlpp | 23 ++++++++++++++++
.../self-join-advise.4.query.sqlpp | 27 ++++++++++++++++++
.../self-join-advise.5.query.sqlpp | 26 ++++++++++++++++++
.../self-join-advise.6.query.sqlpp | 27 ++++++++++++++++++
.../self-join-advise.4.adm} | 2 +-
.../self-join-advise.5.adm} | 2 +-
.../self-join-advise/self-join-advise.6.adm | 1 +
.../simple-advise1/simple-advise1.5.adm | 2 +-
14 files changed, 191 insertions(+), 19 deletions(-)
diff --git
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java
index e14cbf32b9..f1eba1c88a 100644
---
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java
+++
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/base/RuleCollections.java
@@ -337,12 +337,12 @@ public final class RuleCollections {
accessMethod.add(new RemoveUnusedOneToOneEquiJoinRule());
accessMethod.add(new PushSimilarityFunctionsBelowJoin());
accessMethod.add(new RemoveUnusedAssignAndAggregateRule());
- accessMethod.add(new AdviseIndexRule());
return accessMethod;
}
public static List<IAlgebraicRewriteRule> buildPlanCleanupRuleCollection()
{
List<IAlgebraicRewriteRule> planCleanupRules = new LinkedList<>();
+ planCleanupRules.add(new AdviseIndexRule());
planCleanupRules.add(new SwitchInnerJoinBranchRule());
planCleanupRules.add(new
AsterixPushMapOperatorThroughUnionRule(LogicalOperatorTag.ASSIGN));
planCleanupRules.add(new ExtractCommonExpressionsRule());
diff --git
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/BTreeAccessMethod.java
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/BTreeAccessMethod.java
index 14cb45378d..b7e2a2872b 100644
---
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/BTreeAccessMethod.java
+++
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/am/BTreeAccessMethod.java
@@ -595,16 +595,18 @@ public class BTreeAccessMethod implements IAccessMethod {
for (LimitType limitType : lowKeyLimits) {
if (limitType != null) {
numLowKeys++;
- } else
+ } else {
break;
+ }
}
int numHighKeys = 0;
for (LimitType limitType : highKeyLimits) {
if (limitType != null) {
numHighKeys++;
- } else
+ } else {
break;
+ }
}
for (int i = 0; i < lowKeyExprs.length; i++) {
diff --git
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/cbo/indexadvisor/FakeIndexProvider.java
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/cbo/indexadvisor/FakeIndexProvider.java
index fc7206921d..a0ade94507 100644
---
a/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/cbo/indexadvisor/FakeIndexProvider.java
+++
b/asterixdb/asterix-algebra/src/main/java/org/apache/asterix/optimizer/rules/cbo/indexadvisor/FakeIndexProvider.java
@@ -40,7 +40,6 @@ import
org.apache.asterix.metadata.entities.InternalDatasetDetails;
import org.apache.asterix.om.constants.AsterixConstantValue;
import org.apache.asterix.om.types.IAType;
import org.apache.hyracks.algebricks.common.exceptions.AlgebricksException;
-import org.apache.hyracks.algebricks.common.utils.Pair;
import org.apache.hyracks.algebricks.core.algebra.base.LogicalVariable;
import
org.apache.hyracks.algebricks.core.algebra.expressions.ConstantExpression;
import
org.apache.hyracks.algebricks.core.algebra.expressions.IAlgebricksConstantValue;
@@ -119,8 +118,7 @@ public class FakeIndexProvider implements IIndexProvider {
}
private void addSingleDataSourceIndexes(List<AdvisorScanPlanNode>
scanPlanNodes) {
- Map<DatasetFullyQualifiedName, Pair<DataSourceScanOperator,
Set<List<String>>>> singleDataSourceFieldNamesMap =
- new HashMap<>();
+ Map<DataSourceScanOperator, Set<List<String>>>
singleDataSourceFieldNamesMap = new HashMap<>();
for (AdvisorScanPlanNode scanPlanNode : scanPlanNodes) {
DataSourceScanOperator scanOperator =
scanPlanNode.getScanOperator();
@@ -138,26 +136,34 @@ public class FakeIndexProvider implements IIndexProvider {
}
}
- singleDataSourceFieldNamesMap.put(fullyQualifiedName, new
Pair<>(scanOperator, datasetFieldNames));
+ singleDataSourceFieldNamesMap.put(scanOperator, datasetFieldNames);
}
- for (Map.Entry<DatasetFullyQualifiedName, Pair<DataSourceScanOperator,
Set<List<String>>>> entry : singleDataSourceFieldNamesMap
- .entrySet()) {
- DatasetFullyQualifiedName qualifiedName = entry.getKey();
- Set<List<String>> fieldNames = entry.getValue().getSecond();
- DataSourceScanOperator scanOperator = entry.getValue().getFirst();
+ for (Map.Entry<DataSourceScanOperator, Set<List<String>>> entry :
singleDataSourceFieldNamesMap.entrySet()) {
+ DataSourceScanOperator scanOperator = entry.getKey();
+ Set<List<String>> fieldNames = entry.getValue();
+ if (!(scanOperator.getDataSource() instanceof DatasetDataSource
dataSource)) {
+ continue;
+ }
- if (((DatasetDataSource)
scanOperator.getDataSource()).getDataset().getDatasetDetails()
- .getDatasetType() != DatasetConfig.DatasetType.INTERNAL) {
+ if (dataSource.getDataset().getDatasetDetails().getDatasetType()
!= DatasetConfig.DatasetType.INTERNAL) {
continue;
}
+ DatasetFullyQualifiedName qualifiedName =
dataSource.getDataset().getDatasetFullyQualifiedName();
+
List<List<String>> primaryKeys =
((InternalDatasetDetails) ((DatasetDataSource)
scanOperator.getDataSource()).getDataset()
.getDatasetDetails()).getPrimaryKey();
- Map<String, Index> datasetIndexes = new HashMap<>();
- filterIndexesMap.put(qualifiedName, datasetIndexes);
+ Map<String, Index> datasetIndexes;
+
+ if (filterIndexesMap.containsKey(qualifiedName)) {
+ datasetIndexes = filterIndexesMap.get(qualifiedName);
+ } else {
+ datasetIndexes = new HashMap<>();
+ filterIndexesMap.put(qualifiedName, datasetIndexes);
+ }
String primaryKeyName = ((DataSourceId)
scanOperator.getDataSource().getId()).getDatasourceName();
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/CBOJoinQueries.xml
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/CBOJoinQueries.xml
index ab75e0ca50..7c910c9f5a 100644
---
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/CBOJoinQueries.xml
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/CBOJoinQueries.xml
@@ -56,4 +56,9 @@
<output-dir compare="Text">nested-array-index</output-dir>
</compilation-unit>
</test-case>
+ <test-case FilePath="cbo-join/index-advisor">
+ <compilation-unit name="self-join-advise">
+ <output-dir compare="Text">self-join-advise</output-dir>
+ </compilation-unit>
+ </test-case>
</test-group>
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.1.ddl.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.1.ddl.sqlpp
new file mode 100644
index 0000000000..bf8b931584
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.1.ddl.sqlpp
@@ -0,0 +1,25 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+drop dataverse test if exists;
+create dataverse test;
+use test;
+
+CREATE DATASET A PRIMARY KEY ( a_0 : integer);
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.2.update.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.2.update.sqlpp
new file mode 100644
index 0000000000..924f8e1552
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.2.update.sqlpp
@@ -0,0 +1,30 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+use test;
+
+
+
+INSERT INTO A(
+ SELECT VALUE {"a_0": i, "a_1": i%20 , "a_2" : i, "a_3" : i}
+ FROM range(1, 5000) i
+);
+
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.3.update.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.3.update.sqlpp
new file mode 100644
index 0000000000..d8d3c912fb
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.3.update.sqlpp
@@ -0,0 +1,23 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+use test;
+
+
+ANALYZE DATASET A with {"sample": "high", "sample-seed": 2};
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.4.query.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.4.query.sqlpp
new file mode 100644
index 0000000000..dc15af751f
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.4.query.sqlpp
@@ -0,0 +1,27 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+use test;
+
+
+advise SELECT *
+FROM A AS h1, A AS h2
+WHERE h1.`a_2` = 900;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.5.query.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.5.query.sqlpp
new file mode 100644
index 0000000000..99f2bfcac6
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.5.query.sqlpp
@@ -0,0 +1,26 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+use test;
+
+advise SELECT *
+FROM A AS h1, A AS h2
+WHERE h2.`a_2` = 900;
+
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.6.query.sqlpp
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.6.query.sqlpp
new file mode 100644
index 0000000000..6f7b6ad4a4
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/queries_sqlpp/cbo-join/index-advisor/self-join-advise/self-join-advise.6.query.sqlpp
@@ -0,0 +1,27 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+
+use test;
+
+advise SELECT *
+FROM A d1
+JOIN A d2
+ON d1.a_1 /* +indexnl */ = d2.a_1
+WHERE d2.`a_2` = 800 and d1.`a_3` = 900;
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
b/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/self-join-advise/self-join-advise.4.adm
similarity index 61%
copy from
asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
copy to
asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/self-join-advise/self-join-advise.4.adm
index e2b4c29dde..a1000b0d21 100644
---
a/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/self-join-advise/self-join-advise.4.adm
@@ -1 +1 @@
-[{"#operator":"Advise","advice":{"#operator":"IndexAdvice","adviseinfo":{"current_indexes":[],"recommended_indexes":{"indexes":[{"index_statement":"CREATE
INDEX idx_b ON `Default`.`test`.`A`(`b`);"}]}}}}]
\ No newline at end of file
+[{"#operator":"Advise","advice":{"#operator":"IndexAdvice","adviseinfo":{"current_indexes":[],"recommended_indexes":{"indexes":[{"index_statement":"CREATE
INDEX idx_a_2 ON `Default`.`test`.`A`(`a_2`);"}]}}}}]
\ No newline at end of file
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
b/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/self-join-advise/self-join-advise.5.adm
similarity index 61%
copy from
asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
copy to
asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/self-join-advise/self-join-advise.5.adm
index e2b4c29dde..a1000b0d21 100644
---
a/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/self-join-advise/self-join-advise.5.adm
@@ -1 +1 @@
-[{"#operator":"Advise","advice":{"#operator":"IndexAdvice","adviseinfo":{"current_indexes":[],"recommended_indexes":{"indexes":[{"index_statement":"CREATE
INDEX idx_b ON `Default`.`test`.`A`(`b`);"}]}}}}]
\ No newline at end of file
+[{"#operator":"Advise","advice":{"#operator":"IndexAdvice","adviseinfo":{"current_indexes":[],"recommended_indexes":{"indexes":[{"index_statement":"CREATE
INDEX idx_a_2 ON `Default`.`test`.`A`(`a_2`);"}]}}}}]
\ No newline at end of file
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/self-join-advise/self-join-advise.6.adm
b/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/self-join-advise/self-join-advise.6.adm
new file mode 100644
index 0000000000..f39ecc2379
--- /dev/null
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/self-join-advise/self-join-advise.6.adm
@@ -0,0 +1 @@
+[{"#operator":"Advise","advice":{"#operator":"IndexAdvice","adviseinfo":{"current_indexes":[],"recommended_indexes":{"indexes":[{"index_statement":"CREATE
INDEX idx_a_3 ON `Default`.`test`.`A`(`a_3`);"},{"index_statement":"CREATE
INDEX idx_a_1 ON `Default`.`test`.`A`(`a_1`);"}]}}}}]
\ No newline at end of file
diff --git
a/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
b/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
index e2b4c29dde..e7a4a4502b 100644
---
a/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
+++
b/asterixdb/asterix-app/src/test/resources/runtimets/results/cbo-join/index-advisor/simple-advise1/simple-advise1.5.adm
@@ -1 +1 @@
-[{"#operator":"Advise","advice":{"#operator":"IndexAdvice","adviseinfo":{"current_indexes":[],"recommended_indexes":{"indexes":[{"index_statement":"CREATE
INDEX idx_b ON `Default`.`test`.`A`(`b`);"}]}}}}]
\ No newline at end of file
+[{"#operator":"Advise","advice":{"#operator":"IndexAdvice","adviseinfo":{"current_indexes":[],"recommended_indexes":{"indexes":[{"index_statement":"CREATE
INDEX idx_b ON `Default`.`test`.`A`(`b`);"},{"index_statement":"CREATE INDEX
idx_c ON `Default`.`test`.`B`(`c`);"}]}}}}]
\ No newline at end of file
