Skip to content

Commit d0d916d

Browse files
committed
fix build again
1 parent bfdca1a commit d0d916d

File tree

5 files changed

+7
-4
lines changed

5 files changed

+7
-4
lines changed

be/src/vec/exec/format/table/iceberg_metadata_jni_reader.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@
2222
namespace doris::vectorized {
2323
#include "common/compile_check_begin.h"
2424

25-
const std::string PaimonJniReader::HADOOP_OPTION_PREFIX = "hadoop.";
25+
static const std::string HADOOP_OPTION_PREFIX = "hadoop.";
2626

2727
IcebergMetadataJniReader::IcebergMetadataJniReader(
2828
const std::vector<SlotDescriptor*>& file_slot_descs, RuntimeState* state,

build.sh

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -870,6 +870,7 @@ EOF
870870
extensions_modules+=("avro-scanner")
871871
extensions_modules+=("lakesoul-scanner")
872872
extensions_modules+=("preload-extensions")
873+
extensions_modules+=("iceberg-metadata-scanner")
873874

874875
if [[ -n "${BE_EXTENSION_IGNORE}" ]]; then
875876
IFS=',' read -r -a ignore_modules <<<"${BE_EXTENSION_IGNORE}"

fe/be-java-extensions/iceberg-metadata-scanner/src/main/java/org/apache/doris/iceberg/IcebergMetadataJniScanner.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,8 @@
1919

2020
import org.apache.doris.common.jni.JniScanner;
2121
import org.apache.doris.common.jni.vec.ColumnType;
22+
import org.apache.doris.common.security.authentication.PreExecutionAuthenticator;
23+
import org.apache.doris.common.security.authentication.PreExecutionAuthenticatorCache;
2224

2325
import org.apache.iceberg.Table;
2426
import org.apache.iceberg.util.SerializationUtil;
@@ -29,6 +31,7 @@
2931
import java.util.HashMap;
3032
import java.util.Map;
3133
import java.util.TimeZone;
34+
import java.util.stream.Collectors;
3235

3336
/**
3437
* Abstract class for Iceberg metadata scanner.
@@ -51,7 +54,7 @@ public IcebergMetadataJniScanner(int batchSize, Map<String, String> params) {
5154
this.requiredFields = params.get("required_fields").split(",");
5255
this.serializedTable = params.get("serialized_table");
5356
this.timezone = params.getOrDefault("time_zone", TimeZone.getDefault().getID());
54-
HashMap<String, String> hadoopOptionParams = params.entrySet().stream()
57+
Map<String, String> hadoopOptionParams = params.entrySet().stream()
5558
.filter(kv -> kv.getKey().startsWith(HADOOP_OPTION_PREFIX))
5659
.collect(Collectors
5760
.toMap(kv1 -> kv1.getKey().substring(HADOOP_OPTION_PREFIX.length()), kv1 -> kv1.getValue()));

fe/be-java-extensions/iceberg-metadata-scanner/src/main/java/org/apache/doris/iceberg/IcebergSnapshotsJniScanner.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -112,7 +112,7 @@ private Object getValue(String columnName, StructLike dataRow) {
112112
case "manifest_list":
113113
return dataRow.get(columnNameToPosition.get(columnName), String.class);
114114
case "summary":
115-
return dataRow.get(columnNameToPosition.get(columnName), String.class);
115+
return dataRow.get(columnNameToPosition.get(columnName), Map.class);
116116
default:
117117
throw new IllegalArgumentException("Unrecognized column name " + columnName);
118118
}

fe/fe-core/src/main/java/org/apache/doris/tablefunction/IcebergTableValuedFunction.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@
4242
import org.apache.iceberg.Table;
4343
import org.apache.iceberg.util.SerializationUtil;
4444

45-
import java.util.HashMap;
4645
import java.util.List;
4746
import java.util.Map;
4847

0 commit comments

Comments
 (0)