[Java] Remove java api sub package from test module (#8853)

streaming/java/streaming-api/src/main/java/io/ray/streaming/message/Record.java

@@ -3,7 +3,6 @@ package io.ray.streaming.message;
 import java.io.Serializable;
 import java.util.Objects;
 
-
 public class Record<T> implements Serializable {
   protected transient String stream;
   protected T value;

streaming/java/streaming-api/src/main/java/io/ray/streaming/operator/OneInputOperator.java

@@ -2,7 +2,6 @@ package io.ray.streaming.operator;
 
 import io.ray.streaming.message.Record;
 
-
 public interface OneInputOperator<T> extends Operator {
 
   void processElement(Record<T> record) throws Exception;

streaming/java/streaming-api/src/main/java/io/ray/streaming/operator/TwoInputOperator.java

@@ -2,7 +2,6 @@ package io.ray.streaming.operator;
 
 import io.ray.streaming.message.Record;
 
-
 public interface TwoInputOperator<T, O> extends Operator {
 
   void processElement(Record<T> record1, Record<O> record2);

streaming/java/streaming-api/src/main/java/io/ray/streaming/operator/impl/MapOperator.java

@@ -5,7 +5,6 @@ import io.ray.streaming.message.Record;
 import io.ray.streaming.operator.OneInputOperator;
 import io.ray.streaming.operator.StreamOperator;
 
-
 public class MapOperator<T, R> extends StreamOperator<MapFunction<T, R>> implements
     OneInputOperator<T> {
 

streaming/java/streaming-api/src/main/java/io/ray/streaming/operator/impl/SinkOperator.java

@@ -5,7 +5,6 @@ import io.ray.streaming.message.Record;
 import io.ray.streaming.operator.OneInputOperator;
 import io.ray.streaming.operator.StreamOperator;
 
-
 public class SinkOperator<T> extends StreamOperator<SinkFunction<T>> implements
     OneInputOperator<T> {
 

streaming/java/streaming-runtime/src/main/java/io/ray/streaming/runtime/core/processor/ProcessBuilder.java

@@ -8,7 +8,6 @@ import io.ray.streaming.operator.impl.SourceOperator;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-
 public class ProcessBuilder {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(ProcessBuilder.class);

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/demo/HybridStreamTest.java

@@ -6,9 +6,7 @@ import io.ray.streaming.api.function.impl.FilterFunction;
 import io.ray.streaming.api.function.impl.MapFunction;
 import io.ray.streaming.api.function.impl.SinkFunction;
 import io.ray.streaming.api.stream.DataStreamSource;
-import io.ray.streaming.runtime.BaseUnitTest;
 import java.io.IOException;
-import java.io.Serializable;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.nio.file.StandardOpenOption;

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/master/resourcemanager/strategy/PipelineFirstStrategyTest.java

@@ -5,10 +5,10 @@ import io.ray.streaming.jobgraph.JobGraph;
 import io.ray.streaming.runtime.BaseUnitTest;
 import io.ray.streaming.runtime.config.StreamingConfig;
 import io.ray.streaming.runtime.config.types.ResourceAssignStrategyType;
+import io.ray.streaming.runtime.core.graph.ExecutionGraphTest;
 import io.ray.streaming.runtime.core.graph.executiongraph.ExecutionGraph;
 import io.ray.streaming.runtime.core.resource.Container;
 import io.ray.streaming.runtime.core.resource.ResourceType;
-import io.ray.streaming.runtime.core.graph.ExecutionGraphTest;
 import io.ray.streaming.runtime.master.JobRuntimeContext;
 import io.ray.streaming.runtime.master.graphmanager.GraphManager;
 import io.ray.streaming.runtime.master.graphmanager.GraphManagerImpl;

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/python/PythonGatewayTest.java

@@ -1,5 +1,7 @@
 package io.ray.streaming.runtime.python;
 
+import static org.testng.Assert.assertEquals;
+
 import io.ray.streaming.api.stream.StreamSink;
 import io.ray.streaming.jobgraph.JobGraph;
 import io.ray.streaming.jobgraph.JobGraphBuilder;
@@ -9,7 +11,6 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import org.testng.annotations.Test;
-import static org.testng.Assert.assertEquals;
 
 public class PythonGatewayTest {
 

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/serialization/CrossLangSerializerTest.java

@@ -3,9 +3,9 @@ package io.ray.streaming.runtime.serialization;
 import static org.testng.Assert.assertEquals;
 import static org.testng.Assert.assertTrue;
 
-import org.apache.commons.lang3.builder.EqualsBuilder;
 import io.ray.streaming.message.KeyRecord;
 import io.ray.streaming.message.Record;
+import org.apache.commons.lang3.builder.EqualsBuilder;
 import org.testng.annotations.Test;
 
 public class CrossLangSerializerTest {

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/streamingqueue/StreamingQueueTest.java

@@ -1,8 +1,8 @@
 package io.ray.streaming.runtime.streamingqueue;
 
 import com.google.common.collect.ImmutableMap;
-import io.ray.api.Ray;
 import io.ray.api.ActorHandle;
+import io.ray.api.Ray;
 import io.ray.api.options.ActorCreationOptions;
 import io.ray.api.options.ActorCreationOptions.Builder;
 import io.ray.runtime.config.RayConfig;

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/transfer/ChannelIDTest.java

@@ -1,9 +1,10 @@
 package io.ray.streaming.runtime.transfer;
 
+import static org.testng.Assert.assertEquals;
+
 import io.ray.streaming.runtime.BaseUnitTest;
 import io.ray.streaming.runtime.util.EnvUtil;
 import org.testng.annotations.Test;
-import static org.testng.Assert.assertEquals;
 
 public class ChannelIDTest extends BaseUnitTest {
 

streaming/java/streaming-runtime/src/test/java/io/ray/streaming/runtime/util/ReflectionUtilsTest.java

@@ -1,9 +1,10 @@
 package io.ray.streaming.runtime.util;
 
+import static org.testng.Assert.assertEquals;
+
 import java.io.Serializable;
 import java.util.Collections;
 import org.testng.annotations.Test;
-import static org.testng.Assert.assertEquals;
 
 public class ReflectionUtilsTest {
 

streaming/java/streaming-state/src/main/java/io/ray/streaming/state/strategy/StateStoreManagerProxy.java

@@ -25,7 +25,6 @@ import io.ray.streaming.state.keystate.desc.AbstractStateDescriptor;
 import io.ray.streaming.state.store.KeyValueStore;
 import java.util.Map;
 
-
 /**
  * This class support ITransactionState.
  * <p>