All implementations of PortAndAssignment should implement the same equals() method.

All implementations of PortAndAssignment should implement the same equals() method.

{@inheritDoc}

{@inheritDoc} <p/> Keeps events with future ts in the queue for processing in the next window. If the ts difference is more than the lag, stops scanni

Callback when data is about to be removed from the cache. This method then immediately writes the metadata to RocksDB. @param key The evicted stri

Invoked by the framework for each trident tuple in a stream. @param input the input trident tuple @return an iterable over the resultant values

Invoked by the framework for each trident tuple in a stream. @param input the input trident tuple @return the transformed values