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 MASES.JCOBridge.C2JBridge.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 MASES.JCOBridge.C2JBridge.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 MASES.JCOBridge.C2JBridge.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 MASES.JCOBridge.C2JBridge.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 MASES.JCOBridge.C2JBridge.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 MASES.JCOBridge.C2JBridge.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 MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IReducer<V>
- TransformerDirect
Direct override of Transformer or its generic type if there is one
- TransformerDirect<K, V, R>
Direct override of Transformer or its generic type if there is one
- 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 MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IValueJoinerWithKey<K1, V1, V2, VR>
- ValueJoiner<V1, V2, VR>
Listener for Kafka ValueJoiner. Extends MASES.JCOBridge.C2JBridge.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 MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IValueMapperWithKey<K, V, VR>
- ValueMapper<V, VR>
Listener for Kafka ValueMapper. Extends MASES.JCOBridge.C2JBridge.JVMBridgeListener, implements IValueMapper<V, VR>
- ValueTransformerDirect
Direct override of ValueTransformer or its generic type if there is one
- ValueTransformerDirect<V, VR>
Direct override of ValueTransformer or its generic type if there is one
- 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 MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IBranchedKStream<K, V>
.NET interface for TO BE DEFINED FROM USER
- ICogroupedKStream<K, VAgg>
.NET interface for TO BE DEFINED FROM USER
- IEmitStrategy
.NET interface for TO BE DEFINED FROM USER
- IForeachAction<K, V>
Listener for Kafka ForeachAction. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IGlobalKTable<K, V>
.NET interface for TO BE DEFINED FROM USER
- IInitializer<VAgg>
Listener for Kafka Initializer. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IKGroupedStream<K, V>
.NET interface for TO BE DEFINED FROM USER
- IKGroupedTable<K, V>
.NET interface for TO BE DEFINED FROM USER
- IKStream<K, V>
.NET interface for TO BE DEFINED FROM USER
- IKTable<K, V>
.NET interface for TO BE DEFINED FROM USER
- IKeyValueMapper<K, V, VR>
Listener for Kafka KeyValueMapper. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IMerger<K, V>
Listener for Kafka Merger. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- INamedOperation<T>
https://kafka.apache.org/34/javadoc/org/apache/kafka/streams/kstream/NamedOperation.html
- IPredicate<K, V>
Listener for Kafka Predicate. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IReducer<V>
Listener for Kafka Reducer. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- ISessionWindowedCogroupedKStream<K, V>
.NET interface for TO BE DEFINED FROM USER
- ISessionWindowedKStream<K, V>
.NET interface for TO BE DEFINED FROM USER
- ISuppressed<K>
.NET interface for TO BE DEFINED FROM USER
- ITimeWindowedCogroupedKStream<K, V>
.NET interface for TO BE DEFINED FROM USER
- ITimeWindowedKStream<K, V>
.NET interface for TO BE DEFINED FROM USER
- ITransformerSupplier<K, V, R>
.NET interface for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/TransformerSupplier.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/3.9.0/org/apache/kafka/streams/kstream/Transformer.html
- IValueJoinerWithKey<K1, V1, V2, VR>
Listener for Kafka ValueJoinerWithKey. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IValueJoiner<V1, V2, VR>
Listener for Kafka ValueJoiner. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IValueMapperWithKey<K, V, VR>
Listener for Kafka ValueMapperWithKey. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IValueMapper<V, VR>
Listener for Kafka ValueMapper. Extends MASES.JCOBridge.C2JBridge.IJVMBridgeBase
- IValueTransformerSupplier<V, VR>
.NET interface for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.1/org/apache/kafka/streams/kstream/ValueTransformerSupplier.html
- IValueTransformerWithKeySupplier<K, V, VR>
.NET interface for https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/3.7.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/3.9.0/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/3.9.0/org/apache/kafka/streams/kstream/ValueTransformer.html