io.druid.segment.realtime.firehose

Class CombiningFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.CombiningFirehoseFactory

All Implemented Interfaces:

io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.InputRowParser>

public class CombiningFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.InputRowParser>

Creates firehose that combines data from different Firehoses. Useful for ingesting data from multiple sources.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CombiningFirehoseFactory.CombiningFirehose

Constructor Summary

Constructors

Constructor and Description
CombiningFirehoseFactory(List<io.druid.data.input.FirehoseFactory> delegateFactoryList)

Method Summary

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect(io.druid.data.input.impl.InputRowParser parser)
List<io.druid.data.input.FirehoseFactory>	getDelegateFactoryList()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CombiningFirehoseFactory

public CombiningFirehoseFactory(List<io.druid.data.input.FirehoseFactory> delegateFactoryList)

Method Detail

connect

public io.druid.data.input.Firehose connect(io.druid.data.input.impl.InputRowParser parser)
                                     throws IOException

Specified by:

connect in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.InputRowParser>

Throws:

IOException

getDelegateFactoryList

public List<io.druid.data.input.FirehoseFactory> getDelegateFactoryList()