Namespace Org.Apache.Kafka.Streams.Kstream
Classes
- AggregatorDirect
Concrete CLR representation of Aggregator returned by the JVM.
- AggregatorDirect<K, V, VAgg>
Concrete CLR representation of Aggregator returned by the JVM.
- Aggregator<K, V, VAgg>
Listener for Kafka Aggregator. Extends JVMBridgeListener, implements IAggregator<K, V, VAgg>
- ForeachActionDirect
Concrete CLR representation of ForeachAction returned by the JVM.
- ForeachActionDirect<K, V>
Concrete CLR representation of ForeachAction returned by the JVM.
- ForeachAction<K, V>
Listener for Kafka ForeachAction. Extends JVMBridgeListener, implements IForeachAction<K, V>
- InitializerDirect
Concrete CLR representation of Initializer returned by the JVM.
- InitializerDirect<VAgg>
Concrete CLR representation of Initializer returned by the JVM.
- Initializer<VAgg>
Listener for Kafka Initializer. Extends JVMBridgeListener, implements IInitializer<VAgg>
- KeyValueMapperDirect
Concrete CLR representation of KeyValueMapper returned by the JVM.
- KeyValueMapperDirect<K, V, VR>
Concrete CLR representation of KeyValueMapper returned by the JVM.
- KeyValueMapper<K, V, VR>
Listener for Kafka KeyValueMapper. Extends JVMBridgeListener, implements IKeyValueMapper<K, V, VR>
- MergerDirect
Concrete CLR representation of Merger returned by the JVM.
- MergerDirect<K, V>
Concrete CLR representation of Merger returned by the JVM.
- Merger<K, V>
Listener for Kafka Merger. Extends JVMBridgeListener
- PredicateDirect
Concrete CLR representation of Predicate returned by the JVM.
- PredicateDirect<K, V>
Concrete CLR representation of Predicate returned by the JVM.
- Predicate<K, V>
Listener for Kafka Predicate. Extends JVMBridgeListener, implements IPredicate<K, V>
- ReducerDirect
Concrete CLR representation of Reducer returned by the JVM.
- ReducerDirect<V>
Concrete CLR representation of Reducer returned by the JVM.
- Reducer<V>
Listener for Kafka Reducer. Extends JVMBridgeListener, implements IReducer<V>
- TransformerDirect
Concrete CLR representation of Transformer returned by the JVM.
- TransformerDirect<K, V, R>
Concrete CLR representation of Transformer returned by the JVM.
- ValueJoinerDirect
Concrete CLR representation of ValueJoiner returned by the JVM.
- ValueJoinerDirect<V1, V2, VR>
Concrete CLR representation of ValueJoiner returned by the JVM.
- ValueJoinerWithKeyDirect
Concrete CLR representation of ValueJoinerWithKey returned by the JVM.
- ValueJoinerWithKeyDirect<K1, V1, V2, VR>
Concrete CLR representation of ValueJoinerWithKey returned by the JVM.
- 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
Concrete CLR representation of ValueMapper returned by the JVM.
- ValueMapperDirect<V, VR>
Concrete CLR representation of ValueMapper returned by the JVM.
- ValueMapperWithKeyDirect
Concrete CLR representation of ValueMapperWithKey returned by the JVM.
- ValueMapperWithKeyDirect<K, V, VR>
Concrete CLR representation of ValueMapperWithKey returned by the JVM.
- 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>
- ValueTransformerDirect
Concrete CLR representation of ValueTransformer returned by the JVM.
- ValueTransformerDirect<V, VR>
Concrete CLR representation of ValueTransformer returned by the JVM.
- ValueTransformerWithKeyDirect
Concrete CLR representation of ValueTransformerWithKey returned by the JVM.
- ValueTransformerWithKeyDirect<K, V, VR>
Concrete CLR representation of ValueTransformerWithKey returned by the JVM.
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.2.1/org/apache/kafka/streams/kstream/BranchedKStream.html
- ICogroupedKStream<K, VOut>
.NET interface skeleton to be manually developed following https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/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.2.1/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.2.1/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.2.1/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.2.1/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.2.1/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.2.1/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
- 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.2.1/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.2.1/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.2.1/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.2.1/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.2.1/org/apache/kafka/streams/kstream/TimeWindowedKStream.html
- ITransformer<K, V, R>
.NET interface for org.mases.knet.generated.org.apache.kafka.streams.kstream.Transformer implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/Transformer.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.2.1/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.2.1/org/apache/kafka/streams/kstream/ValueTransformerWithKey.html
- IValueTransformer<V, VR>
.NET interface for org.mases.knet.generated.org.apache.kafka.streams.kstream.ValueTransformer implementing https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/kstream/ValueTransformer.html