Package | Description |
---|---|
io.druid.indexing.common.actions | |
io.druid.indexing.overlord | |
io.druid.metadata | |
io.druid.segment.realtime.appenderator |
Modifier and Type | Method and Description |
---|---|
SegmentIdentifier |
SegmentAllocateAction.perform(Task task,
TaskActionToolbox toolbox) |
Modifier and Type | Method and Description |
---|---|
com.fasterxml.jackson.core.type.TypeReference<SegmentIdentifier> |
SegmentAllocateAction.getReturnTypeReference() |
Modifier and Type | Method and Description |
---|---|
SegmentIdentifier |
IndexerMetadataStorageCoordinator.allocatePendingSegment(String dataSource,
String sequenceName,
String previousSegmentId,
org.joda.time.Interval interval,
String maxVersion)
Allocate a new pending segment in the pending segments table.
|
Modifier and Type | Method and Description |
---|---|
SegmentIdentifier |
IndexerSQLMetadataStorageCoordinator.allocatePendingSegment(String dataSource,
String sequenceName,
String previousSegmentId,
org.joda.time.Interval interval,
String maxVersion) |
Modifier and Type | Method and Description |
---|---|
static SegmentIdentifier |
SegmentIdentifier.fromDataSegment(io.druid.timeline.DataSegment segment) |
Copyright © 2011–2016. All rights reserved.