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(InputRow row, String sequenceName, String previousSegmentId, boolean skipSegmentLineageCheck) 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(InputRow row,
                                  String sequenceName,
                                  String previousSegmentId,
                                  boolean skipSegmentLineageCheck)
                           throws IOException

Description copied from interface: SegmentAllocator

Allocates a new segment for a given timestamp.

Specified by:

allocate in interface SegmentAllocator

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