From b3a1f18d94925bbf3e04304f24a38174f5fd6bce Mon Sep 17 00:00:00 2001 From: lincoln-lil Date: Mon, 12 Aug 2024 18:59:18 +0800 Subject: [PATCH] fix style --- .../table/runtime/operators/rank/FastTop1Function.java | 3 --- .../operators/rank/TopNBufferCacheRemovalListener.java | 7 ++++--- .../runtime/operators/rank/UpdatableTopNFunction.java | 3 --- 3 files changed, 4 insertions(+), 9 deletions(-) diff --git a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/FastTop1Function.java b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/FastTop1Function.java index e2dad0684ee6c..7af4b8cab28f9 100644 --- a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/FastTop1Function.java +++ b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/FastTop1Function.java @@ -35,9 +35,6 @@ import org.apache.flink.shaded.guava32.com.google.common.cache.Cache; import org.apache.flink.shaded.guava32.com.google.common.cache.CacheBuilder; -import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalCause; -import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalListener; -import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalNotification; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBufferCacheRemovalListener.java b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBufferCacheRemovalListener.java index 2640951b0c214..33eedbe3a125c 100644 --- a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBufferCacheRemovalListener.java +++ b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/TopNBufferCacheRemovalListener.java @@ -18,13 +18,14 @@ package org.apache.flink.table.runtime.operators.rank; -import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalCause; -import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalListener; -import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalNotification; import org.apache.flink.streaming.api.operators.KeyContext; import org.apache.flink.table.data.RowData; import org.apache.flink.util.function.ThrowingConsumer; +import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalCause; +import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalListener; +import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalNotification; + /** * A common cache removal listener for rank node. * diff --git a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java index 1246892f56fe3..8f3820a0c1792 100644 --- a/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java +++ b/flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/runtime/operators/rank/UpdatableTopNFunction.java @@ -41,9 +41,6 @@ import org.apache.flink.shaded.guava32.com.google.common.cache.Cache; import org.apache.flink.shaded.guava32.com.google.common.cache.CacheBuilder; -import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalCause; -import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalListener; -import org.apache.flink.shaded.guava32.com.google.common.cache.RemovalNotification; import org.slf4j.Logger; import org.slf4j.LoggerFactory;