Package org.apache.druid.data.input

Class HandlingInputRowIterator

java.lang.Object

org.apache.druid.data.input.HandlingInputRowIterator

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<InputRow>, CloseableIterator<InputRow>

public class HandlingInputRowIterator
extends Object
implements CloseableIterator<InputRow>

Decorated CloseableIterator<InputRow> that can process rows with HandlingInputRowIterator.InputRowHandlers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	HandlingInputRowIterator.InputRowHandler

Constructor Summary

Constructors

Constructor	Description
HandlingInputRowIterator(CloseableIterator<InputRow> inputRowIterator, List<HandlingInputRowIterator.InputRowHandler> inputRowHandlers)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasNext()
InputRow	next()

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.java.util.common.parsers.CloseableIterator

flatMap, map

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Constructor Details

HandlingInputRowIterator

public HandlingInputRowIterator(CloseableIterator<InputRow> inputRowIterator,
 List<HandlingInputRowIterator.InputRowHandler> inputRowHandlers)

Parameters:

inputRowIterator - Source of InputRows

inputRowHandlers - Before yielding the next InputRow, each HandlingInputRowIterator.InputRowHandler is sequentially applied to the InputRow until one of them returns true or all of the handlers are applied.

Method Details

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<InputRow>

next

@Nullable
public InputRow next()

Specified by:

next in interface Iterator<InputRow>

Returns:

Next InputRow or null if row was successfully handled by an HandlingInputRowIterator.InputRowHandler.

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException