diff --git a/core/trino-main/src/main/java/io/trino/operator/aggregation/LongDoubleState.java b/core/trino-main/src/main/java/io/trino/operator/aggregation/LongDoubleState.java index 6bf808a096be..2c51284d0cca 100644 --- a/core/trino-main/src/main/java/io/trino/operator/aggregation/LongDoubleState.java +++ b/core/trino-main/src/main/java/io/trino/operator/aggregation/LongDoubleState.java @@ -13,7 +13,6 @@ */ package io.trino.operator.aggregation; -import io.trino.operator.aggregation.state.InitialBooleanValue; import io.trino.spi.function.AccumulatorState; public interface LongDoubleState @@ -23,17 +22,7 @@ public interface LongDoubleState void setFirst(long first); - @InitialBooleanValue(true) - boolean isFirstNull(); - - void setFirstNull(boolean firstNull); - double getSecond(); void setSecond(double second); - - @InitialBooleanValue(true) - boolean isSecondNull(); - - void setSecondNull(boolean secondNull); } diff --git a/core/trino-main/src/main/java/io/trino/operator/aggregation/LongLongState.java b/core/trino-main/src/main/java/io/trino/operator/aggregation/LongLongState.java index a239a78dd607..ce7e4ffc9777 100644 --- a/core/trino-main/src/main/java/io/trino/operator/aggregation/LongLongState.java +++ b/core/trino-main/src/main/java/io/trino/operator/aggregation/LongLongState.java @@ -13,7 +13,6 @@ */ package io.trino.operator.aggregation; -import io.trino.operator.aggregation.state.InitialBooleanValue; import io.trino.spi.function.AccumulatorState; public interface LongLongState @@ -23,17 +22,7 @@ public interface LongLongState void setFirst(long first); - @InitialBooleanValue(true) - boolean isFirstNull(); - - void setFirstNull(boolean firstNull); - long getSecond(); void setSecond(long second); - - @InitialBooleanValue(true) - boolean isSecondNull(); - - void setSecondNull(boolean secondNull); } diff --git a/testing/trino-tests/src/test/java/io/trino/execution/TestEventListenerWithSplits.java b/testing/trino-tests/src/test/java/io/trino/execution/TestEventListenerWithSplits.java index 1d1170e7581f..902464d5dc29 100644 --- a/testing/trino-tests/src/test/java/io/trino/execution/TestEventListenerWithSplits.java +++ b/testing/trino-tests/src/test/java/io/trino/execution/TestEventListenerWithSplits.java @@ -164,7 +164,7 @@ public void testSplitsForNormalQuery() assertEquals(statistics.getPhysicalInputRows(), expectedCompletedPositions); assertEquals(statistics.getProcessedInputBytes(), 0); assertEquals(statistics.getProcessedInputRows(), expectedCompletedPositions); - assertEquals(statistics.getInternalNetworkBytes(), 381); + assertEquals(statistics.getInternalNetworkBytes(), 261); assertEquals(statistics.getInternalNetworkRows(), 3); assertEquals(statistics.getTotalBytes(), 0); assertEquals(statistics.getOutputBytes(), 9);