Skip to content

Commit f90b33e

Browse files
[hotfix] Fix compilation error: implement missing getMap method in IcebergArrayAsFlussArray (#2306)
1 parent b2fa4a9 commit f90b33e

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

fluss-lake/fluss-lake-iceberg/src/main/java/org/apache/fluss/lake/iceberg/source/IcebergArrayAsFlussArray.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121
import org.apache.fluss.row.BinaryString;
2222
import org.apache.fluss.row.Decimal;
2323
import org.apache.fluss.row.InternalArray;
24+
import org.apache.fluss.row.InternalMap;
2425
import org.apache.fluss.row.InternalRow;
2526
import org.apache.fluss.row.TimestampLtz;
2627
import org.apache.fluss.row.TimestampNtz;
@@ -136,6 +137,11 @@ public InternalArray getArray(int pos) {
136137
return nestedList == null ? null : new IcebergArrayAsFlussArray(nestedList);
137138
}
138139

140+
@Override
141+
public InternalMap getMap(int pos) {
142+
throw new UnsupportedOperationException();
143+
}
144+
139145
@Override
140146
public InternalRow getRow(int pos, int numFields) {
141147
throw new UnsupportedOperationException();

0 commit comments

Comments
 (0)