com.mongodb.client.gridfs

Class GridFSDownloadStreamImpl

java.lang.Object

java.io.InputStream

com.mongodb.client.gridfs.GridFSDownloadStream

com.mongodb.client.gridfs.GridFSDownloadStreamImpl

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

class GridFSDownloadStreamImpl
extends GridFSDownloadStream

Field Summary

Fields

Modifier and Type	Field and Description
private int	batchSize
private byte[]	buffer
private int	bufferOffset
private int	chunkIndex
private MongoCollection<Document>	chunksCollection
private int	chunkSizeInBytes
private boolean	closed
private java.lang.Object	closeLock
private long	currentPosition
private MongoCursor<Document>	cursor
private java.lang.Object	cursorLock
private BsonValue	fileId
private GridFSFile	fileInfo
private long	length
private long	markPosition
private int	numberOfChunks

Constructor Summary

Constructors

Constructor and Description
GridFSDownloadStreamImpl(GridFSFile fileInfo, MongoCollection<Document> chunksCollection)

Method Summary

Modifier and Type	Method and Description
int	available()
GridFSDownloadStream	batchSize(int batchSize) Sets the number of chunks to return per batch.
private void	checkClosed()
void	close()
private void	discardCursor()
private byte[]	getBuffer(int chunkIndexToFetch)
private byte[]	getBufferFromChunk(Document chunk, int expectedChunkIndex)
private Document	getChunk(int startChunkIndex)
GridFSFile	getGridFSFile() Gets the corresponding GridFSFile for the file being downloaded
void	mark() Marks the current position in this input stream.
void	mark(int readlimit)
boolean	markSupported()
int	read()
int	read(byte[] b)
int	read(byte[] b, int off, int len)
void	reset()
long	skip(long bytesToSkip)

Methods inherited from class java.lang.Object

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

Field Detail

fileInfo

private final GridFSFile fileInfo

chunksCollection

private final MongoCollection<Document> chunksCollection

fileId

private final BsonValue fileId

length

private final long length

chunkSizeInBytes

private final int chunkSizeInBytes

numberOfChunks

private final int numberOfChunks

cursor

private MongoCursor<Document> cursor

batchSize

private int batchSize

chunkIndex

private int chunkIndex

bufferOffset

private int bufferOffset

currentPosition

private long currentPosition

buffer

private byte[] buffer

markPosition

private long markPosition

closeLock

private final java.lang.Object closeLock

cursorLock

private final java.lang.Object cursorLock

closed

private boolean closed

Constructor Detail

GridFSDownloadStreamImpl

GridFSDownloadStreamImpl(GridFSFile fileInfo,
                         MongoCollection<Document> chunksCollection)

Method Detail

getGridFSFile

public GridFSFile getGridFSFile()

Description copied from class: GridFSDownloadStream

Gets the corresponding GridFSFile for the file being downloaded

Specified by:

getGridFSFile in class GridFSDownloadStream

Returns:

the corresponding GridFSFile for the file being downloaded

batchSize

public GridFSDownloadStream batchSize(int batchSize)

Description copied from class: GridFSDownloadStream

Sets the number of chunks to return per batch.

Can be used to control the memory consumption of this InputStream. The smaller the batchSize the lower the memory consumption and higher latency.

Specified by:

batchSize in class GridFSDownloadStream

Parameters:

batchSize - the batch size

Returns:

this

read

public int read()

Specified by:

read in class GridFSDownloadStream

read

public int read(byte[] b)

Specified by:

read in class GridFSDownloadStream

read

public int read(byte[] b,
                int off,
                int len)

Specified by:

read in class GridFSDownloadStream

skip

public long skip(long bytesToSkip)

Specified by:

skip in class GridFSDownloadStream

available

public int available()

Specified by:

available in class GridFSDownloadStream

mark

public void mark()

Description copied from class: GridFSDownloadStream

Marks the current position in this input stream.

A subsequent call to the reset method repositions this stream at the last marked position so that subsequent reads re-read the same bytes.

Specified by:

mark in class GridFSDownloadStream

mark

public void mark(int readlimit)

Overrides:

mark in class java.io.InputStream

reset

public void reset()

Specified by:

reset in class GridFSDownloadStream

markSupported

public boolean markSupported()

Overrides:

markSupported in class java.io.InputStream

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in class GridFSDownloadStream

checkClosed

private void checkClosed()

discardCursor

private void discardCursor()

getChunk

private Document getChunk(int startChunkIndex)

getBufferFromChunk

private byte[] getBufferFromChunk(Document chunk,
                                  int expectedChunkIndex)

getBuffer

private byte[] getBuffer(int chunkIndexToFetch)