Uses of Interface
io.druid.data.input.Committer

Packages that use Committer

Package	Description
io.druid.data.input
io.druid.segment.realtime.appenderator
io.druid.segment.realtime.plumber

Uses of Committer in io.druid.data.input

Methods in io.druid.data.input that return Committer

Modifier and Type	Method and Description
Committer	FirehoseV2.makeCommitter() Returns a Committer that will "commit" everything read up to the point at which makeCommitter() is called.

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

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

Modifier and Type	Method and Description
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.
Object	StreamAppenderatorDriver.persist(Committer committer) Persist all data indexed through this driver so far.
void	AppenderatorPlumber.persist(Committer committer)
com.google.common.util.concurrent.ListenableFuture<Object>	AppenderatorImpl.persistAll(Committer committer)
default com.google.common.util.concurrent.ListenableFuture<Object>	Appenderator.persistAll(Committer committer) Persist any in-memory indexed data to durable storage.
com.google.common.util.concurrent.ListenableFuture<Object>	StreamAppenderatorDriver.persistAsync(Committer committer) Persist all data indexed through this driver so far.
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata>	StreamAppenderatorDriver.publish(TransactionalSegmentPublisher publisher, Committer committer, Collection<String> sequenceNames) Execute a task in background to publish all segments corresponding to the given sequence names.
com.google.common.util.concurrent.ListenableFuture<SegmentsAndMetadata>	StreamAppenderatorDriver.publishAndRegisterHandoff(TransactionalSegmentPublisher publisher, Committer committer, Collection<String> sequenceNames)
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.

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

Modifier and Type	Method and Description
AppenderatorDriverAddResult	StreamAppenderatorDriver.add(InputRow row, String sequenceName, com.google.common.base.Supplier<Committer> committerSupplier, boolean skipSegmentLineageCheck, boolean allowIncrementalPersists) Add a row.
int	AppenderatorPlumber.add(InputRow row, com.google.common.base.Supplier<Committer> committerSupplier)
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.
protected AppenderatorDriverAddResult	BaseAppenderatorDriver.append(InputRow row, String sequenceName, com.google.common.base.Supplier<Committer> committerSupplier, boolean skipSegmentLineageCheck, boolean allowIncrementalPersists) Add a row.

Uses of Committer in io.druid.segment.realtime.plumber

Methods in io.druid.segment.realtime.plumber that return Committer

Modifier and Type	Method and Description
static Committer	Committers.nil()

Methods in io.druid.segment.realtime.plumber that return types with arguments of type Committer

Modifier and Type	Method and Description
static com.google.common.base.Supplier<Committer>	Committers.supplierFromFirehose(Firehose firehose)
static com.google.common.base.Supplier<Committer>	Committers.supplierFromFirehoseV2(FirehoseV2 firehose)
static com.google.common.base.Supplier<Committer>	Committers.supplierFromRunnable(Runnable runnable)

Methods in io.druid.segment.realtime.plumber with parameters of type Committer

Modifier and Type	Method and Description
void	RealtimePlumber.persist(Committer committer)
void	Plumber.persist(Committer committer) Persist any in-memory indexed data to durable storage.

Method parameters in io.druid.segment.realtime.plumber with type arguments of type Committer

Modifier and Type	Method and Description
int	RealtimePlumber.add(InputRow row, com.google.common.base.Supplier<Committer> committerSupplier)
int	Plumber.add(InputRow row, com.google.common.base.Supplier<Committer> committerSupplier)
static void	Plumbers.addNextRow(com.google.common.base.Supplier<Committer> committerSupplier, Firehose firehose, Plumber plumber, boolean reportParseExceptions, FireDepartmentMetrics metrics)