Namespace MASES.KNet.Streams.Processor
Classes
- StreamPartitionerNoValue<K>
KNet implementation of StreamPartitionerNoValue<K, TJVMK>
- StreamPartitionerNoValue<K, TJVMK>
KNet implementation of StreamPartitioner<K, V, TJVMK, TJVMV>
- StreamPartitioner<K, V>
KNet implementation of StreamPartitioner<K, V, TJVMK, TJVMV>
- StreamPartitioner<K, V, TJVMK, TJVMV>
KNet implementation of StreamPartitioner<K, V>
- TimestampExtractor<K, V, TJVMK, TJVMV>
KNet extension of TimestampExtractor
- TopicNameExtractor<K, V>
KNet implementation of TopicNameExtractor<K, V>
- TopicNameExtractor<K, V, TJVMK, TJVMV>
KNet implementation of TopicNameExtractor<K, V>