org.apache.druid.segment.realtime.firehose

Class SqlFirehoseFactory

java.lang.Object

org.apache.druid.data.input.impl.prefetch.PrefetchSqlFirehoseFactory<String>

org.apache.druid.segment.realtime.firehose.SqlFirehoseFactory

All Implemented Interfaces:

org.apache.druid.data.input.FirehoseFactory<org.apache.druid.data.input.impl.InputRowParser<Map<String,Object>>>

public class SqlFirehoseFactory
extends org.apache.druid.data.input.impl.prefetch.PrefetchSqlFirehoseFactory<String>

Constructor Summary

Constructors

Constructor and Description
SqlFirehoseFactory(List<String> sqls, Long maxCacheCapacityBytes, Long maxFetchCapacityBytes, Long prefetchTriggerBytes, Long fetchTimeout, boolean foldCase, SQLFirehoseDatabaseConnector sqlFirehoseDatabaseConnector, com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Summary

Modifier and Type	Method and Description
protected Collection<String>	initObjects()
protected InputStream	openObjectStream(String object, File fileName)

Methods inherited from class org.apache.druid.data.input.impl.prefetch.PrefetchSqlFirehoseFactory

connect, getFetchTimeout, getMaxCacheCapacityBytes, getMaxFetchCapacityBytes, getPrefetchTriggerBytes

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.data.input.FirehoseFactory

connect, isSplittable

Constructor Detail

SqlFirehoseFactory

public SqlFirehoseFactory(List<String> sqls,
                          Long maxCacheCapacityBytes,
                          Long maxFetchCapacityBytes,
                          Long prefetchTriggerBytes,
                          Long fetchTimeout,
                          boolean foldCase,
                          SQLFirehoseDatabaseConnector sqlFirehoseDatabaseConnector,
                          com.fasterxml.jackson.databind.ObjectMapper objectMapper)

Method Detail

openObjectStream

protected InputStream openObjectStream(String object,
                                       File fileName)
                                throws IOException

Specified by:

openObjectStream in class org.apache.druid.data.input.impl.prefetch.PrefetchSqlFirehoseFactory<String>

Throws:

IOException

initObjects

protected Collection<String> initObjects()

Specified by:

initObjects in class org.apache.druid.data.input.impl.prefetch.PrefetchSqlFirehoseFactory<String>