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

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


The following commit(s) were added to refs/heads/master by this push:
     new d36070c  -- Resolving Spelling mistake
d36070c is described below

commit d36070cc544095cc5a1850ba3b35da160c79c30c
Author: sulthan309 <sul@3091994>
AuthorDate: Mon May 4 15:02:23 2020 +0530

    -- Resolving Spelling mistake
---
 .../java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java    | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

diff --git 
a/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java 
b/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java
index a151ff1..4808af2 100644
--- a/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java
+++ b/hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile/TSFInputFormat.java
@@ -68,7 +68,7 @@ TSFInputFormat extends FileInputFormat<NullWritable, 
MapWritable> {
    */
   public static final String READ_MEASUREMENTID = "tsfile.read.measurement";
   private static final Logger logger = 
LoggerFactory.getLogger(TSFInputFormat.class);
-  private static final String SPERATOR = ",";
+  private static final String SEPARATOR = ",";
 
   /**
    * Set the deltaObjectIds which want to be read
@@ -83,7 +83,7 @@ TSFInputFormat extends FileInputFormat<NullWritable, 
MapWritable> {
     } else {
       StringBuilder deltaObjectIdsBuilder = new StringBuilder();
       for (String deltaObjectId : value) {
-        deltaObjectIdsBuilder.append(deltaObjectId).append(SPERATOR);
+        deltaObjectIdsBuilder.append(deltaObjectId).append(SEPARATOR);
       }
       String deltaObjectIds = deltaObjectIdsBuilder.toString();
       job.getConfiguration().set(READ_DELTAOBJECTS,
@@ -104,7 +104,7 @@ TSFInputFormat extends FileInputFormat<NullWritable, 
MapWritable> {
       return new LinkedList<>();
     } else {
 
-      return 
Arrays.stream(deviceIds.split(SPERATOR)).collect(Collectors.toList());
+      return 
Arrays.stream(deviceIds.split(SEPARATOR)).collect(Collectors.toList());
     }
   }
 
@@ -121,7 +121,7 @@ TSFInputFormat extends FileInputFormat<NullWritable, 
MapWritable> {
     } else {
       StringBuilder measurementIdsBuilder = new StringBuilder();
       for (String measurementId : value) {
-        measurementIdsBuilder.append(measurementId).append(SPERATOR);
+        measurementIdsBuilder.append(measurementId).append(SEPARATOR);
       }
       String measurementIds = measurementIdsBuilder.toString();
       // Get conf type
@@ -141,7 +141,7 @@ TSFInputFormat extends FileInputFormat<NullWritable, 
MapWritable> {
     if (measurementIds == null || measurementIds.length() < 1) {
       return new LinkedList<>();
     } else {
-      return 
Arrays.stream(measurementIds.split(SPERATOR)).collect(Collectors.toList());
+      return 
Arrays.stream(measurementIds.split(SEPARATOR)).collect(Collectors.toList());
     }
   }
 

Reply via email to