Package | Description |
---|---|
io.druid.indexing.appenderator | |
io.druid.indexing.common.actions | |
io.druid.indexing.overlord | |
io.druid.metadata | |
io.druid.segment.realtime.appenderator |
Modifier and Type | Method and Description |
---|---|
SegmentIdentifier |
ActionBasedSegmentAllocator.allocate(InputRow row,
String sequenceName,
String previousSegmentId,
boolean skipSegmentLineageCheck) |
Modifier and Type | Method and Description |
---|---|
Set<DataSegment> |
ActionBasedUsedSegmentChecker.findUsedSegments(Set<SegmentIdentifier> identifiers) |
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,
boolean skipSegmentLineageCheck)
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,
boolean skipSegmentLineageCheck) |
Modifier and Type | Method and Description |
---|---|
SegmentIdentifier |
SegmentAllocator.allocate(InputRow row,
String sequenceName,
String previousSegmentId,
boolean skipSegmentLineageCheck)
Allocates a new segment for a given timestamp.
|
static SegmentIdentifier |
SegmentIdentifier.fromDataSegment(DataSegment segment) |
SegmentIdentifier |
SegmentWithState.getSegmentIdentifier() |
SegmentIdentifier |
AppenderatorDriverAddResult.getSegmentIdentifier() |
Modifier and Type | Method and Description |
---|---|
List<SegmentIdentifier> |
AppenderatorImpl.getSegments() |
List<SegmentIdentifier> |
Appenderator.getSegments()
Returns a list of all currently active segments.
|
Map<Long,SegmentIdentifier> |
AppenderatorPlumber.getSegmentsView() |
Modifier and Type | Method and Description |
---|---|
default Appenderator.AppenderatorAddResult |
Appenderator.add(SegmentIdentifier identifier,
InputRow row,
com.google.common.base.Supplier<Committer> committerSupplier)
Same as
Appenderator.add(SegmentIdentifier, InputRow, Supplier, boolean) , with allowIncrementalPersists set to true |
Appenderator.AppenderatorAddResult |
AppenderatorImpl.add(SegmentIdentifier identifier,
InputRow row,
com.google.common.base.Supplier<Committer> committerSupplier,
boolean allowIncrementalPersists) |
Appenderator.AppenderatorAddResult |
Appenderator.add(SegmentIdentifier identifier,
InputRow row,
com.google.common.base.Supplier<Committer> committerSupplier,
boolean allowIncrementalPersists)
Add a row.
|
com.google.common.util.concurrent.ListenableFuture<?> |
AppenderatorImpl.drop(SegmentIdentifier identifier) |
com.google.common.util.concurrent.ListenableFuture<?> |
Appenderator.drop(SegmentIdentifier identifier)
Drop all data associated with a particular pending segment.
|
void |
AppenderatorPlumber.dropSegment(SegmentIdentifier identifier) |
int |
AppenderatorImpl.getRowCount(SegmentIdentifier identifier) |
int |
Appenderator.getRowCount(SegmentIdentifier identifier)
Returns the number of rows in a particular pending segment.
|
static AppenderatorDriverAddResult |
AppenderatorDriverAddResult.ok(SegmentIdentifier segmentIdentifier,
int numRowsInSegment,
long totalNumRowsInAppenderator,
boolean isPersistRequired) |
Modifier and Type | Method and Description |
---|---|
static Committed |
Committed.create(Map<SegmentIdentifier,Integer> hydrants0,
Object metadata) |
Set<DataSegment> |
UsedSegmentChecker.findUsedSegments(Set<SegmentIdentifier> identifiers)
For any identifiers that exist and are actually used, returns the corresponding DataSegment objects.
|
void |
StreamAppenderatorDriver.moveSegmentOut(String sequenceName,
List<SegmentIdentifier> identifiers)
Move a set of identifiers out from "active", making way for newer segments.
|
com.google.common.util.concurrent.ListenableFuture<Object> |
AppenderatorImpl.persist(Collection<SegmentIdentifier> identifiers,
Committer committer) |
com.google.common.util.concurrent.ListenableFuture<Object> |
Appenderator.persist(Collection<SegmentIdentifier> identifiers,
Committer committer)
Persist any in-memory indexed data for segments of the given identifiers to durable storage.
|
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
AppenderatorImpl.push(Collection<SegmentIdentifier> identifiers,
Committer committer) |
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata> |
Appenderator.push(Collection<SegmentIdentifier> identifiers,
Committer committer)
Merge and push particular segments to deep storage.
|
Constructor and Description |
---|
SegmentWithState(SegmentIdentifier segmentIdentifier,
SegmentWithState.SegmentState state,
DataSegment dataSegment) |
Constructor and Description |
---|
AppenderatorDriverMetadata(Map<String,List<SegmentWithState>> segments,
Map<String,String> lastSegmentIds,
Object callerMetadata,
Map<String,List<SegmentIdentifier>> activeSegments,
Map<String,List<SegmentIdentifier>> publishPendingSegments) |
AppenderatorDriverMetadata(Map<String,List<SegmentWithState>> segments,
Map<String,String> lastSegmentIds,
Object callerMetadata,
Map<String,List<SegmentIdentifier>> activeSegments,
Map<String,List<SegmentIdentifier>> publishPendingSegments) |
Copyright © 2011–2018. All rights reserved.