Package edu.stanford.slac.archiverappliance.PlainPB

Class FileStreamCreator

java.lang.Object

edu.stanford.slac.archiverappliance.PlainPB.FileStreamCreator

All Implemented Interfaces:

ETLStreamCreator

public class FileStreamCreator
extends Object
implements ETLStreamCreator

A stream creator that is backed by a single file.

Author:

mshankar

Constructor Summary

Constructors

Constructor	Description
FileStreamCreator(String pvName, Path path, PBFileInfo fileinfo)

Method Summary

Modifier and Type	Method	Description
EventStream	getStream()
static EventStream	getStream(String pvName, Path path, ArchDBRTypes dbrType)
static EventStream	getStreamForIteration(String pvName, Path path, Instant startAtTime, ArchDBRTypes archDBRTypes, BiDirectionalIterable.IterationDirection direction)
static EventStream	getTimeStream(String pvName, Path path, Instant start, Instant end, boolean skipSearch, ArchDBRTypes archDBRTypes)
static EventStream	getTimeStream(String pvName, Path path, ArchDBRTypes dbrType, Instant start, Instant end, boolean skipSearch)

Methods inherited from class java.lang.Object

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

Constructor Details

FileStreamCreator

public FileStreamCreator(String pvName,
 Path path,
 PBFileInfo fileinfo)

Method Details

getTimeStream

public static EventStream getTimeStream(String pvName,
 Path path,
 ArchDBRTypes dbrType,
 Instant start,
 Instant end,
 boolean skipSearch)
                                 throws IOException

Throws:

IOException

getTimeStream

public static EventStream getTimeStream(String pvName,
 Path path,
 Instant start,
 Instant end,
 boolean skipSearch,
 ArchDBRTypes archDBRTypes)
                                 throws IOException

Throws:

IOException

getStream

public static EventStream getStream(String pvName,
 Path path,
 ArchDBRTypes dbrType)
                             throws IOException

Throws:

IOException

getStreamForIteration

public static EventStream getStreamForIteration(String pvName,
 Path path,
 Instant startAtTime,
 ArchDBRTypes archDBRTypes,
 BiDirectionalIterable.IterationDirection direction)
                                         throws IOException

Throws:

IOException

getStream

public EventStream getStream()
                      throws IOException

Specified by:

getStream in interface ETLStreamCreator

Throws:

IOException