@Override
  public void remove(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);

    List<TimeSeriesKey<K>> keysToDelete = new LinkedList<>();

    KeyValueIterator<TimeSeriesKey<K>, V> range = kvStore.range(fromKey, toKey);
    try {
      while (range.hasNext()) {
        keysToDelete.add(range.next().getKey());
      }
    } finally {
      range.close();
    }
    kvStore.deleteAll(keysToDelete);
  }
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