diff --git a/client/trino-client/src/main/java/io/trino/client/JsonResultRows.java b/client/trino-client/src/main/java/io/trino/client/JsonResultRows.java index 5e0834c8ae66..d61bfe19f86f 100644 --- a/client/trino-client/src/main/java/io/trino/client/JsonResultRows.java +++ b/client/trino-client/src/main/java/io/trino/client/JsonResultRows.java @@ -26,7 +26,6 @@ import java.io.InputStream; import java.io.UncheckedIOException; import java.util.ArrayList; -import java.util.Iterator; import java.util.List; import static com.fasterxml.jackson.core.JsonParser.Feature.AUTO_CLOSE_SOURCE; @@ -138,32 +137,24 @@ private void close() public static ResultRows forJsonParser(JsonParser parser, List columns) { - return new ResultRows() { - @Override - public Iterator> iterator() - { - try { - return new RowWiseIterator(parser, createTypeDecoders(columns)); - } - catch (IOException e) { - throw new UncheckedIOException(e); - } + return () -> { + try { + return new RowWiseIterator(parser, createTypeDecoders(columns)); + } + catch (IOException e) { + throw new UncheckedIOException(e); } }; } public static ResultRows forInputStream(InputStream stream, TypeDecoder[] decoders) { - return new ResultRows() { - @Override - public Iterator> iterator() - { - try { - return new RowWiseIterator(stream, decoders); - } - catch (IOException e) { - throw new UncheckedIOException(e); - } + return () -> { + try { + return new RowWiseIterator(stream, decoders); + } + catch (IOException e) { + throw new UncheckedIOException(e); } }; }