io.druid.segment.realtime.appenderator

Interface SegmentAllocator

All Known Implementing Classes:

ActionBasedSegmentAllocator

public interface SegmentAllocator

Method Summary

Modifier and Type	Method and Description
SegmentIdentifier	allocate(InputRow row, String sequenceName, String previousSegmentId, boolean skipSegmentLineageCheck) Allocates a new segment for a given timestamp.

Method Detail

allocate

SegmentIdentifier allocate(InputRow row,
                           String sequenceName,
                           String previousSegmentId,
                           boolean skipSegmentLineageCheck)
                    throws IOException

Allocates a new segment for a given timestamp.

Parameters:

row - the event which triggered this allocation request

sequenceName - sequenceName for this allocation

previousSegmentId - segment identifier returned on the previous call to allocate for your sequenceName

skipSegmentLineageCheck - if true, perform lineage validation using previousSegmentId for this sequence. Should be set to false if replica tasks would index events in same order

Returns:

the pending segment identifier, or null if it was impossible to allocate a new segment

Throws:

IOException