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

Class PBPlainFileHandler

java.lang.Object

edu.stanford.slac.archiverappliance.plain.pb.PBPlainFileHandler

All Implemented Interfaces:

PlainFileHandler, PlainStreams

public class PBPlainFileHandler
extends Object
implements PlainFileHandler

Field Summary

Fields

Modifier and Type	Field	Description
static final String	PB_PLUGIN_IDENTIFIER
static final String	pbFileExtension
static int	SIZE_THAT_DETERMINES_A_SMALL_FILE

Fields inherited from interface edu.stanford.slac.archiverappliance.plain.PlainFileHandler

logger

Constructor Summary

Constructors

Constructor	Description
PBPlainFileHandler()

Method Summary

Modifier and Type	Method	Description
AppendDataStateData	appendDataStateData(Instant timestamp, PartitionGranularity partitionGranularity, String rootFolder, String desc, PVNameToKeyMapping pv2key)
boolean	backUpFiles(boolean backupFilesBeforeETL)
Event	dataAtTime(List<Path> pathList, String pvName, Instant atTime, Instant startAtTime, BiDirectionalIterable.IterationDirection direction)
void	dataDeleteTempFiles(BasicContext context, String pvName, String randSuffix, String rootFolder, PVNameToKeyMapping pv2key)
void	dataMovePaths(BasicContext context, String pvName, String randSuffix, String suffix, String rootFolder, PVNameToKeyMapping pv2key)
FileInfo	fileInfo(Path path)
Event	findByTime(List<Path> pathList, String pvName, Instant atTime, Instant startAtTime, BiDirectionalIterable.IterationDirection direction)
String	getPathKey(Path path)
PathResolver	getPathResolver()
EventStream	getStream(String pvName, Path path, ArchDBRTypes dbrType)
static EventStream	getStreamForIteration(String pvName, Path path, Instant startAtTime, ArchDBRTypes archDBRTypes, BiDirectionalIterable.IterationDirection direction)
EventStream	getTimeStream(String pvName, Path path, Instant start, Instant end, boolean skipSearch, FileInfo fileInfo)
EventStream	getTimeStream(String pvName, Path path, ArchDBRTypes dbrType, Instant start, Instant end, boolean skipSearch)
void	initCompression(Map<String,String> queryStrings)
void	markForDeletion(Path path)
ETLInfoListProcessor	optimisedETLInfoListProcessor(ETLDest etlDest)
String	pluginIdentifier()
String	rootFolderPath(String rootFolder)
String	toString()
String	updateRootFolderStr(String rootFolderStr)
Map<URLKey,String>	urlOptions()
boolean	useSearchForPositions()

Methods inherited from class java.lang.Object

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

Methods inherited from interface edu.stanford.slac.archiverappliance.plain.PlainFileHandler

getExtensionString

Field Details

PB_PLUGIN_IDENTIFIER

public static final String PB_PLUGIN_IDENTIFIER

See Also:

• Constant Field Values

pbFileExtension

public static final String pbFileExtension

See Also:

• Constant Field Values

SIZE_THAT_DETERMINES_A_SMALL_FILE

public static int SIZE_THAT_DETERMINES_A_SMALL_FILE

Constructor Details

PBPlainFileHandler

public PBPlainFileHandler()

Method Details

pluginIdentifier

public String pluginIdentifier()

Specified by:

pluginIdentifier in interface PlainFileHandler

getPathResolver

public PathResolver getPathResolver()

Specified by:

getPathResolver in interface PlainFileHandler

useSearchForPositions

public boolean useSearchForPositions()

Specified by:

useSearchForPositions in interface PlainFileHandler

rootFolderPath

public String rootFolderPath(String rootFolder)

Specified by:

rootFolderPath in interface PlainFileHandler

initCompression

public void initCompression(Map<String,String> queryStrings)

Specified by:

initCompression in interface PlainFileHandler

fileInfo

public FileInfo fileInfo(Path path)
                  throws IOException

Specified by:

fileInfo in interface PlainFileHandler

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

getTimeStream

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

Specified by:

getTimeStream in interface PlainStreams

Throws:

IOException

getTimeStream

public EventStream getTimeStream(String pvName,
 Path path,
 Instant start,
 Instant end,
 boolean skipSearch,
 FileInfo fileInfo)
                          throws IOException

Specified by:

getTimeStream in interface PlainStreams

Throws:

IOException

getStream

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

Specified by:

getStream in interface PlainStreams

Throws:

IOException

appendDataStateData

public AppendDataStateData appendDataStateData(Instant timestamp,
 PartitionGranularity partitionGranularity,
 String rootFolder,
 String desc,
 PVNameToKeyMapping pv2key)

Specified by:

appendDataStateData in interface PlainFileHandler

markForDeletion

public void markForDeletion(Path path)

Specified by:

markForDeletion in interface PlainFileHandler

dataMovePaths

public void dataMovePaths(BasicContext context,
 String pvName,
 String randSuffix,
 String suffix,
 String rootFolder,
 PVNameToKeyMapping pv2key)
                   throws IOException

Specified by:

dataMovePaths in interface PlainFileHandler

Throws:

IOException

dataDeleteTempFiles

public void dataDeleteTempFiles(BasicContext context,
 String pvName,
 String randSuffix,
 String rootFolder,
 PVNameToKeyMapping pv2key)
                         throws IOException

Specified by:

dataDeleteTempFiles in interface PlainFileHandler

Throws:

IOException

optimisedETLInfoListProcessor

public ETLInfoListProcessor optimisedETLInfoListProcessor(ETLDest etlDest)

Specified by:

optimisedETLInfoListProcessor in interface PlainFileHandler

findByTime

public Event findByTime(List<Path> pathList,
 String pvName,
 Instant atTime,
 Instant startAtTime,
 BiDirectionalIterable.IterationDirection direction)
                 throws IOException

Throws:

IOException

getStreamForIteration

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

Throws:

IOException

dataAtTime

public Event dataAtTime(List<Path> pathList,
 String pvName,
 Instant atTime,
 Instant startAtTime,
 BiDirectionalIterable.IterationDirection direction)
                 throws IOException

Specified by:

dataAtTime in interface PlainStreams

Throws:

IOException

updateRootFolderStr

public String updateRootFolderStr(String rootFolderStr)

Specified by:

updateRootFolderStr in interface PlainFileHandler

backUpFiles

public boolean backUpFiles(boolean backupFilesBeforeETL)

Specified by:

backUpFiles in interface PlainFileHandler

urlOptions

public Map<URLKey,String> urlOptions()

Specified by:

urlOptions in interface PlainFileHandler

getPathKey

public String getPathKey(Path path)

Specified by:

getPathKey in interface PlainFileHandler