org.yamcs.yarch

Class TimePartitionSchema

java.lang.Object

org.yamcs.yarch.TimePartitionSchema

public abstract class TimePartitionSchema
extends Object

Implements different schemes for partitioning by time. It gives back a partition start/end and a directory where data shall be stored. Currently the following are implemented: YYYY/DOY YYYY/MM

Author:

nm

Constructor Summary

Constructors

Constructor and Description
TimePartitionSchema()

Method Summary

Modifier and Type	Method and Description
static TimePartitionSchema	getInstance(String schema)
String	getName() name for the partitioning schema (YYYY/DOY, YYYY/MM, etc)
abstract TimePartitionInfo	getPartitionInfo(long instant) returns the directory where this instant shall be written.
abstract TimePartitionInfo	parseDir(String dir) Parses a string of the shape "A/B/..." into a PartitionInfo.

Methods inherited from class java.lang.Object

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

Constructor Detail

TimePartitionSchema

public TimePartitionSchema()

Method Detail

getPartitionInfo

public abstract TimePartitionInfo getPartitionInfo(long instant)

returns the directory where this instant shall be written. This is likely to be expensive operation - since instant has to be converted into a calendar taking into accounts leap seconds and all the rest.

Parameters:

instant -

parseDir

public abstract TimePartitionInfo parseDir(String dir)

Parses a string of the shape "A/B/..." into a PartitionInfo. It is used by the storage engines to parse the partitions from disk at startup. Returns null if the given string does not match the expected directory.

getInstance

public static TimePartitionSchema getInstance(String schema)

getName

public String getName()

name for the partitioning schema (YYYY/DOY, YYYY/MM, etc)

Returns:

the name of the partitioning schema