io.druid.examples.web

Class InputSupplierUpdateStreamFactory

java.lang.Object

io.druid.examples.web.InputSupplierUpdateStreamFactory

All Implemented Interfaces:

UpdateStreamFactory

public class InputSupplierUpdateStreamFactory
extends Object
implements UpdateStreamFactory

Constructor Summary

Constructors

Constructor and Description
InputSupplierUpdateStreamFactory(com.google.common.io.InputSupplier<BufferedReader> inputSupplier, String timeDimension)

Method Summary

Methods

Modifier and Type	Method and Description
InputSupplierUpdateStream	build()

Methods inherited from class java.lang.Object

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

Constructor Detail

InputSupplierUpdateStreamFactory

public InputSupplierUpdateStreamFactory(com.google.common.io.InputSupplier<BufferedReader> inputSupplier,
                                String timeDimension)

Method Detail

build

public InputSupplierUpdateStream build()

Specified by:

build in interface UpdateStreamFactory