Skip to content

Commit e7ca49b

Browse files
authored
With clause enhance (apache#16353)
1 parent f32f574 commit e7ca49b

File tree

67 files changed

+3819
-375
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

67 files changed

+3819
-375
lines changed

integration-test/src/main/java/org/apache/iotdb/it/env/cluster/config/MppCommonConfig.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -657,6 +657,18 @@ public CommonConfig setRestrictObjectLimit(boolean restrictObjectLimit) {
657657
return this;
658658
}
659659

660+
@Override
661+
public CommonConfig setCteBufferSize(long cteBufferSize) {
662+
setProperty("cte_buffer_size_in_bytes", String.valueOf(cteBufferSize));
663+
return this;
664+
}
665+
666+
@Override
667+
public CommonConfig setMaxRowsInCteBuffer(int maxRows) {
668+
setProperty("max_rows_in_cte_buffer", String.valueOf(maxRows));
669+
return this;
670+
}
671+
660672
// For part of the log directory
661673
public String getClusterConfigStr() {
662674
return fromConsensusFullNameToAbbr(properties.getProperty(CONFIG_NODE_CONSENSUS_PROTOCOL_CLASS))

integration-test/src/main/java/org/apache/iotdb/it/env/cluster/config/MppSharedCommonConfig.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -691,4 +691,18 @@ public CommonConfig setRestrictObjectLimit(boolean restrictObjectLimit) {
691691
dnConfig.setRestrictObjectLimit(restrictObjectLimit);
692692
return this;
693693
}
694+
695+
@Override
696+
public CommonConfig setCteBufferSize(long cteBufferSize) {
697+
dnConfig.setCteBufferSize(cteBufferSize);
698+
cnConfig.setCteBufferSize(cteBufferSize);
699+
return this;
700+
}
701+
702+
@Override
703+
public CommonConfig setMaxRowsInCteBuffer(int maxRows) {
704+
dnConfig.setMaxRowsInCteBuffer(maxRows);
705+
cnConfig.setMaxRowsInCteBuffer(maxRows);
706+
return this;
707+
}
694708
}

integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteCommonConfig.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -482,4 +482,14 @@ public CommonConfig setAuditableOperationResult(String auditableOperationResult)
482482
public CommonConfig setRestrictObjectLimit(boolean restrictObjectLimit) {
483483
return this;
484484
}
485+
486+
@Override
487+
public CommonConfig setCteBufferSize(long cteBufferSize) {
488+
return this;
489+
}
490+
491+
@Override
492+
public CommonConfig setMaxRowsInCteBuffer(int maxRows) {
493+
return this;
494+
}
485495
}

integration-test/src/main/java/org/apache/iotdb/itbase/env/CommonConfig.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -213,4 +213,8 @@ default CommonConfig setDefaultDatabaseLevel(int defaultDatabaseLevel) {
213213
CommonConfig setAuditableOperationResult(String auditableOperationResult);
214214

215215
CommonConfig setRestrictObjectLimit(boolean restrictObjectLimit);
216+
217+
CommonConfig setCteBufferSize(long cteBufferSize);
218+
219+
CommonConfig setMaxRowsInCteBuffer(int maxRows);
216220
}

0 commit comments

Comments
 (0)