public class Committers extends Object
Constructor and Description |
---|
Committers() |
Modifier and Type | Method and Description |
---|---|
static io.druid.data.input.Committer |
nil() |
static com.google.common.base.Supplier<io.druid.data.input.Committer> |
supplierFromFirehose(io.druid.data.input.Firehose firehose) |
static com.google.common.base.Supplier<io.druid.data.input.Committer> |
supplierFromFirehoseV2(io.druid.data.input.FirehoseV2 firehose) |
static com.google.common.base.Supplier<io.druid.data.input.Committer> |
supplierFromRunnable(Runnable runnable) |
static com.google.common.base.Supplier<io.druid.data.input.Committer> |
supplierOf(io.druid.data.input.Committer committer) |
public static com.google.common.base.Supplier<io.druid.data.input.Committer> supplierFromRunnable(Runnable runnable)
public static com.google.common.base.Supplier<io.druid.data.input.Committer> supplierFromFirehose(io.druid.data.input.Firehose firehose)
public static com.google.common.base.Supplier<io.druid.data.input.Committer> supplierFromFirehoseV2(io.druid.data.input.FirehoseV2 firehose)
public static io.druid.data.input.Committer nil()
public static com.google.common.base.Supplier<io.druid.data.input.Committer> supplierOf(io.druid.data.input.Committer committer)
Copyright © 2011–2016. All rights reserved.