Package deltix.qsrv.hf.tickdb.tool

Class S3RawMessageReader

java.lang.Object

deltix.util.s3.S3Reader<RawMessage>

deltix.qsrv.hf.tickdb.tool.S3RawMessageReader

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class S3RawMessageReader
extends deltix.util.s3.S3Reader<RawMessage>

Nested Class Summary

Nested classes/interfaces inherited from class deltix.util.s3.S3Reader

deltix.util.s3.S3Reader.DataOutputStream

Field Summary

Fields inherited from class deltix.util.s3.S3Reader

LOG

Constructor Summary

Constructors

Constructor	Description
S3RawMessageReader(deltix.util.s3.S3DataStore dataStore, java.lang.String dataKey, long startTime, long endTime, RecordClassDescriptor[] descriptors)

Method Summary

Modifier and Type	Method	Description
void	close()
protected java.lang.String	getDataFormat()
S3SpaceMetadata	getSpaceMetadata()
boolean	isOldFormat()
protected RawMessage	readNextRecord()
protected void	startBatch(java.io.InputStream batchData)

Methods inherited from class deltix.util.s3.S3Reader

extractTimestamp, getLastTimestamp, getUserMetadata, read

Methods inherited from class java.lang.Object

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

Constructor Detail

S3RawMessageReader

public S3RawMessageReader(deltix.util.s3.S3DataStore dataStore,
                          java.lang.String dataKey,
                          long startTime,
                          long endTime,
                          RecordClassDescriptor[] descriptors)
                   throws java.io.IOException

Throws:

java.io.IOException

Method Detail

startBatch

protected void startBatch(java.io.InputStream batchData)
                   throws java.io.IOException

Specified by:

startBatch in class deltix.util.s3.S3Reader<RawMessage>

Throws:

java.io.IOException

readNextRecord

protected RawMessage readNextRecord()

Specified by:

readNextRecord in class deltix.util.s3.S3Reader<RawMessage>

getDataFormat

protected java.lang.String getDataFormat()

Specified by:

getDataFormat in class deltix.util.s3.S3Reader<RawMessage>

getSpaceMetadata

public S3SpaceMetadata getSpaceMetadata()

isOldFormat

public boolean isOldFormat()

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Overrides:

close in class deltix.util.s3.S3Reader<RawMessage>

Throws:

java.io.IOException