com.mission.base.s3

Class PositionableReadStream

java.lang.Object

java.io.InputStream

com.mission.base.s3.PositionableReadStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class PositionableReadStream
extends InputStream

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
java.util.stream.Stream<Character>	characterStream()
PositionableReadStream	clone()
String	getContents()
long	getLength()
boolean	getNextPage(long position)
long	getPosition()
String	getVersionId()
long	indexOf(String str)
java.util.stream.IntStream	intStream()
boolean	nextMatches(int[] chars)
int	occurrences(String string)
String	peekFor(long length)
int	read()
String	read(int length)
String	readTo(long endPosition)
Scanner	scanner()
void	setPosition(long position)
java.util.stream.Stream<String>	stringStream()

Methods inherited from class java.io.InputStream

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

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 Scanner scanner

buffer

protected int[] buffer

bufferStartPosition

protected long bufferStartPosition

bufferEndPosition

protected long bufferEndPosition

key

protected final 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,
                              String key,
                              com.amazonaws.services.s3.model.ObjectMetadata metadata,
                              long position,
                              int maxBufferSize)

Method Detail

read

public int read()

Specified by:

read in class InputStream

getNextPage

public boolean getNextPage(long position)

getContents

public String getContents()

clone

public PositionableReadStream clone()

Overrides:

clone in class Object

indexOf

public long indexOf(String str)

nextMatches

public boolean nextMatches(int[] chars)

peekFor

public String peekFor(long length)

read

public String read(int length)

readTo

public String readTo(long endPosition)

intStream

public java.util.stream.IntStream intStream()

characterStream

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

scanner

public Scanner scanner()

stringStream

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

getPosition

public long getPosition()

setPosition

public void setPosition(long position)

occurrences

public int occurrences(String string)

getVersionId

public String getVersionId()

getLength

public long getLength()