Namespace MASES.KNet.Streams.Kstream
Classes
- Aggregator<K, V, VA>
KNet implementation of Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>
- Aggregator<K, V, VA, TJVMK, TJVMV, TJVMVA>
KNet implementation of Aggregator<K, V, VAgg>
- BranchedKStream<K, V, TJVMK, TJVMV>
KNet extension of BranchedKStream<K, V>
- Branched<K, V, TJVMK, TJVMV>
KNet extension of Branched<K, V>
- CogroupedKStream<K, VOut, TJVMK, TJVMVOut>
KNet extension of CogroupedKStream<K, VAgg>
- Consumed<K, V, TJVMK, TJVMV>
KNet extension of Consumed<K, V>
- CountingMaterialized<K, TJVMK>
KNet extension of Materialized<K, V, TJVMK, TJVMV, TContainer>
- EnumerableKeyValueMapper<K, V, KR, VR>
KNet extension of EnumerableKeyValueMapper<K, V, KR, VR, TJVMK, TJVMV, TJVMKR, TJVMVR>
- EnumerableKeyValueMapper<K, V, KR, VR, TJVMK, TJVMV, TJVMKR, TJVMVR>
KNet extension of KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>
- EnumerableValueMapperWithKey<K, V, VR>
KNet extension of EnumerableValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>
- EnumerableValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>
KNet extension of ValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>
- EnumerableValueMapper<V, VR>
KNet extension of EnumerableValueMapper<V, VR, TJVMV, TJVMVR>
- EnumerableValueMapper<V, VR, TJVMV, TJVMVR>
KNet extension of ValueMapper<V, VR, TJVMV, TJVMVR>
- ForeachAction<K, V>
KNet extension of ForeachAction<K, V, TJVMK, TJVMV>
- ForeachAction<K, V, TJVMK, TJVMV>
KNet extension of ForeachAction<K, V>
- GlobalKTable<K, V, TJVMK, TJVMV>
KNet extension of GlobalKTable<K, V>
- Grouped<K, V>
KNet extension of Grouped<K, V, TJVMK, TJVMV>
- Grouped<K, V, TJVMK, TJVMV>
KNet extension of Grouped<K, V>
- Initializer<VA>
KNet implementation of Initializer<VAgg>
- Initializer<VA, TJVMVA>
KNet implementation of Initializer<VAgg>
- Joined<K, V, VO>
KNet extension of Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>
- Joined<K, V, VO, TJVMK, TJVMV, TJVMVO>
KNet extension of Joined<K, V, VO>
- KGroupedStream<K, V, TJVMK, TJVMV>
KNet extension of KGroupedStream<K, V>
- KGroupedTable<K, V, TJVMK, TJVMV>
KNet extension of KGroupedTable<K, V>
- KStream<K, V, TJVMK, TJVMV>
KNet extension of KStream<K, V>
- KTable<K, V, TJVMK, TJVMV>
KNet extension of KTable<K, V>
- KeyValueKeyValueMapper<K, V, KR, VR>
KNet extension of KeyValueKeyValueMapper<K, V, KR, VR, TJVMK, TJVMV, TJVMKR, TJVMVR>
- KeyValueKeyValueMapper<K, V, KR, VR, TJVMK, TJVMV, TJVMKR, TJVMVR>
KNet extension of KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>
- KeyValueMapperForString<K, V>
KNet extension of KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>
- KeyValueMapperForString<K, V, TJVMK, TJVMV>
KNet extension of KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>
- KeyValueMapper<K, V, VR>
KNet extension of KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>
- KeyValueMapper<K, V, VR, TJVMK, TJVMV, TJVMVR>
KNet extension of KeyValueMapper<K, V, VR>
- Materialized<K, V, TJVMK>
KNet extension of Materialized<K, V, TJVMK, TJVMV, TContainer>
- Materialized<K, V, TJVMK, TJVMV>
KNet extension of Materialized<K, V, TJVMK, TJVMV, TContainer>
- Materialized<K, V, TJVMK, TJVMV, TContainer>
KNet base extension of Materialized<K, V, S>
- Merger<K, V>
KNet extension of Merger<K, V, TJVMK, TJVMV>
- Merger<K, V, TJVMK, TJVMV>
KNet extension of Merger<K, V>
- PredicateEqualityTest<TKey, TValue>
KNet extension of Predicate<K, V> to execute Test(K, V) directly in the JVM
- Predicate<K, V>
KNet implementation of Predicate<K, V, TJVMK, TJVMV>
- Predicate<K, V, TJVMK, TJVMV>
KNet implementation of Predicate<K, V>
- Printed<K, V>
KNet extension of Printed<K, V, TJVMK, TJVMV>
- Printed<K, V, TJVMK, TJVMV>
KNet extension of Printed<K, V>
- Produced<K, V>
KNet extension of Produced<K, V, TJVMK, TJVMV>
- Produced<K, V, TJVMK, TJVMV>
KNet extension of Produced<K, V>
- Reducer<V>
KNet extension of Reducer<V, TJVMV>
- Reducer<V, TJVMV>
KNet extension of Reducer<V>
- Repartitioned<K, V, TJVMK, TJVMV>
KNet extension of Produced<K, V>
- SessionWindowedCogroupedKStream<K, V, TJVMK, TJVMV>
KNet extension of SessionWindowedCogroupedKStream<K, V>
- SessionWindowedKStream<K, V, TJVMK, TJVMV>
KNet extension of SessionWindowedKStream<K, V>
- StreamJoined<K, V1, V2, TJVMK, TJVMV1, TJVMV2>
KNet extension of StreamJoined<K, V1, V2>
- Suppressed<K>
KNet extension of Suppressed<K, TJVMK>
- Suppressed<K, TJVMK>
KNet extension of Suppressed<K>
- TableJoined<K, KO>
KNet extension of TableJoined<K, KO>
- TableJoined<K, KO, TJVMK, TJVMKO>
KNet extension of TableJoined<K, KO>
- TimeWindowedCogroupedKStream<K, V, TJVMK, TJVMV>
KNet extension of TimeWindowedCogroupedKStream<K, V>
- TimeWindowedKStream<K, V, TJVMK, TJVMV>
KNet extension of TimeWindowedKStream<K, V>
- ValueJoinerWithKey<K1, V1, V2, VR>
KNet extension of ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
- ValueJoinerWithKey<K1, V1, V2, VR, TJVMK1, TJVMV1, TJVMV2, TJVMVR>
KNet extension of ValueJoinerWithKey<K1, V1, V2, VR>
- ValueJoiner<V1, V2, VR>
KNet extension of ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>
- ValueJoiner<V1, V2, VR, TJVMV1, TJVMV2, TJVMVR>
KNet extension of ValueJoiner<V1, V2, VR>
- ValueMapper<V, VR>
KNet extension of ValueMapper<V, VR>
- ValueMapper<V, VR, TJVMV, TJVMVR>
KNet extension of ValueMapper<V, VR>
- Windowed<K, TJVMK>
KNet implementation of Windowed<K>
Interfaces
- IKNetMaterialized<TJVMK, TJVMV>
Supporting interface for Materialized<K, V, TJVMK, TJVMV, TContainer>