@Override
    public void init(Context context) {
      this.statsStore =
          (KeyValueStore<String, StatsWindowState>) context.getTaskContext().getStore("my-stats-wnd-store");
    }
Example code using {@link KeyValueStore} to implement event-time window
samza-test/src/main/java/org/apache/samza/example/KeyValueStoreExample.java