Package com.ksc.mission.base.s3

Class PositionableS3ReadStream

java.lang.Object

java.io.InputStream

com.ksc.mission.base.s3.PositionableS3ReadStream

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class PositionableS3ReadStream
extends java.io.InputStream

Field Summary

Fields

Modifier and Type	Field	Description
protected byte[]	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
PositionableS3ReadStream(S3ClientConnector clientConnector, java.lang.String key, com.amazonaws.services.s3.model.ObjectMetadata metadata, long position, int maxBufferSize)
PositionableS3ReadStream(S3ClientConnector clientConnector, java.lang.String key, com.amazonaws.services.s3.model.ObjectMetadata metadata, long position, int maxBufferSize, long readLimit)

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()
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()
java.util.stream.Stream<java.lang.String>	lines()
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)
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

clone, 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 byte[] 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

PositionableS3ReadStream

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

PositionableS3ReadStream

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

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()

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()

lines

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

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()