org.lenskit.util.io

Class LineStream

java.lang.Object

org.lenskit.util.io.AbstractObjectStream<java.lang.String>

org.lenskit.util.io.LineStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Iterable<java.lang.String>, java.util.stream.BaseStream<java.lang.String,java.util.stream.Stream<java.lang.String>>, java.util.stream.Stream<java.lang.String>, ObjectStream<java.lang.String>

public class LineStream
extends AbstractObjectStream<java.lang.String>

Stream that reads lines from a file.

Since:

0.10

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.stream.Stream

java.util.stream.Stream.Builder<T>

Field Summary

Fields inherited from class org.lenskit.util.io.AbstractObjectStream

stream

Constructor Summary

Constructors

Constructor and Description
LineStream(java.io.BufferedReader in) Construct a stream reading lines from a buffered reader.

Method Summary

Modifier and Type	Method and Description
void	close() No-op implementation of the ObjectStream.close() method.
int	getLineNumber() Return the number of the line returned by the last call to readObject().
static LineStream	openFile(java.io.File file) Open a delimited text stream as a file.
static LineStream	openFile(java.io.File file, CompressionMode comp) Open a delimited text stream as a file.
java.lang.String	readObject() Read the next object from this stream.
ObjectStream<java.util.List<java.lang.String>>	tokenize(org.apache.commons.lang3.text.StrTokenizer tok)

Methods inherited from class org.lenskit.util.io.AbstractObjectStream

allMatch, anyMatch, collect, collect, count, distinct, filter, findAny, findFirst, flatMap, flatMapToDouble, flatMapToInt, flatMapToLong, forEach, forEachOrdered, isParallel, iterator, limit, map, mapToDouble, mapToInt, mapToLong, max, min, noneMatch, onClose, parallel, peek, reduce, reduce, reduce, sequential, skip, sorted, sorted, spliterator, toArray, toArray, unordered

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.stream.Stream

builder, concat, empty, generate, iterate, of, of

Constructor Detail

LineStream

public LineStream(@WillCloseWhenClosed @Nonnull
                  java.io.BufferedReader in)

Construct a stream reading lines from a buffered reader.

Parameters:

in - The input reader.

Method Detail

openFile

public static LineStream openFile(java.io.File file)
                           throws java.io.FileNotFoundException

Open a delimited text stream as a file.

Parameters:

file - The file to open.

Returns:

The stream.

Throws:

java.io.FileNotFoundException - if there is an error opening the file.

openFile

public static LineStream openFile(java.io.File file,
                                  CompressionMode comp)
                           throws java.io.IOException

Open a delimited text stream as a file.

Parameters:

file - The file to open.

Returns:

The stream.

Throws:

java.io.FileNotFoundException - if there is an error opening the file.

java.io.IOException

readObject

@Nullable
public java.lang.String readObject()

Description copied from interface: ObjectStream

Read the next object from this stream.

Returns:

The next object, or null if at the end of the stream.

getLineNumber

public int getLineNumber()

Return the number of the line returned by the last call to readObject().

Returns:

The number of the last line retrieved.

close

public void close()

Description copied from class: AbstractObjectStream

No-op implementation of the ObjectStream.close() method.

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.util.stream.BaseStream<java.lang.String,java.util.stream.Stream<java.lang.String>>

Specified by:

close in interface ObjectStream<java.lang.String>

Overrides:

close in class AbstractObjectStream<java.lang.String>

tokenize

public ObjectStream<java.util.List<java.lang.String>> tokenize(org.apache.commons.lang3.text.StrTokenizer tok)