Package edu.stanford.slac.archiverappliance.plain

Interface PlainFileHandler

All Superinterfaces:

PlainStreams

All Known Implementing Classes:

ParquetPlainFileHandler, PBPlainFileHandler

public interface PlainFileHandler
extends PlainStreams

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.logging.log4j.Logger	logger

Method Summary

Modifier and Type	Method	Description
AppendDataStateData	appendDataStateData(Instant timestamp, PartitionGranularity partitionGranularity, String rootFolder, String desc, PVNameToKeyMapping pv2key)
boolean	backUpFiles(boolean backupFilesBeforeETL)
EventFileWriter	createEventFileWriter(String pvName, Path path, ArchDBRTypes type, short year)
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)
static void	deleteTempFiles(BasicContext context, String pvName, String randSuffix, String rootFolder, PathResolver pathResolver, PVNameToKeyMapping pv2key)
FileInfo	fileInfo(Path path)
default String	getExtensionString()
String	getPathKey(Path path)
default PathResolver	getPathResolver()
void	initCompression(Map<String,String> queryStrings)
void	markForDeletion(Path path)
static void	movePaths(BasicContext context, String pvName, String randSuffix, String suffix, String rootFolder, PathResolver pathResolver, PVNameToKeyMapping pv2key)
ETLInfoListProcessor	optimisedETLInfoListProcessor(ETLDest etlDest)
String	pluginIdentifier()
default String	rootFolderPath(String rootFolder)
String	updateRootFolderStr(String rootFolderStr)
Map<URLKey,String>	urlOptions()
default boolean	useSearchForPositions()

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

dataAtTime, getStream, getTimeStream, getTimeStream

Field Details

logger

static final org.apache.logging.log4j.Logger logger

Method Details

pluginIdentifier

String pluginIdentifier()

getPathResolver

default PathResolver getPathResolver()

getExtensionString

default String getExtensionString()

useSearchForPositions

default boolean useSearchForPositions()

rootFolderPath

default String rootFolderPath(String rootFolder)

initCompression

void initCompression(Map<String,String> queryStrings)

fileInfo

FileInfo fileInfo(Path path)
           throws IOException

Throws:

IOException

appendDataStateData

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

createEventFileWriter

EventFileWriter createEventFileWriter(String pvName,
 Path path,
 ArchDBRTypes type,
 short year)
                               throws IOException

Throws:

IOException

markForDeletion

void markForDeletion(Path path)
              throws IOException

Throws:

IOException

movePaths

static void movePaths(BasicContext context,
 String pvName,
 String randSuffix,
 String suffix,
 String rootFolder,
 PathResolver pathResolver,
 PVNameToKeyMapping pv2key)
               throws IOException

Throws:

IOException

deleteTempFiles

static void deleteTempFiles(BasicContext context,
 String pvName,
 String randSuffix,
 String rootFolder,
 PathResolver pathResolver,
 PVNameToKeyMapping pv2key)
                     throws IOException

Throws:

IOException

dataMovePaths

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

Throws:

IOException

dataDeleteTempFiles

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

Throws:

IOException

optimisedETLInfoListProcessor

ETLInfoListProcessor optimisedETLInfoListProcessor(ETLDest etlDest)

updateRootFolderStr

String updateRootFolderStr(String rootFolderStr)

backUpFiles

boolean backUpFiles(boolean backupFilesBeforeETL)

urlOptions

Map<URLKey,String> urlOptions()

getPathKey

String getPathKey(Path path)