Skip to content

Commit 028deef

Browse files
committed
Rename pending aligned chunk consumer
1 parent 5a826e3 commit 028deef

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/parser/scan/TsFileInsertionEventScanParser.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -593,7 +593,7 @@ private void moveToNextChunkReader()
593593
modsInfos.clear();
594594

595595
if (lastMarker == MetaMarker.SEPARATOR) {
596-
if (!recordPendingAlignedChunk(lastMarker)) {
596+
if (!useNextPendingAlignedChunk(lastMarker)) {
597597
clearCachedAlignedChunkData();
598598
chunkReader = null;
599599
}
@@ -698,7 +698,7 @@ private void moveToNextChunkReader()
698698
case MetaMarker.CHUNK_GROUP_HEADER:
699699
{
700700
// Return before "currentDevice" changes.
701-
if (recordPendingAlignedChunk(marker)) {
701+
if (useNextPendingAlignedChunk(marker)) {
702702
return;
703703
}
704704
clearCachedAlignedChunkData();
@@ -721,7 +721,7 @@ private void moveToNextChunkReader()
721721
}
722722

723723
lastMarker = marker;
724-
if (!recordPendingAlignedChunk(marker)) {
724+
if (!useNextPendingAlignedChunk(marker)) {
725725
clearCachedAlignedChunkData();
726726
chunkReader = null;
727727
}
@@ -808,7 +808,7 @@ private boolean filterChunk(
808808
return false;
809809
}
810810

811-
private boolean recordPendingAlignedChunk(final byte marker) throws IOException {
811+
private boolean useNextPendingAlignedChunk(final byte marker) throws IOException {
812812
while (!pendingAlignedChunkGroups.isEmpty()) {
813813
final PendingAlignedChunkGroup pendingAlignedChunkGroup = pendingAlignedChunkGroups.remove(0);
814814
pendingAlignedChunkSize =
@@ -909,7 +909,7 @@ private boolean returnPendingAlignedChunkBeforeCaching(final CachedAlignedValueC
909909
}
910910

911911
cachedAlignedValueChunk = valueChunk;
912-
if (recordPendingAlignedChunk(Byte.MIN_VALUE)) {
912+
if (useNextPendingAlignedChunk(Byte.MIN_VALUE)) {
913913
return true;
914914
}
915915
cachedAlignedValueChunk = null;

0 commit comments

Comments
 (0)