diff --git a/presto-orc/src/main/java/io/prestosql/orc/reader/ListStreamReader.java b/presto-orc/src/main/java/io/prestosql/orc/reader/ListStreamReader.java index 1eee6a0d8a790..978a5621d4fdb 100644 --- a/presto-orc/src/main/java/io/prestosql/orc/reader/ListStreamReader.java +++ b/presto-orc/src/main/java/io/prestosql/orc/reader/ListStreamReader.java @@ -207,7 +207,7 @@ public String toString() public void close() { try (Closer closer = Closer.create()) { - closer.register(() -> elementStreamReader.close()); + closer.register(elementStreamReader::close); } catch (IOException e) { throw new UncheckedIOException(e); diff --git a/presto-orc/src/main/java/io/prestosql/orc/reader/LongStreamReader.java b/presto-orc/src/main/java/io/prestosql/orc/reader/LongStreamReader.java index 73a673de69dda..9ee2b68746003 100644 --- a/presto-orc/src/main/java/io/prestosql/orc/reader/LongStreamReader.java +++ b/presto-orc/src/main/java/io/prestosql/orc/reader/LongStreamReader.java @@ -101,8 +101,8 @@ public String toString() public void close() { try (Closer closer = Closer.create()) { - closer.register(() -> directReader.close()); - closer.register(() -> dictionaryReader.close()); + closer.register(directReader::close); + closer.register(dictionaryReader::close); } catch (IOException e) { throw new UncheckedIOException(e); diff --git a/presto-orc/src/main/java/io/prestosql/orc/reader/SliceStreamReader.java b/presto-orc/src/main/java/io/prestosql/orc/reader/SliceStreamReader.java index 1725b9edc22f3..96c4b15e967b5 100644 --- a/presto-orc/src/main/java/io/prestosql/orc/reader/SliceStreamReader.java +++ b/presto-orc/src/main/java/io/prestosql/orc/reader/SliceStreamReader.java @@ -137,8 +137,8 @@ public static int computeTruncatedLength(Slice slice, int offset, int length, in public void close() { try (Closer closer = Closer.create()) { - closer.register(() -> directReader.close()); - closer.register(() -> dictionaryReader.close()); + closer.register(directReader::close); + closer.register(dictionaryReader::close); } catch (IOException e) { throw new UncheckedIOException(e); diff --git a/presto-orc/src/main/java/io/prestosql/orc/reader/StructStreamReader.java b/presto-orc/src/main/java/io/prestosql/orc/reader/StructStreamReader.java index a142a41dd4e3b..cfd5d9d035eb0 100644 --- a/presto-orc/src/main/java/io/prestosql/orc/reader/StructStreamReader.java +++ b/presto-orc/src/main/java/io/prestosql/orc/reader/StructStreamReader.java @@ -225,7 +225,7 @@ public void close() { try (Closer closer = Closer.create()) { for (StreamReader structField : structFields.values()) { - closer.register(() -> structField.close()); + closer.register(structField::close); } } catch (IOException e) {