@Override
  public ClosableIterator<TimestampedValue<V>> get(K key, long startTimestamp, long endTimestamp) {
    validateRange(startTimestamp, endTimestamp);
    TimeSeriesKey<K> fromKey = new TimeSeriesKey(key, startTimestamp, 0);
    TimeSeriesKey<K> toKey = new TimeSeriesKey(key, endTimestamp, 0);

    KeyValueIterator<TimeSeriesKey<K>, V> range = kvStore.range(fromKey, toKey);

    LOG.trace("Getting entries in the store for {} from {} to {}", new Object[] {key, startTimestamp, endTimestamp});
    return new TimeSeriesStoreIterator<>(range);
  }
Creates a {@link TimeSeriesStoreImpl} in append mode.

@param kvStore the backing kv store to use
samza-core/src/main/java/org/apache/samza/operators/impl/store/TimeSeriesStoreImpl.java