database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[vectorized](jdbc) support array type in jdbc external table (#15303)

Browse Source
This commit is contained in:
zhangstar333
2022-12-30 00:29:08 +08:00
committed by GitHub
parent edb9a3b58d
commit 85c7c531f1
11 changed files with 385 additions and 154 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/analysis/ColumnDef.java
View File

@ -266,7 +266,7 @@ public class ColumnDef {
defaultValue = DefaultValue.BITMAP_EMPTY_DEFAULT_VALUE;
}
if (type.getPrimitiveType() == PrimitiveType.ARRAY) {
if (type.getPrimitiveType() == PrimitiveType.ARRAY && isOlap) {
if (isKey()) {
throw new AnalysisException("Array can only be used in the non-key column of"
+ " the duplicate table at present.");

2
fe/fe-core/src/main/java/org/apache/doris/analysis/CreateTableStmt.java
View File

@ -390,7 +390,7 @@ public class CreateTableStmt extends DdlStmt {
for (ColumnDef columnDef : columnDefs) {
columnDef.analyze(engineName.equals("olap"));
if (columnDef.getType().isArrayType()) {
if (columnDef.getType().isArrayType() && engineName.equals("olap")) {
if (columnDef.getAggregateType() != null && columnDef.getAggregateType() != AggregateType.NONE) {
throw new AnalysisException("Array column can't support aggregation "
+ columnDef.getAggregateType());