| 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.