优化pom文件

1 files changed, 15 insertions, 15 deletions

diff --git a/src/test/java/com/zdjizhi/FileChunkCombinerTests.java b/src/test/java/com/zdjizhi/FileChunkCombinerTests.java
index d3d30c4..959db5c 100644
--- a/src/test/java/com/zdjizhi/FileChunkCombinerTests.java
+++ b/src/test/java/com/zdjizhi/FileChunkCombinerTests.java
@@ -630,20 +630,6 @@ public class FileChunkCombinerTests {
         }
     }
 
-    private static class ProcessWindowFunctionMock extends ProcessWindowFunction<FileChunk, FileChunk, String, TimeWindow> implements OutputTypeConfigurable<FileChunk> {
-        private static final long serialVersionUID = 1L;
-
-        private ProcessWindowFunctionMock() {
-        }
-
-        @Override
-        public void process(String s, Context context, Iterable<FileChunk> elements, Collector<FileChunk> out) throws Exception {
-        }
-
-        public void setOutputType(TypeInformation<FileChunk> outTypeInfo, ExecutionConfig executionConfig) {
-        }
-    }
-
     private StreamExecutionEnvironment createPipeline(int parallelism, SourceFunction<byte[]> source, long windowTime, long windowIdleTime) {
         StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
         env.setParallelism(parallelism);
@@ -656,7 +642,7 @@ public class FileChunkCombinerTests {
         Trigger<Object, TimeWindow> trigger = MultipleTrigger.of(triggers);
         env.addSource(source)
                 .map(new ParseMessagePackMapFunction())
-                .filter(new FileChunkFilterFunction("","test"))
+                .filter(new FileChunkFilterFunction("", "test"))
                 .assignTimestampsAndWatermarks(watermarkStrategy)
                 .keyBy(new FileChunkKeySelector(), BasicTypeInfo.STRING_TYPE_INFO)
                 .window(TumblingEventTimeWindows.of(Time.seconds(windowTime)))
@@ -715,6 +701,20 @@ public class FileChunkCombinerTests {
 //        windowFunction.close();
 //        Mockito.verify(mock).close();
 //    }
+//
+//    private static class ProcessWindowFunctionMock extends ProcessWindowFunction<FileChunk, FileChunk, String, TimeWindow> implements OutputTypeConfigurable<FileChunk> {
+//        private static final long serialVersionUID = 1L;
+//
+//        private ProcessWindowFunctionMock() {
+//        }
+//
+//        @Override
+//        public void process(String s, Context context, Iterable<FileChunk> elements, Collector<FileChunk> out) throws Exception {
+//        }
+//
+//        public void setOutputType(TypeInformation<FileChunk> outTypeInfo, ExecutionConfig executionConfig) {
+//        }
+//    }
 
 //    @Test
 //    public void testCombineChunkProcessWindowFunction() throws Exception {