Skip to content

Commit c087dc1

Browse files
committed
address comment
1 parent 85fe33a commit c087dc1

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/utils/DeltaJoinUtilTest.java

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import org.apache.calcite.util.ImmutableBitSet;
3131
import org.junit.jupiter.api.Test;
3232

33-
import java.util.Arrays;
3433
import java.util.List;
3534
import java.util.Set;
3635
import java.util.stream.Collectors;
@@ -40,10 +39,10 @@
4039
import static org.assertj.core.api.Assertions.assertThat;
4140

4241
/** Test for {@link DeltaJoinUtil}. */
43-
public class DeltaJoinUtilTest {
42+
class DeltaJoinUtilTest {
4443

4544
@Test
46-
public void testIsFilterOnOneSetOfUpsertKeys() {
45+
void testIsFilterOnOneSetOfUpsertKeys() {
4746
FlinkTypeFactory typeFactory =
4847
new FlinkTypeFactory(
4948
Thread.currentThread().getContextClassLoader(), FlinkTypeSystem.INSTANCE);
@@ -88,6 +87,6 @@ public void testIsFilterOnOneSetOfUpsertKeys() {
8887
}
8988

9089
private Set<ImmutableBitSet> buildUpsertKeys(ImmutableBitSet... upsertKeys) {
91-
return Arrays.stream(upsertKeys).collect(Collectors.toSet());
90+
return Set.of(upsertKeys);
9291
}
9392
}

0 commit comments

Comments
 (0)