Table of Contents

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>

ValueMapperWithKey<K, V, VR>

KNet extension of ValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>

ValueMapperWithKey<K, V, VR, TJVMK, TJVMV, TJVMVR>

KNet extension of ValueMapperWithKey<K, V, 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>