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

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TimePartitionSchema.PartitionInfo

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 TimePartitionSchema.PartitionInfo	getPartitionInfo(long instant) returns the directory where this instant shall be written.
abstract TimePartitionSchema.PartitionInfo	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 TimePartitionSchema.PartitionInfo 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 -

Returns:

parseDir

public abstract TimePartitionSchema.PartitionInfo 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.

Returns:

getInstance

public static TimePartitionSchema getInstance(String schema)

getName

public String getName()

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

Returns: