Hi, Shekar,
Sorry I was not able to follow up w/ you in time. It is great that you have
found the configure problem and made it work!
As for the exception on the iterator, could you send us the log w/ the
exception?
Thanks!
-Yi
On Thu, Jul 2, 2015 at 4:36 PM, Shekar Tippur <ctip...@gmail.com> wrote:
> Yi,
>
> Looks like it is working now. There was a redundant line in the config.
>
> I am able to initialize kv store and add values.
> In the window code, I am unable to retrieve them and mark them as 0.
>
> Here is my window code:
>
> public void window(MessageCollector collector,
>
> TaskCoordinator coordinator) {
>
> //store.delete(appName);
>
> collector.send(new OutgoingMessageEnvelope(OUTPUT_STREAM, eventsSeen));
>
> KeyValueIterator<String, String> i = store.all();
>
> while(i.hasNext()){
>
> Entry <String, String> next = i.next();
>
> log.info("Trying to remove Key", next.getKey());
>
> //i.remove();
>
>
>
> }
>
> eventsSeen = 0;
>
> i.close();
>
>
>
> }
>
>
> How do I retrieve the key and is there a way to remove it? i.remove throws
> an exception.
>
>
> - Shekar
>
> On Wed, Jul 1, 2015 at 7:25 PM, Shekar Tippur <ctip...@gmail.com> wrote:
>
> > Yi,
> >
> > Here is my config file:
> > http://pastebin.com/Kf3C9E0h
> >
> > - S
> >
>
