org.xbib.marc.dialects.pica

Class PicaPlainInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

java.io.BufferedInputStream

org.xbib.marc.io.PatternInputStream

org.xbib.marc.dialects.pica.PicaPlainInputStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, ChunkStream<byte[],BytesReference>

public class PicaPlainInputStream
extends PatternInputStream

Pica plain, a line-feed-delimited text file dialect of MARC. The format is specified as follows:

• character set is PICA or UTF-8
• each record is delimited by empy line
• each field is delimited by line-feed
• no record label
• each field tag has one indicator (including "@") and a repeat counter (like 201B/01)
• subfields are delimited by '$' and can even be empty

Field Summary

Fields

Modifier and Type	Field and Description
protected int	begin
protected byte[]	buffer
protected int	end
protected BytesStreamOutput	ref

Fields inherited from class java.io.BufferedInputStream

buf, count, marklimit, markpos, pos

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
PicaPlainInputStream(java.io.InputStream in, byte[] pattern, MarcGenerator marcGenerator)

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<Chunk<byte[],BytesReference>>	chunks() This methods creates a Java 8 stream of chunks.
protected void	processChunk(Chunk<byte[],BytesReference> chunk) This method can be overriden by classes to extend the processing of a chunk before it is returned to the caller.

Methods inherited from class org.xbib.marc.io.PatternInputStream

crlf, lf, readChunk

Methods inherited from class java.io.BufferedInputStream

available, close, mark, markSupported, read, read, reset, skip

Methods inherited from class java.io.FilterInputStream

read

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Field Detail

ref

protected final BytesStreamOutput ref

buffer

protected byte[] buffer

begin

protected int begin

end

protected int end

Constructor Detail

PicaPlainInputStream

public PicaPlainInputStream(java.io.InputStream in,
                            byte[] pattern,
                            MarcGenerator marcGenerator)

Method Detail

processChunk

protected void processChunk(Chunk<byte[],BytesReference> chunk)
                     throws java.io.IOException

Description copied from class: PatternInputStream

This method can be overriden by classes to extend the processing of a chunk before it is returned to the caller.

Overrides:

processChunk in class PatternInputStream

Parameters:

chunk - the chunk to be processed.

Throws:

java.io.IOException - if chunk processing fails

chunks

public java.util.stream.Stream<Chunk<byte[],BytesReference>> chunks()

This methods creates a Java 8 stream of chunks.

Specified by:

chunks in interface ChunkStream<byte[],BytesReference>

Returns:

a stream of chunks