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

[Improvement](regression-test) add http_stream case (#24930)

Browse Source
This commit is contained in:
zzzzzzzs
2023-09-27 09:55:52 +08:00
committed by GitHub
parent 2e8f9a6429
commit 6d27a016b9
5 changed files with 414 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
fe/fe-core/src/main/java/org/apache/doris/tablefunction/HttpStreamTableValuedFunction.java
View File

@ -22,10 +22,10 @@ import org.apache.doris.analysis.StorageBackend.StorageType;
import org.apache.doris.common.AnalysisException;
import org.apache.doris.thrift.TFileType;
import org.apache.commons.collections.map.CaseInsensitiveMap;
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import java.util.HashMap;
import java.util.Map;
/**
@ -37,16 +37,16 @@ public class HttpStreamTableValuedFunction extends ExternalFileTableValuedFuncti
public static final String NAME = "http_stream";
public HttpStreamTableValuedFunction(Map<String, String> params) throws AnalysisException {
Map<String, String> fileParams = new HashMap<>();
Map<String, String> fileParams = new CaseInsensitiveMap();
for (String key : params.keySet()) {
String lowerKey = key.toLowerCase();
if (!FILE_FORMAT_PROPERTIES.contains(lowerKey)) {
throw new AnalysisException(key + " is invalid property");
}
fileParams.put(lowerKey, params.get(key));
fileParams.put(lowerKey, params.get(key).toLowerCase());
}
String formatString = fileParams.getOrDefault(FORMAT, "");
String formatString = fileParams.getOrDefault(FORMAT, "").toLowerCase();
if (formatString.equals("parquet")
|| formatString.equals("avro")
|| formatString.equals("orc")) {