org.apache.druid.server.coordinator.helper

Class NewestSegmentFirstIterator

java.lang.Object

org.apache.druid.server.coordinator.helper.NewestSegmentFirstIterator

All Implemented Interfaces:

Iterator<List<org.apache.druid.timeline.DataSegment>>, CompactionSegmentIterator

public class NewestSegmentFirstIterator
extends Object
implements CompactionSegmentIterator

This class iterates all segments of the dataSources configured for compaction from the newest to the oldest.

Field Summary

Fields inherited from interface org.apache.druid.server.coordinator.helper.CompactionSegmentIterator

UNKNOWN_REMAINING_SEGMENT_SIZE

Method Summary

Modifier and Type	Method and Description
boolean	hasNext()
List<org.apache.druid.timeline.DataSegment>	next()
it.unimi.dsi.fastutil.objects.Object2LongOpenHashMap<String>	remainingSegmentSizeBytes() Return a map of (dataSource, total size of remaining segments) for all dataSources.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Method Detail

remainingSegmentSizeBytes

public it.unimi.dsi.fastutil.objects.Object2LongOpenHashMap<String> remainingSegmentSizeBytes()

Description copied from interface: CompactionSegmentIterator

Return a map of (dataSource, total size of remaining segments) for all dataSources. This method should consider all segments except the segments returned by Iterator.next().

Specified by:

remainingSegmentSizeBytes in interface CompactionSegmentIterator

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<List<org.apache.druid.timeline.DataSegment>>

next

public List<org.apache.druid.timeline.DataSegment> next()

Specified by:

next in interface Iterator<List<org.apache.druid.timeline.DataSegment>>