public interface TSData extends Collection<TimeSeriesCollection>, CollectHistory
CollectHistory.ApplyExpressions, CollectHistory.NamedEvaluation| Modifier and Type | Method and Description |
|---|---|
boolean |
add(TimeSeriesCollection tsv) |
default boolean |
addAll(Collection<? extends TimeSeriesCollection> c) |
default ColumnMajorTSData |
asColumnMajorTSData()
Returns the data in column major format.
|
boolean |
canAddSingleRecord()
Returns true if the file is suitable for adding single records at a time.
|
default void |
clear()
Unsupported.
|
default boolean |
contains(Object o)
Test if the TSData contains the given value.
|
default boolean |
containsAll(Collection<?> c)
Test if the TSData contains all the given values.
|
Compression |
getAppendCompression()
Get the compression used for append files.
|
org.joda.time.DateTime |
getBegin()
Get the lowest timestamp covered by this TSData series.
|
org.joda.time.DateTime |
getEnd()
Get the highest timestamp covered by this TSData series.
|
Optional<GCCloseable<FileChannel>> |
getFileChannel()
Return the file channel used to read this file, if it is uses a file
descriptor.
|
long |
getFileSize()
Retrieve the filesize used by the TSData.
|
short |
getMajor()
Returns the major version of the TSData file.
|
short |
getMinor()
Returns the minor version of the TSData file.
|
Compression |
getOptimizedCompression()
Get the compression used for optimized files.
|
boolean |
isEmpty()
Test if the TSData is empty.
|
boolean |
isOptimized()
Returns true if the file is optimized for access by (GroupPath, Tags,
MetricName) tuple.
|
Iterator<TimeSeriesCollection> |
iterator()
Returns an iterator for this TSData.
|
static SequenceTSData |
readonly(Path file)
Open the given TSData file.
|
default boolean |
remove(Object o)
Unsupported.
|
default boolean |
removeAll(Collection<?> c)
Unsupported.
|
default boolean |
removeIf(Predicate<? super TimeSeriesCollection> p)
Unsupported.
|
default boolean |
retainAll(Collection<?> c)
Unsupported.
|
void |
setAppendCompression(Compression compression)
Set the compression used for append files.
|
void |
setOptimizedCompression(Compression compression)
Set the compression used for optimized files.
|
int |
size()
Returns the number of entries in the TSData.
|
default Spliterator<TimeSeriesCollection> |
spliterator()
Returns an iterator for this TSData.
|
default Stream<TimeSeriesCollection> |
stream()
Stream the TSData contents.
|
default Stream<TimeSeriesCollection> |
streamReversed()
Stream the TSData contents in reverse chronological order.
|
default Object[] |
toArray() |
default <T> T[] |
toArray(T[] a) |
equals, hashCode, parallelStreamaddAll, evaluate, evaluate, evaluate, getContext, getContext, getContext, stream, stream, stream, stream, stream, streamGrouporg.joda.time.DateTime getBegin()
org.joda.time.DateTime getEnd()
getEnd in interface CollectHistorylong getFileSize()
getFileSize in interface CollectHistoryCompression getAppendCompression()
void setAppendCompression(Compression compression)
compression - The compression used for append files.Compression getOptimizedCompression()
void setOptimizedCompression(Compression compression)
compression - The compression used for optimized files.short getMajor()
short getMinor()
boolean canAddSingleRecord()
boolean isOptimized()
Iterator<TimeSeriesCollection> iterator()
iterator in interface Collection<TimeSeriesCollection>iterator in interface Iterable<TimeSeriesCollection>default Spliterator<TimeSeriesCollection> spliterator()
spliterator in interface Collection<TimeSeriesCollection>spliterator in interface Iterable<TimeSeriesCollection>default Stream<TimeSeriesCollection> stream()
stream in interface CollectHistorystream in interface Collection<TimeSeriesCollection>default Stream<TimeSeriesCollection> streamReversed()
streamReversed in interface CollectHistoryboolean isEmpty()
isEmpty in interface Collection<TimeSeriesCollection>int size()
size in interface Collection<TimeSeriesCollection>default boolean contains(Object o)
contains in interface Collection<TimeSeriesCollection>default boolean containsAll(Collection<?> c)
containsAll in interface Collection<TimeSeriesCollection>default Object[] toArray()
toArray in interface Collection<TimeSeriesCollection>default <T> T[] toArray(T[] a)
toArray in interface Collection<TimeSeriesCollection>boolean add(TimeSeriesCollection tsv)
add in interface CollectHistoryadd in interface Collection<TimeSeriesCollection>default boolean addAll(Collection<? extends TimeSeriesCollection> c)
addAll in interface CollectHistoryaddAll in interface Collection<TimeSeriesCollection>default void clear()
clear in interface Collection<TimeSeriesCollection>default boolean retainAll(Collection<?> c)
retainAll in interface Collection<TimeSeriesCollection>default boolean removeAll(Collection<?> c)
removeAll in interface Collection<TimeSeriesCollection>default boolean remove(Object o)
remove in interface Collection<TimeSeriesCollection>default boolean removeIf(Predicate<? super TimeSeriesCollection> p)
removeIf in interface Collection<TimeSeriesCollection>static SequenceTSData readonly(Path file) throws IOException
file - The file to open.IOException - If an IOException occurs, the file is not a valid
TSData file or the version of the file is too new.Optional<GCCloseable<FileChannel>> getFileChannel()
default ColumnMajorTSData asColumnMajorTSData() throws IOException
IOException - if IO errors prevent the computation from
succeeding.Copyright © 2017. All rights reserved.