spotless

apache · Dec 21, 2024 · b7d8987 · b7d8987
1 parent 62427af
commit b7d8987
Show file tree

Hide file tree

Showing 12 changed files with 2 additions and 37 deletions.
diff --git a/...java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java b/...java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java
@@ -22,16 +22,7 @@
 //import org.apache.kafka.streams.errors.StreamsException;
 //import org.apache.kafka.streams.processor.Cancellable;
 import org.apache.kafka.streams.processor.ProcessorContext;
-//import org.apache.kafka.streams.processor.PunctuationType;
-//import org.apache.kafka.streams.processor.Punctuator;
-//import org.apache.kafka.streams.processor.StateRestoreCallback;
-//import org.apache.kafka.streams.processor.StateStore;
-////import org.apache.kafka.streams.processor.TaskId;
-//import org.apache.kafka.streams.processor.To;
-//
-//import java.io.File;
-//import java.time.Duration;
-//import java.util.Map;
+
 import java.util.Objects;
 
 /**

diff --git a/...rc/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java b/...rc/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java
@@ -24,7 +24,6 @@
 import org.apache.kafka.streams.processor.Punctuator;
 import org.apache.kafka.streams.processor.StateStore;
 import org.apache.kafka.streams.processor.TaskId;
-//import org.apache.kafka.streams.processor.To;
 import org.apache.kafka.streams.processor.api.FixedKeyRecord;
 import org.apache.kafka.streams.processor.api.Record;
 import org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl;

diff --git a/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java b/streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
@@ -28,7 +28,6 @@
 import org.apache.kafka.streams.processor.Punctuator;
 import org.apache.kafka.streams.processor.StateStore;
 import org.apache.kafka.streams.processor.TaskId;
-//import org.apache.kafka.streams.processor.To;
 import org.apache.kafka.streams.processor.api.FixedKeyRecord;
 import org.apache.kafka.streams.processor.api.Record;
 import org.apache.kafka.streams.processor.internals.Task.TaskType;

diff --git a/.../test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.java b/.../test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.java
@@ -31,7 +31,6 @@
 import org.apache.kafka.streams.processor.Punctuator;
 import org.apache.kafka.streams.processor.StateStore;
 import org.apache.kafka.streams.processor.TaskId;
-//import org.apache.kafka.streams.processor.To;
 import org.apache.kafka.streams.processor.api.FixedKeyRecord;
 import org.apache.kafka.streams.processor.api.Record;
 import org.apache.kafka.streams.query.Position;
@@ -48,10 +47,7 @@
 
 import static org.apache.kafka.test.StreamsTestUtils.getStreamsConfig;
 import static org.hamcrest.CoreMatchers.equalTo;
-//import static org.hamcrest.CoreMatchers.nullValue;
 import static org.hamcrest.MatcherAssert.assertThat;
-//import static org.hamcrest.Matchers.emptyIterable;
-//import static org.hamcrest.Matchers.is;
 import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.fail;
 

diff --git a/.../org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContextTest.java b/.../org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContextTest.java
@@ -18,12 +18,9 @@
 
 //import org.apache.kafka.streams.errors.StreamsException;
 import org.apache.kafka.streams.processor.ProcessorContext;
-//import org.apache.kafka.streams.processor.To;
 
 import org.junit.jupiter.api.BeforeEach;
-//import org.junit.jupiter.api.Test;
 
-//import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.mockito.Mockito.mock;
 
 public class ForwardingDisabledProcessorContextTest {

diff --git a/...est/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImplTest.java b/...est/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImplTest.java
@@ -20,7 +20,6 @@
 import org.apache.kafka.common.utils.Time;
 import org.apache.kafka.streams.StreamsConfig;
 import org.apache.kafka.streams.processor.StateStore;
-//import org.apache.kafka.streams.processor.To;
 import org.apache.kafka.streams.state.KeyValueStore;
 import org.apache.kafka.streams.state.SessionStore;
 import org.apache.kafka.streams.state.TimestampedKeyValueStore;
@@ -40,8 +39,6 @@
 import static org.junit.jupiter.api.Assertions.assertNull;
 import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.junit.jupiter.api.Assertions.fail;
-//import static org.mockito.ArgumentMatchers.any;
-//import static org.mockito.Mockito.doNothing;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.when;
 

diff --git a/.../src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java b/.../src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextImplTest.java
@@ -27,7 +27,6 @@
 import org.apache.kafka.streams.processor.PunctuationType;
 import org.apache.kafka.streams.processor.StateStore;
 import org.apache.kafka.streams.processor.TaskId;
-//import org.apache.kafka.streams.processor.To;
 import org.apache.kafka.streams.processor.api.Processor;
 import org.apache.kafka.streams.processor.api.ProcessorContext;
 import org.apache.kafka.streams.processor.api.Record;

diff --git a/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java b/streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorContextTest.java
@@ -25,13 +25,7 @@
 import org.apache.kafka.streams.state.internals.ThreadCache;
 
 import org.junit.jupiter.api.BeforeEach;
-//import org.junit.jupiter.api.Test;
-//
-//import java.time.Duration;
-//
-//import static org.hamcrest.MatcherAssert.assertThat;
-//import static org.hamcrest.Matchers.equalTo;
-//import static org.junit.jupiter.api.Assertions.fail;
+
 import static org.mockito.Mockito.doReturn;
 import static org.mockito.Mockito.mock;
 

diff --git a/streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java b/streams/src/test/java/org/apache/kafka/test/InternalMockProcessorContext.java
@@ -34,7 +34,6 @@
 import org.apache.kafka.streams.processor.StateRestoreCallback;
 import org.apache.kafka.streams.processor.StateStore;
 import org.apache.kafka.streams.processor.TaskId;
-//import org.apache.kafka.streams.processor.To;
 import org.apache.kafka.streams.processor.api.FixedKeyRecord;
 import org.apache.kafka.streams.processor.api.Record;
 import org.apache.kafka.streams.processor.internals.AbstractProcessorContext;

diff --git a/streams/src/test/java/org/apache/kafka/test/MockInternalProcessorContext.java b/streams/src/test/java/org/apache/kafka/test/MockInternalProcessorContext.java
@@ -23,7 +23,6 @@
 import org.apache.kafka.streams.processor.StateRestoreCallback;
 import org.apache.kafka.streams.processor.StateStore;
 import org.apache.kafka.streams.processor.TaskId;
-//import org.apache.kafka.streams.processor.To;
 import org.apache.kafka.streams.processor.api.FixedKeyRecord;
 import org.apache.kafka.streams.processor.api.MockProcessorContext;
 import org.apache.kafka.streams.processor.api.Record;

diff --git a/streams/src/test/java/org/apache/kafka/test/NoOpProcessorContext.java b/streams/src/test/java/org/apache/kafka/test/NoOpProcessorContext.java
@@ -26,7 +26,6 @@
 import org.apache.kafka.streams.processor.StateRestoreCallback;
 import org.apache.kafka.streams.processor.StateStore;
 import org.apache.kafka.streams.processor.TaskId;
-//import org.apache.kafka.streams.processor.To;
 import org.apache.kafka.streams.processor.api.FixedKeyRecord;
 import org.apache.kafka.streams.processor.api.Record;
 import org.apache.kafka.streams.processor.internals.AbstractProcessorContext;

diff --git a/...ams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java b/...ams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
@@ -20,20 +20,16 @@
 import org.apache.kafka.common.metrics.MetricConfig;
 import org.apache.kafka.common.metrics.Metrics;
 import org.apache.kafka.common.metrics.Sensor;
-//import org.apache.kafka.common.serialization.Serde;
 import org.apache.kafka.common.utils.Time;
 import org.apache.kafka.streams.KeyValue;
 import org.apache.kafka.streams.StreamsConfig;
-//import org.apache.kafka.streams.StreamsMetrics;
-//import org.apache.kafka.streams.internals.ApiUtils;
 import org.apache.kafka.streams.processor.internals.ClientUtils;
 import org.apache.kafka.streams.processor.internals.RecordCollector;
 import org.apache.kafka.streams.processor.internals.metrics.StreamsMetricsImpl;
 import org.apache.kafka.streams.processor.internals.metrics.TaskMetrics;
 import org.apache.kafka.streams.state.internals.InMemoryKeyValueStore;
 
 import java.io.File;
-//import java.time.Duration;
 import java.util.HashMap;
 import java.util.LinkedList;
 import java.util.List;