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

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, boolean skipSegmentLineageCheck) 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, boolean skipSegmentLineageCheck)

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	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()

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

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()

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

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)

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

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

Constructor and Description
SegmentWithState(SegmentIdentifier segmentIdentifier, SegmentWithState.SegmentState state, DataSegment dataSegment)

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

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)