Package org.apache.druid.data.input

Interface InputSourceReader

All Known Implementing Classes:

InputEntityIteratingReader, TimedShutoffInputSourceReader, TransformingInputSourceReader

public interface InputSourceReader

InputSourceReader reads data from InputSource and returns a CloseableIterator of InputRows. See InputSource for an example usage. Implementations of this class can use InputEntity and InputEntityReader. InputFormat can be useful to understand how to create an InputEntityReader. See InputEntityIteratingReader as an example.

Method Summary

Modifier and Type	Method	Description
default CloseableIterator<InputRow>	read()
CloseableIterator<InputRow>	read(InputStats inputStats)
default RowAdapter<InputRow>	rowAdapter()	Returns an adapter that can be used to read the rows from read().
CloseableIterator<InputRowListPlusRawValues>	sample()

Method Details

read

default CloseableIterator<InputRow> read()
                                  throws IOException

Throws:

IOException

read

CloseableIterator<InputRow> read(InputStats inputStats)
                          throws IOException

Throws:

IOException

sample

CloseableIterator<InputRowListPlusRawValues> sample()
                                             throws IOException

Throws:

IOException

rowAdapter

default RowAdapter<InputRow> rowAdapter()

Returns an adapter that can be used to read the rows from read().