Package deltix.qsrv.hf.stream

Class MessageSorter

java.lang.Object

deltix.qsrv.hf.stream.MessageSorter

All Implemented Interfaces:

deltix.util.lang.Disposable, java.io.Closeable, java.lang.AutoCloseable

public class MessageSorter
extends java.lang.Object
implements deltix.util.lang.Disposable

Constructor Summary

Constructors

Constructor	Description
MessageSorter(long memSize, TypeLoader typeLoader, RecordClassDescriptor... descriptors)
MessageSorter(long memSize, java.io.File tmpDir, TypeLoader typeLoader, RecordClassDescriptor... descriptors)
MessageSorter(java.io.File tmpDir, TypeLoader typeLoader, RecordClassDescriptor... descriptors)

Method Summary

Modifier and Type	Method	Description
void	add(deltix.qsrv.hf.pub.InstrumentMessage msg)
void	close()
deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage>	finish()
deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage>	finish(TypeLoader bindLoader)
deltix.util.io.TeraByteOutputStream	getBuffer()
long	getBufferSize()
java.io.File	getTmpFile()
long	getTotalNumMessages()
static long	halfAvailableMemory()

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageSorter

public MessageSorter(java.io.File tmpDir,
                     TypeLoader typeLoader,
                     RecordClassDescriptor... descriptors)

MessageSorter

public MessageSorter(long memSize,
                     TypeLoader typeLoader,
                     RecordClassDescriptor... descriptors)

MessageSorter

public MessageSorter(long memSize,
                     java.io.File tmpDir,
                     TypeLoader typeLoader,
                     RecordClassDescriptor... descriptors)

Method Detail

halfAvailableMemory

public static long halfAvailableMemory()

add

public void add(deltix.qsrv.hf.pub.InstrumentMessage msg)
         throws java.io.IOException

Throws:

java.io.IOException

getTotalNumMessages

public long getTotalNumMessages()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface deltix.util.lang.Disposable

finish

public deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage> finish()
                                                                              throws java.io.IOException

Throws:

java.io.IOException

finish

public deltix.data.stream.MessageSource<deltix.qsrv.hf.pub.InstrumentMessage> finish(TypeLoader bindLoader)
                                                                              throws java.io.IOException

Throws:

java.io.IOException

getBuffer

public deltix.util.io.TeraByteOutputStream getBuffer()

getBufferSize

public long getBufferSize()

getTmpFile

public java.io.File getTmpFile()