Uses of Class
io.druid.segment.realtime.appenderator.SegmentIdentifier

Packages that use SegmentIdentifier

Package	Description
io.druid.indexing.appenderator
io.druid.indexing.common.actions
io.druid.indexing.overlord
io.druid.metadata
io.druid.segment.realtime.appenderator

Uses of SegmentIdentifier in io.druid.indexing.appenderator

Methods in io.druid.indexing.appenderator that return SegmentIdentifier

Modifier and Type	Method and Description
SegmentIdentifier	ActionBasedSegmentAllocator.allocate(org.joda.time.DateTime timestamp, String sequenceName, String previousSegmentId)

Method parameters in io.druid.indexing.appenderator with type arguments of type SegmentIdentifier

Modifier and Type	Method and Description
Set<DataSegment>	ActionBasedUsedSegmentChecker.findUsedSegments(Set<SegmentIdentifier> identifiers)

Uses of SegmentIdentifier in io.druid.indexing.common.actions

Methods in io.druid.indexing.common.actions that return SegmentIdentifier

Modifier and Type	Method and Description
SegmentIdentifier	SegmentAllocateAction.perform(Task task, TaskActionToolbox toolbox)

Methods in io.druid.indexing.common.actions that return types with arguments of type SegmentIdentifier

Modifier and Type	Method and Description
com.fasterxml.jackson.core.type.TypeReference<SegmentIdentifier>	SegmentAllocateAction.getReturnTypeReference()

Uses of SegmentIdentifier in io.druid.indexing.overlord

Methods in io.druid.indexing.overlord that return SegmentIdentifier

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.

Uses of SegmentIdentifier in io.druid.metadata

Methods in io.druid.metadata that return SegmentIdentifier

Modifier and Type	Method and Description
SegmentIdentifier	IndexerSQLMetadataStorageCoordinator.allocatePendingSegment(String dataSource, String sequenceName, String previousSegmentId, org.joda.time.Interval interval, String maxVersion)

Uses of SegmentIdentifier in io.druid.segment.realtime.appenderator

Methods in io.druid.segment.realtime.appenderator that return SegmentIdentifier

Modifier and Type	Method and Description
SegmentIdentifier	FiniteAppenderatorDriver.add(InputRow row, String sequenceName, com.google.common.base.Supplier<Committer> committerSupplier) Add a row.
SegmentIdentifier	SegmentAllocator.allocate(org.joda.time.DateTime timestamp, String sequenceName, String previousSegmentId) Allocates a new segment for a given timestamp.
static SegmentIdentifier	SegmentIdentifier.fromDataSegment(DataSegment segment)

Methods in io.druid.segment.realtime.appenderator that return types with arguments of type SegmentIdentifier

Modifier and Type	Method and Description
Map<String,List<SegmentIdentifier>>	FiniteAppenderatorDriverMetadata.getActiveSegments()
List<SegmentIdentifier>	AppenderatorImpl.getSegments()
List<SegmentIdentifier>	Appenderator.getSegments() Returns a list of all currently active segments.
Map<Long,SegmentIdentifier>	AppenderatorPlumber.getSegmentsView()

Methods in io.druid.segment.realtime.appenderator with parameters of type SegmentIdentifier

Modifier and Type	Method and Description
int	AppenderatorImpl.add(SegmentIdentifier identifier, InputRow row, com.google.common.base.Supplier<Committer> committerSupplier)
int	Appenderator.add(SegmentIdentifier identifier, InputRow row, com.google.common.base.Supplier<Committer> committerSupplier) 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.

Method parameters in io.druid.segment.realtime.appenderator with type arguments of type SegmentIdentifier

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.
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata>	AppenderatorImpl.push(List<SegmentIdentifier> identifiers, Committer committer)
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata>	Appenderator.push(List<SegmentIdentifier> identifiers, Committer committer) Merge and push particular segments to deep storage.

Constructor parameters in io.druid.segment.realtime.appenderator with type arguments of type SegmentIdentifier

Constructor and Description
FiniteAppenderatorDriverMetadata(Map<String,List<SegmentIdentifier>> activeSegments, Map<String,String> lastSegmentIds, Object callerMetadata)