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

Class FastLineIterator<T>

java.lang.Object

org.apache.druid.data.input.impl.FastLineIterator<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Iterator<T>, CloseableIterator<T>

Direct Known Subclasses:

FastLineIterator.Bytes, FastLineIterator.Strings

public abstract class FastLineIterator<T>
extends Object
implements CloseableIterator<T>

Like the Apache Commons LineIterator, but faster. Use FastLineIterator.Strings or FastLineIterator.Bytes as appropriate. Bytes is faster.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	FastLineIterator.Bytes
static class	FastLineIterator.Strings

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FastLineIterator(InputStream source)	Constructor; a local buffer will be created
protected	FastLineIterator(InputStream source, byte[] buffer)	Constructor; BYO buffer.

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	hasNext()
protected abstract T	makeObject(byte[] bytes, int offset, int length)
T	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

FastLineIterator

protected FastLineIterator(InputStream source)

Constructor; a local buffer will be created

Parameters:

source -

FastLineIterator

protected FastLineIterator(InputStream source,
 byte[] buffer)

Constructor; BYO buffer. Existing contents of the buffer will be destroyed.

Parameters:

source -

buffer - a buffer used for between-read calls

Method Details

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<T>

next

public T next()

Specified by:

next in interface Iterator<T>

makeObject

protected abstract T makeObject(byte[] bytes,
 int offset,
 int length)