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 2023/04/11 11:22:39 UTC
[iotdb] branch FIDig updated: add log in offset operator
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch FIDig
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/FIDig by this push:
new 7e528f0dd0 add log in offset operator
7e528f0dd0 is described below
commit 7e528f0dd036243216cc93d0d36a070ed60df589
Author: JackieTien97 <ja...@gmail.com>
AuthorDate: Tue Apr 11 19:22:30 2023 +0800
add log in offset operator
---
.../iotdb/db/mpp/execution/operator/process/OffsetOperator.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java
index 37127e82aa..debd350d10 100644
--- a/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java
+++ b/server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/OffsetOperator.java
@@ -23,12 +23,16 @@ import org.apache.iotdb.db.mpp.execution.operator.OperatorContext;
import org.apache.iotdb.tsfile.read.common.block.TsBlock;
import com.google.common.util.concurrent.ListenableFuture;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
import static com.google.common.base.Preconditions.checkArgument;
import static java.util.Objects.requireNonNull;
public class OffsetOperator implements ProcessOperator {
+ private static final Logger LOGGER = LoggerFactory.getLogger(OffsetOperator.class);
+
private final OperatorContext operatorContext;
private long remainingOffset;
private final Operator child;
@@ -59,6 +63,7 @@ public class OffsetOperator implements ProcessOperator {
if (remainingOffset > 0) {
int offset = Math.min((int) remainingOffset, block.getPositionCount());
remainingOffset -= offset;
+ LOGGER.info("current remaining offset: {}", remainingOffset);
return block.getRegion(offset, block.getPositionCount() - offset);
} else {
return block;