org.apache.druid.server.coordinator.helper

Class NewestSegmentFirstPolicy

java.lang.Object

org.apache.druid.server.coordinator.helper.NewestSegmentFirstPolicy

All Implemented Interfaces:

CompactionSegmentSearchPolicy

public class NewestSegmentFirstPolicy
extends Object
implements CompactionSegmentSearchPolicy

This policy searches segments for compaction from the newest one to oldest one.

Constructor Summary

Constructors

Constructor and Description
NewestSegmentFirstPolicy()

Method Summary

Modifier and Type	Method and Description
CompactionSegmentIterator	reset(Map<String,DataSourceCompactionConfig> compactionConfigs, Map<String,org.apache.druid.timeline.VersionedIntervalTimeline<String,org.apache.druid.timeline.DataSegment>> dataSources) Reset the current states of this policy.

Methods inherited from class java.lang.Object

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

Constructor Detail

NewestSegmentFirstPolicy

public NewestSegmentFirstPolicy()

Method Detail

reset

public CompactionSegmentIterator reset(Map<String,DataSourceCompactionConfig> compactionConfigs,
                                       Map<String,org.apache.druid.timeline.VersionedIntervalTimeline<String,org.apache.druid.timeline.DataSegment>> dataSources)

Description copied from interface: CompactionSegmentSearchPolicy

Reset the current states of this policy. This method should be called whenever iterating starts.

Specified by:

reset in interface CompactionSegmentSearchPolicy