[incubator-iotdb] branch fix_flink_name updated: fix a class name error in flink

[haonan]

This is an automated email from the ASF dual-hosted git repository.

haonan pushed a commit to branch fix_flink_name
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/fix_flink_name by this push:
     new 5603d77  fix a class name error in flink
5603d77 is described below

commit 5603d77177a53c4db3ede5d02de3d4d8088e90ef
Author: HTHou <hhao...@outlook.com>
AuthorDate: Tue May 12 22:17:03 2020 +0800

    fix a class name error in flink
---
 .../src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSink.java      | 2 +-
 .../src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java    | 2 +-
 .../src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSink.java     | 2 +-
 .../src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java   | 2 +-
 .../java/org/apache/iotdb/flink/{TsFlieUtils.java => TsFileUtils.java}  | 2 +-
 5 files changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSink.java 
b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSink.java
index 2394824..f1174c9 100644
--- 
a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSink.java
+++ 
b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSink.java
@@ -106,7 +106,7 @@ public class FlinkTsFileBatchSink {
                        .filter(s -> !s.equals(QueryConstant.RESERVED_TIME))
                        .map(Path::new)
                        .collect(Collectors.toList());
-               String[] result = TsFlieUtils.readTsFile(path, paths);
+               String[] result = TsFileUtils.readTsFile(path, paths);
                for (String row : result) {
                        System.out.println(row);
                }
diff --git 
a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java
 
b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java
index 6f01b75..54d31a4 100644
--- 
a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java
+++ 
b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileBatchSource.java
@@ -41,7 +41,7 @@ public class FlinkTsFileBatchSource {
 
        public static void main(String[] args) throws Exception {
                String path = "test.tsfile";
-               TsFlieUtils.writeTsFile(path);
+               TsFileUtils.writeTsFile(path);
                new File(path).deleteOnExit();
                String[] filedNames = {
                        QueryConstant.RESERVED_TIME,
diff --git 
a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSink.java 
b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSink.java
index cdf1390..0a5759c 100644
--- 
a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSink.java
+++ 
b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSink.java
@@ -107,7 +107,7 @@ public class FlinkTsFileStreamSink {
                        .filter(s -> !s.equals(QueryConstant.RESERVED_TIME))
                        .map(Path::new)
                        .collect(Collectors.toList());
-               String[] result = TsFlieUtils.readTsFile(path, paths);
+               String[] result = TsFileUtils.readTsFile(path, paths);
                for (String row : result) {
                        System.out.println(row);
                }
diff --git 
a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
 
b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
index 83f7de9..d17d3c5 100644
--- 
a/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
+++ 
b/example/flink/src/main/java/org/apache/iotdb/flink/FlinkTsFileStreamSource.java
@@ -44,7 +44,7 @@ public class FlinkTsFileStreamSource {
 
        public static void main(String[] args) throws IOException {
                String path = "test.tsfile";
-               TsFlieUtils.writeTsFile(path);
+               TsFileUtils.writeTsFile(path);
                new File(path).deleteOnExit();
                String[] filedNames = {
                        QueryConstant.RESERVED_TIME,
diff --git 
a/example/flink/src/main/java/org/apache/iotdb/flink/TsFlieUtils.java 
b/example/flink/src/main/java/org/apache/iotdb/flink/TsFileUtils.java
similarity index 99%
rename from example/flink/src/main/java/org/apache/iotdb/flink/TsFlieUtils.java
rename to example/flink/src/main/java/org/apache/iotdb/flink/TsFileUtils.java
index f97b683..476b659 100644
--- a/example/flink/src/main/java/org/apache/iotdb/flink/TsFlieUtils.java
+++ b/example/flink/src/main/java/org/apache/iotdb/flink/TsFileUtils.java
@@ -42,7 +42,7 @@ import java.util.stream.Collectors;
 /**
  * Utils used to prepare source TsFiles for the examples.
  */
-public class TsFlieUtils {
+public class TsFileUtils {
 
        private static final String DEFAULT_TEMPLATE = "template";