Package io.deephaven.importers.csv

Class CsvImporterHelperBpipe.BPipeInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

java.io.BufferedInputStream

io.deephaven.importers.util.SkipLinesInputStream

io.deephaven.importers.csv.CsvImporterHelperBpipe.BPipeInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

CsvImporterHelperBpipe

public static class CsvImporterHelperBpipe.BPipeInputStream
extends SkipLinesInputStream

Extends SkipLinesInputStream as that supports readLine functionality.

Field Summary

Fields inherited from class io.deephaven.importers.util.SkipLinesInputStream

DEFAULT_BUFFER_SIZE, EOF, LINE_BUFFER_SIZE

Fields inherited from class java.io.BufferedInputStream

buf, count, marklimit, markpos, pos

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor	Description
BPipeInputStream(InputStream in, int skipHeaderLines, int skipFooterLines, @NotNull String eodString, @NotNull String commentString)

Method Summary

Modifier and Type	Method	Description
int	available()
boolean	markSupported()
int	read()
int	read(byte @NotNull [] b, int off, int len)
void	reset()
long	skip(long n)

Methods inherited from class io.deephaven.importers.util.SkipLinesInputStream

getBufferSize, getDefaultBufferSize, readLine, readLine, readLineAsBytes

Methods inherited from class java.io.BufferedInputStream

close, mark

Methods inherited from class java.io.FilterInputStream

read

Methods inherited from class java.io.InputStream

nullInputStream, readAllBytes, readNBytes, readNBytes, skipNBytes, transferTo

Methods inherited from class java.lang.Object

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

Constructor Details

BPipeInputStream

public BPipeInputStream(InputStream in,
 int skipHeaderLines,
 int skipFooterLines,
 @NotNull
 @NotNull String eodString,
 @NotNull
 @NotNull String commentString)
                 throws IOException

Throws:

IOException

Method Details

read

public int read()
         throws IOException

Overrides:

read in class SkipLinesInputStream

Throws:

IOException

read

public int read(byte @NotNull [] b,
 int off,
 int len)
         throws IOException

Overrides:

read in class SkipLinesInputStream

Throws:

IOException

skip

public long skip(long n)

Overrides:

skip in class SkipLinesInputStream

markSupported

public boolean markSupported()

Overrides:

markSupported in class BufferedInputStream

reset

public void reset()

Overrides:

reset in class SkipLinesInputStream

available

public int available()

Overrides:

available in class SkipLinesInputStream