[ https://issues.apache.org/jira/browse/SAMZA-1423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jagadish updated SAMZA-1423: ---------------------------- Description: I'm thinking of the following API for the time-series store: {code} /** * A key-value store that allows entries to be queried and stored based on time ranges. * * Implementations of this interface are expected to be thread-safe. * * @param <K>, the type of key in the store * @param <V>, the type of value in the store */ public interface TimeSeriesStore<K, V> { ClosableIterator<KV<V, Long>> get(K key, Long startTimestamp, Long endTimeStamp); void put(K key, V val, Long timeStamp); void remove(K key, Long startTimestamp, Long endTimeStamp); } {code} > Implement a RocksDb backed time-series store for storing and retrieving > messages time-ranges > -------------------------------------------------------------------------------------------- > > Key: SAMZA-1423 > URL: https://issues.apache.org/jira/browse/SAMZA-1423 > Project: Samza > Issue Type: Sub-task > Reporter: Jagadish > Assignee: Jagadish > > I'm thinking of the following API for the time-series store: > {code} > /** > * A key-value store that allows entries to be queried and stored based on > time ranges. > * > * Implementations of this interface are expected to be thread-safe. > * > * @param <K>, the type of key in the store > * @param <V>, the type of value in the store > */ > public interface TimeSeriesStore<K, V> { > ClosableIterator<KV<V, Long>> get(K key, Long startTimestamp, Long > endTimeStamp); > void put(K key, V val, Long timeStamp); > void remove(K key, Long startTimestamp, Long endTimeStamp); > } > {code} -- This message was sent by Atlassian JIRA (v6.4.14#64029)