Namespace Org.Apache.Kafka.Streams.Kstream
Classes
- AggregatorDirect
Direct override of Aggregator or its generic type if there is one
- AggregatorDirect<K, V, VAgg>
Direct override of Aggregator or its generic type if there is one
- Aggregator<K, V, VAgg>
Listener for Kafka Aggregator. Extends JVMBridgeListener, implements IAggregator<K, V, VAgg>
- ForeachActionDirect
Direct override of ForeachAction or its generic type if there is one
- ForeachActionDirect<K, V>
Direct override of ForeachAction or its generic type if there is one
- ForeachAction<K, V>
Listener for Kafka ForeachAction. Extends JVMBridgeListener, implements IForeachAction<K, V>
- InitializerDirect
Direct override of Initializer or its generic type if there is one
- InitializerDirect<VAgg>
Direct override of Initializer or its generic type if there is one
- Initializer<VAgg>
Listener for Kafka Initializer. Extends JVMBridgeListener, implements IInitializer<VAgg>
- KeyValueMapperDirect
Direct override of KeyValueMapper or its generic type if there is one
- KeyValueMapperDirect<K, V, VR>
Direct override of KeyValueMapper or its generic type if there is one
- KeyValueMapper<K, V, VR>
Listener for Kafka KeyValueMapper. Extends JVMBridgeListener, implements IKeyValueMapper<K, V, VR>
- MergerDirect
Direct override of Merger or its generic type if there is one
- MergerDirect<K, V>
Direct override of Merger or its generic type if there is one
- Merger<K, V>
Listener for Kafka Merger. Extends JVMBridgeListener
- NamedOperation
https://kafka.apache.org/34/javadoc/org/apache/kafka/streams/kstream/NamedOperation.html
- NamedOperation<T>
https://kafka.apache.org/34/javadoc/org/apache/kafka/streams/kstream/NamedOperation.html
- PredicateDirect
Direct override of Predicate or its generic type if there is one
- PredicateDirect<K, V>
Direct override of Predicate or its generic type if there is one
- Predicate<K, V>
Listener for Kafka Predicate. Extends JVMBridgeListener, implements IPredicate<K, V>
- ReducerDirect
Direct override of Reducer or its generic type if there is one
- ReducerDirect<V>
Direct override of Reducer or its generic type if there is one
- Reducer<V>
Listener for Kafka Reducer. Extends JVMBridgeListener, implements IReducer<V>
- ValueJoinerDirect
Direct override of ValueJoiner or its generic type if there is one
- ValueJoinerDirect<V1, V2, VR>
Direct override of ValueJoiner or its generic type if there is one
- ValueJoinerWithKeyDirect
Direct override of ValueJoinerWithKey or its generic type if there is one
- ValueJoinerWithKeyDirect<K1, V1, V2, VR>
Direct override of ValueJoinerWithKey or its generic type if there is one
- ValueJoinerWithKey<K1, V1, V2, VR>
Listener for Kafka ValueJoinerWithKey. Extends JVMBridgeListener, implements IValueJoinerWithKey<K1, V1, V2, VR>
- ValueJoiner<V1, V2, VR>
Listener for Kafka ValueJoiner. Extends JVMBridgeListener, implements IValueJoiner<V1, V2, VR>
- ValueMapperDirect
Direct override of ValueMapper or its generic type if there is one
- ValueMapperDirect<V, VR>
Direct override of ValueMapper or its generic type if there is one
- ValueMapperWithKeyDirect
Direct override of ValueMapperWithKey or its generic type if there is one
- ValueMapperWithKeyDirect<K, V, VR>
Direct override of ValueMapperWithKey or its generic type if there is one
- ValueMapperWithKey<K, V, VR>
Listener for Kafka ValueMapperWithKey. Extends JVMBridgeListener, implements IValueMapperWithKey<K, V, VR>
- ValueMapper<V, VR>
Listener for Kafka ValueMapper. Extends JVMBridgeListener, implements IValueMapper<V, VR>
- ValueTransformerWithKeyDirect
Direct override of ValueTransformerWithKey or its generic type if there is one
- ValueTransformerWithKeyDirect<K, V, VR>
Direct override of ValueTransformerWithKey or its generic type if there is one
Interfaces
- IAggregator<K, V, VAgg>
Listener for Kafka Aggregator. Extends IJVMBridgeBase
- IBranchedKStream<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/BranchedKStream.html
- ICogroupedKStream<K, VAgg>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/CogroupedKStream.html
- IEmitStrategy
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/EmitStrategy.html
- IForeachAction<K, V>
Listener for Kafka ForeachAction. Extends IJVMBridgeBase
- IGlobalKTable<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/GlobalKTable.html
- IInitializer<VAgg>
Listener for Kafka Initializer. Extends IJVMBridgeBase
- IKGroupedStream<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/KGroupedStream.html
- IKGroupedTable<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/KGroupedTable.html
- IKStream<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/KStream.html
- IKTable<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/KTable.html
- IKeyValueMapper<K, V, VR>
Listener for Kafka KeyValueMapper. Extends IJVMBridgeBase
- IMerger<K, V>
Listener for Kafka Merger. Extends IJVMBridgeBase
- INamedOperation<T>
https://kafka.apache.org/34/javadoc/org/apache/kafka/streams/kstream/NamedOperation.html
- IPredicate<K, V>
Listener for Kafka Predicate. Extends IJVMBridgeBase
- IReducer<V>
Listener for Kafka Reducer. Extends IJVMBridgeBase
- ISessionWindowedCogroupedKStream<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/SessionWindowedCogroupedKStream.html
- ISessionWindowedKStream<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/SessionWindowedKStream.html
- ISuppressed<K>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/Suppressed.html
- ITimeWindowedCogroupedKStream<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.html
- ITimeWindowedKStream<K, V>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/TimeWindowedKStream.html
- IValueJoinerWithKey<K1, V1, V2, VR>
Listener for Kafka ValueJoinerWithKey. Extends IJVMBridgeBase
- IValueJoiner<V1, V2, VR>
Listener for Kafka ValueJoiner. Extends IJVMBridgeBase
- IValueMapperWithKey<K, V, VR>
Listener for Kafka ValueMapperWithKey. Extends IJVMBridgeBase
- IValueMapper<V, VR>
Listener for Kafka ValueMapper. Extends IJVMBridgeBase
- IValueTransformerWithKeySupplier<K, V, VR>
.NET interface for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.html
- IValueTransformerWithKey<K, V, VR>
.NET interface for org.mases.knet.generated.org.apache.kafka.streams.kstream.ValueTransformerWithKey implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/kstream/ValueTransformerWithKey.html