You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/05/07 12:28:47 UTC
[iotdb] 02/03: spotless
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch FillOperator
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit d2fe7abbea01931902fb393b1f497904f025da59
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Fri May 6 16:27:17 2022 +0800
spotless
---
.../execution/operator/process/fill/previous/BinaryPreviousFill.java | 3 ++-
.../execution/operator/process/fill/previous/BooleanPreviousFill.java | 3 ++-
.../execution/operator/process/fill/previous/DoublePreviousFill.java | 3 ++-
.../execution/operator/process/fill/previous/FloatPreviousFill.java | 3 ++-
.../mpp/execution/operator/process/fill/previous/IntPreviousFill.java | 3 ++-
.../mpp/execution/operator/process/fill/previous/LongPreviousFill.java | 3 ++-
6 files changed, 12 insertions(+), 6 deletions(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BinaryPreviousFill.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BinaryPreviousFill.java
index 855d90585e..897cd21d7a 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BinaryPreviousFill.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BinaryPreviousFill.java
@@ -62,7 +62,8 @@ public class BinaryPreviousFill implements IFill {
} else {
// update the value using last non-null value
value = column.getBinary(size - 1);
- return new RunLengthEncodedColumn(new BinaryColumn(1, Optional.empty(), new Binary[] {value}), size);
+ return new RunLengthEncodedColumn(
+ new BinaryColumn(1, Optional.empty(), new Binary[] {value}), size);
}
} else {
Binary[] array = new Binary[size];
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BooleanPreviousFill.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BooleanPreviousFill.java
index 766b6296af..a1f3c5a9e7 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BooleanPreviousFill.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BooleanPreviousFill.java
@@ -61,7 +61,8 @@ public class BooleanPreviousFill implements IFill {
} else {
// update the value using last non-null value
value = column.getBoolean(size - 1);
- return new RunLengthEncodedColumn(new BooleanColumn(1, Optional.empty(), new boolean[] {value}), size);
+ return new RunLengthEncodedColumn(
+ new BooleanColumn(1, Optional.empty(), new boolean[] {value}), size);
}
} else {
boolean[] array = new boolean[size];
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/DoublePreviousFill.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/DoublePreviousFill.java
index a5bc6aeaf7..e113ffffd5 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/DoublePreviousFill.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/DoublePreviousFill.java
@@ -61,7 +61,8 @@ public class DoublePreviousFill implements IFill {
} else {
// update the value using last non-null value
value = column.getDouble(size - 1);
- return new RunLengthEncodedColumn(new DoubleColumn(1, Optional.empty(), new double[] {value}), size);
+ return new RunLengthEncodedColumn(
+ new DoubleColumn(1, Optional.empty(), new double[] {value}), size);
}
} else {
double[] array = new double[size];
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/FloatPreviousFill.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/FloatPreviousFill.java
index e80a85b8ad..d482430a6d 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/FloatPreviousFill.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/FloatPreviousFill.java
@@ -61,7 +61,8 @@ public class FloatPreviousFill implements IFill {
} else {
// update the value using last non-null value
value = column.getFloat(size - 1);
- return new RunLengthEncodedColumn(new FloatColumn(1, Optional.empty(), new float[] {value}), size);
+ return new RunLengthEncodedColumn(
+ new FloatColumn(1, Optional.empty(), new float[] {value}), size);
}
} else {
float[] array = new float[size];
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/IntPreviousFill.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/IntPreviousFill.java
index 0b4686c9a2..6e95f028b1 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/IntPreviousFill.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/IntPreviousFill.java
@@ -61,7 +61,8 @@ public class IntPreviousFill implements IFill {
} else {
// update the value using last non-null value
value = column.getInt(size - 1);
- return new RunLengthEncodedColumn(new IntColumn(1, Optional.empty(), new int[] {value}), size);
+ return new RunLengthEncodedColumn(
+ new IntColumn(1, Optional.empty(), new int[] {value}), size);
}
} else {
int[] array = new int[size];
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/LongPreviousFill.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/LongPreviousFill.java
index ca41850020..116f616aab 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/LongPreviousFill.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/LongPreviousFill.java
@@ -61,7 +61,8 @@ public class LongPreviousFill implements IFill {
} else {
// update the value using last non-null value
value = column.getLong(size - 1);
- return new RunLengthEncodedColumn(new LongColumn(1, Optional.empty(), new long[] {value}), size);
+ return new RunLengthEncodedColumn(
+ new LongColumn(1, Optional.empty(), new long[] {value}), size);
}
} else {
long[] array = new long[size];