public class Plumbers extends Object
Modifier and Type | Method and Description |
---|---|
static void |
addNextRow(com.google.common.base.Supplier<io.druid.data.input.Committer> committerSupplier,
io.druid.data.input.Firehose firehose,
Plumber plumber,
boolean reportParseExceptions,
FireDepartmentMetrics metrics) |
public static void addNextRow(com.google.common.base.Supplier<io.druid.data.input.Committer> committerSupplier, io.druid.data.input.Firehose firehose, Plumber plumber, boolean reportParseExceptions, FireDepartmentMetrics metrics)
Copyright © 2011–2016. All rights reserved.