io.druid.indexing.appenderator

Class ActionBasedSegmentAllocator

java.lang.Object

io.druid.indexing.appenderator.ActionBasedSegmentAllocator

All Implemented Interfaces:

SegmentAllocator

public class ActionBasedSegmentAllocator
extends Object
implements SegmentAllocator

Constructor Summary

Constructors

Constructor and Description
ActionBasedSegmentAllocator(TaskActionClient taskActionClient, DataSchema dataSchema)

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

ActionBasedSegmentAllocator

public ActionBasedSegmentAllocator(TaskActionClient taskActionClient,
                                   DataSchema dataSchema)

Method Detail

allocate

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

Description copied from interface: SegmentAllocator

Allocates a new segment for a given timestamp.

Specified by:

allocate in interface SegmentAllocator

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