Package edu.stanford.slac.archiverappliance.plain.pb

Class LineByteStreamCreator

java.lang.Object

edu.stanford.slac.archiverappliance.plain.pb.LineByteStreamCreator

public class LineByteStreamCreator
extends Object

When using a MultiFileEventStream on a HOUR granularity, we could potentially run into "too many open files" issues. So we add a level of indirection for this case.

Author:

mshankar

Constructor Summary

Constructors

Constructor	Description
LineByteStreamCreator(LineByteStream lis, String pvName, ArchDBRTypes type)	In this case we get a correctly positioned LIS
LineByteStreamCreator(Path path, String pvName, ArchDBRTypes type)	In this case, we get a whole file We need to position the lis past the header before returning.

Method Summary

Modifier and Type	Method	Description
LineByteStream	getLineByteStream()
void	safeClose()

Methods inherited from class java.lang.Object

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

Constructor Details

LineByteStreamCreator

public LineByteStreamCreator(LineByteStream lis,
 String pvName,
 ArchDBRTypes type)

In this case we get a correctly positioned LIS

Parameters:

lis - The line bytes stream

pvName - the PV name

type - Enum ArchDBRTypes

LineByteStreamCreator

public LineByteStreamCreator(Path path,
 String pvName,
 ArchDBRTypes type)

In this case, we get a whole file We need to position the lis past the header before returning.

Parameters:

path - Path

pvName - The PV name

type - Enum ArchDBRTypes

Method Details

getLineByteStream

public LineByteStream getLineByteStream()
                                 throws IOException

Throws:

IOException

safeClose

public void safeClose()