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(org.joda.time.DateTime timestamp, String sequenceName, String previousSegmentId) Allocates a new segment for a given timestamp.

Method Detail

allocate

SegmentIdentifier allocate(org.joda.time.DateTime timestamp,
                           String sequenceName,
                           String previousSegmentId)
                    throws IOException

Allocates a new segment for a given timestamp.

Parameters:

timestamp - timestamp of 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

Returns:

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

Throws:

IOException