Do not use stream to create TypeDecoders

trinodb · Nov 1, 2024 · 59c3bef · 59c3bef
1 parent 9c970f0
commit 59c3bef
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/client/trino-client/src/main/java/io/trino/client/JsonDecodingUtils.java b/client/trino-client/src/main/java/io/trino/client/JsonDecodingUtils.java
@@ -76,9 +76,11 @@ private JsonDecodingUtils() {}
     public static TypeDecoder[] createTypeDecoders(List<Column> columns)
     {
         verify(!columns.isEmpty(), "Columns must not be empty");
-        return columns.stream()
-                .map(column -> createTypeDecoder(column.getTypeSignature()))
-                .toArray(TypeDecoder[]::new);
+        TypeDecoder[] decoders = new TypeDecoder[columns.size()];
+        for (int i = 0; i < columns.size(); i++) {
+            decoders[i] = createTypeDecoder(columns.get(i).getTypeSignature());
+        }
+        return decoders;
     }
 
     public interface TypeDecoder