Package com.ksc.mission.base.s3

Class PositionableReadStream

java.lang.Object

java.io.InputStream

com.ksc.mission.base.s3.PositionableReadStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class PositionableReadStream
extends java.io.InputStream

Field Summary

Fields

Modifier and Type	Field	Description
protected int[]	buffer
protected long	bufferEndPosition
protected long	bufferStartPosition
protected S3ClientConnector	clientConnector
protected java.lang.String	key
protected int	maxBufferSize
protected com.amazonaws.services.s3.model.ObjectMetadata	metadata
protected long	objectLength
protected long	position
protected java.util.Scanner	scanner

Constructor Summary

Constructors

Constructor	Description
PositionableReadStream(S3ClientConnector clientConnector, java.lang.String key, com.amazonaws.services.s3.model.ObjectMetadata metadata, long position, int maxBufferSize)

Method Summary

Modifier and Type	Method	Description
java.io.InputStreamReader	asInputStreamReader()
java.io.InputStreamReader	asInputStreamReader(java.lang.String codepage)
java.util.zip.ZipInputStream	asZipInputStream()
java.util.stream.Stream<java.lang.Character>	characterStream()
PositionableReadStream	clone()
long	getLength()
boolean	getNextPage(long position)
long	getPosition()
java.lang.String	getVersionId()
long	indexOf(byte[] bytes)
long	indexOf(java.lang.String string)
java.util.stream.IntStream	intStream()
boolean	nextMatches(byte[] bytes)
boolean	nextMatches(java.lang.String string)
int	occurrences(byte[] bytes)
int	occurrences(java.lang.String string)
byte[]	peekFor(long length)
int	read()
byte[]	read(int length)
byte[]	readTo(long endPosition)
java.util.Scanner	scanner()
void	setPosition(long position)
java.util.stream.Stream<java.lang.String>	stringStream()
byte[]	toByteArray()

Methods inherited from class java.io.InputStream

available, close, mark, markSupported, nullInputStream, read, read, readAllBytes, readNBytes, readNBytes, reset, skip, transferTo

Methods inherited from class java.lang.Object

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

Field Detail

maxBufferSize

protected int maxBufferSize

clientConnector

protected final S3ClientConnector clientConnector

scanner

protected java.util.Scanner scanner

buffer

protected int[] buffer

bufferStartPosition

protected long bufferStartPosition

bufferEndPosition

protected long bufferEndPosition

key

protected final java.lang.String key

metadata

protected final com.amazonaws.services.s3.model.ObjectMetadata metadata

position

protected long position

objectLength

protected long objectLength

Constructor Detail

PositionableReadStream

public PositionableReadStream(S3ClientConnector clientConnector,
                              java.lang.String key,
                              com.amazonaws.services.s3.model.ObjectMetadata metadata,
                              long position,
                              int maxBufferSize)

Method Detail

asZipInputStream

public java.util.zip.ZipInputStream asZipInputStream()

read

public int read()

Specified by:

read in class java.io.InputStream

getNextPage

public boolean getNextPage(long position)

toByteArray

public byte[] toByteArray()

clone

public PositionableReadStream clone()

Overrides:

clone in class java.lang.Object

indexOf

public long indexOf(java.lang.String string)

indexOf

public long indexOf(byte[] bytes)

nextMatches

public boolean nextMatches(java.lang.String string)

nextMatches

public boolean nextMatches(byte[] bytes)

peekFor

public byte[] peekFor(long length)

read

public byte[] read(int length)

readTo

public byte[] readTo(long endPosition)

asInputStreamReader

public java.io.InputStreamReader asInputStreamReader()

asInputStreamReader

public java.io.InputStreamReader asInputStreamReader(java.lang.String codepage)

intStream

public java.util.stream.IntStream intStream()

characterStream

public java.util.stream.Stream<java.lang.Character> characterStream()

scanner

public java.util.Scanner scanner()

stringStream

public java.util.stream.Stream<java.lang.String> stringStream()

getPosition

public long getPosition()

setPosition

public void setPosition(long position)

occurrences

public int occurrences(java.lang.String string)

occurrences

public int occurrences(byte[] bytes)

getVersionId

public java.lang.String getVersionId()

getLength

public long getLength()