io.druid.segment.realtime.appenderator

Class SegmentWithState

java.lang.Object

io.druid.segment.realtime.appenderator.SegmentWithState

public class SegmentWithState
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SegmentWithState.SegmentState Segment state transition is different in BatchAppenderatorDriver and StreamAppenderatorDriver.

Constructor Summary

Constructors

Constructor and Description
SegmentWithState(SegmentIdentifier segmentIdentifier, SegmentWithState.SegmentState state, DataSegment dataSegment)

Method Summary

Modifier and Type	Method and Description
void	finishAppending() Change the segment state to SegmentWithState.SegmentState.APPEND_FINISHED.
DataSegment	getDataSegment()
SegmentIdentifier	getSegmentIdentifier()
SegmentWithState.SegmentState	getState()
void	pushAndDrop(DataSegment dataSegment) Change the segment state to SegmentWithState.SegmentState.PUSHED_AND_DROPPED.
void	setState(SegmentWithState.SegmentState state)

Methods inherited from class java.lang.Object

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

Constructor Detail

SegmentWithState

public SegmentWithState(SegmentIdentifier segmentIdentifier,
                        SegmentWithState.SegmentState state,
                        @Nullable
                        DataSegment dataSegment)

Method Detail

setState

public void setState(SegmentWithState.SegmentState state)

finishAppending

public void finishAppending()

Change the segment state to SegmentWithState.SegmentState.APPEND_FINISHED. The current state should be SegmentWithState.SegmentState.APPENDING.

pushAndDrop

public void pushAndDrop(DataSegment dataSegment)

Change the segment state to SegmentWithState.SegmentState.PUSHED_AND_DROPPED. The current state should be SegmentWithState.SegmentState.APPENDING. This method should be called after the segment of segmentIdentifier is completely pushed and dropped.

Parameters:

dataSegment - pushed DataSegment

getSegmentIdentifier

public SegmentIdentifier getSegmentIdentifier()

getState

public SegmentWithState.SegmentState getState()

getDataSegment

@Nullable
public DataSegment getDataSegment()