[hotfix] Fix checkstyle violations

ViggoC · Sep 14, 2020 · 2a1da16 · 2a1da16
1 parent 6f38c9b
commit 2a1da16
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/...dge/src/main/java/org/apache/flink/table/factories/datagen/types/DataGeneratorMapper.java b/...dge/src/main/java/org/apache/flink/table/factories/datagen/types/DataGeneratorMapper.java
@@ -56,5 +56,8 @@ public B next() {
 		return mapper.apply(generator.next());
 	}
 
+	/**
+	 * A simple serializable function.
+	 */
 	public interface SerializableFunction<A, B> extends Function<A, B>, Serializable {}
 }
diff --git a/...ava/org/apache/flink/table/planner/runtime/stream/table/DataGeneratorConnectorITCase.java b/...ava/org/apache/flink/table/planner/runtime/stream/table/DataGeneratorConnectorITCase.java
@@ -18,16 +18,19 @@
 
 package org.apache.flink.table.planner.runtime.stream.table;
 
-import org.apache.flink.table.data.RowData;
 import org.apache.flink.table.planner.runtime.utils.BatchTestBase;
 import org.apache.flink.types.Row;
 import org.apache.flink.util.CloseableIterator;
+
 import org.junit.Assert;
 import org.junit.Test;
 
 import java.util.ArrayList;
 import java.util.List;
 
+/**
+ * IT case for data generator source.
+ */
 public class DataGeneratorConnectorITCase extends BatchTestBase {
 
 	private static final String TABLE = "CREATE TABLE datagen_t (\n" +
@@ -67,6 +70,6 @@ public void testTypes() throws Exception {
 			}
 		}
 
-		Assert.assertEquals("Unexpected number of results",10, results.size());
+		Assert.assertEquals("Unexpected number of results", 10, results.size());
 	}
 }