Package org.apache.druid.data.input.impl

Class InputEntityIteratingReader

java.lang.Object

org.apache.druid.data.input.impl.InputEntityIteratingReader

All Implemented Interfaces:

InputSourceReader

public class InputEntityIteratingReader
extends Object
implements InputSourceReader

InputSourceReader iterating multiple InputEntitys. This class could be used for most of InputSources.

Constructor Summary

Constructors

Constructor	Description
InputEntityIteratingReader(InputRowSchema inputRowSchema, InputFormat inputFormat, CloseableIterator<? extends InputEntity> sourceIterator, SystemFieldDecoratorFactory systemFieldDecoratorFactory, File temporaryDirectory)

Method Summary

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

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.InputSourceReader

read

Constructor Details

InputEntityIteratingReader

public InputEntityIteratingReader(InputRowSchema inputRowSchema,
 InputFormat inputFormat,
 CloseableIterator<? extends InputEntity> sourceIterator,
 SystemFieldDecoratorFactory systemFieldDecoratorFactory,
 File temporaryDirectory)

Method Details

read

public CloseableIterator<InputRow> read(InputStats inputStats)

Specified by:

read in interface InputSourceReader

sample

public CloseableIterator<InputRowListPlusRawValues> sample()

Specified by:

sample in interface InputSourceReader

rowAdapter

public RowAdapter<InputRow> rowAdapter()

Description copied from interface: InputSourceReader

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

Specified by:

rowAdapter in interface InputSourceReader