Package deltix.qsrv.hf.tickdb.tool

Class S3Utils

java.lang.Object

deltix.qsrv.hf.tickdb.tool.S3Utils

public class S3Utils
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field	Description
static S3Utils	INSTANCE

Method Summary

Modifier and Type	Method	Description
static java.lang.String	getDataKey(DXTickStream stream, java.lang.String spaceId)
static java.lang.String	getDataKey(java.lang.String streamKey, java.lang.String spaceId)
static long	getFirstMessageTimestamp(deltix.util.s3.S3DataStore dataStore, java.lang.String dataKey, long startTime, long endTime, RecordClassDescriptor[] types)
static long	getMinTimestamp(deltix.util.s3.S3DataStore dataStore, java.lang.String[] dataKeys, long startTime, long endTime, RecordClassDescriptor[] types)
static java.lang.String	getSpaceFromDataKey(java.lang.String dataKey)
static java.lang.String[]	getSpaces(deltix.util.s3.S3DataStore dataStore, java.lang.String streamKey)
S3SpaceMetadata	parseMetadata(java.lang.String metadata)
java.lang.String	serializeMetadata(DXTickStream stream, java.lang.String space, long firstTimestamp)
java.lang.String	serializeMetadata(S3SpaceMetadata metadata)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static S3Utils INSTANCE

Method Detail

parseMetadata

public S3SpaceMetadata parseMetadata(java.lang.String metadata)

serializeMetadata

public java.lang.String serializeMetadata(S3SpaceMetadata metadata)

serializeMetadata

public java.lang.String serializeMetadata(DXTickStream stream,
                                          java.lang.String space,
                                          long firstTimestamp)

getDataKey

public static java.lang.String getDataKey(java.lang.String streamKey,
                                          java.lang.String spaceId)

getDataKey

public static java.lang.String getDataKey(DXTickStream stream,
                                          java.lang.String spaceId)

getSpaces

public static java.lang.String[] getSpaces(deltix.util.s3.S3DataStore dataStore,
                                           java.lang.String streamKey)

getSpaceFromDataKey

public static java.lang.String getSpaceFromDataKey(java.lang.String dataKey)

getFirstMessageTimestamp

public static long getFirstMessageTimestamp(deltix.util.s3.S3DataStore dataStore,
                                            java.lang.String dataKey,
                                            long startTime,
                                            long endTime,
                                            RecordClassDescriptor[] types)
                                     throws java.io.IOException

Throws:

java.io.IOException

getMinTimestamp

public static long getMinTimestamp(deltix.util.s3.S3DataStore dataStore,
                                   java.lang.String[] dataKeys,
                                   long startTime,
                                   long endTime,
                                   RecordClassDescriptor[] types)
                            throws java.io.IOException

Throws:

java.io.IOException