3f3e77f28b
This ports a useful workaround (the `transform` function) to JavaPairDStream. It is necessary to do things like sorting which are not supported yet in the core streaming API. |
||
---|---|---|
.. | ||
lib/org/apache/kafka/kafka | ||
src | ||
pom.xml |