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
SegmentsAndMetadata	FiniteAppenderatorDriver.finish(TransactionalSegmentPublisher publisher, Committer committer) Publish all data indexed through this driver so far, and waits for it to be handed off.
Object	FiniteAppenderatorDriver.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)
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<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.

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

Modifier and Type	Method and Description
SegmentIdentifier	FiniteAppenderatorDriver.add(InputRow row, String sequenceName, com.google.common.base.Supplier<Committer> committerSupplier) Add a row.
int	AppenderatorPlumber.add(InputRow row, com.google.common.base.Supplier<Committer> committerSupplier)
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.

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)