Table of Contents

Class KNetShareConsumer<K, V>

Namespace
MASES.KNet.Consumer
Assembly
MASES.KNet.dll

Extends KNetShareConsumer<K, V, TJVMK, TJVMV> using array of byte

public class KNetShareConsumer<K, V> : KNetShareConsumer<K, V, byte[], byte[]>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IShareConsumer<K, V, byte[], byte[]>, IShareConsumer<byte[], byte[]>, ICloseable, IAutoCloseable

Type Parameters

K

The key type

V

The value type

Inheritance
KNetShareConsumer<K, V>
Implements
Inherited Members

Constructors

KNetShareConsumer(ConsumerConfigBuilder, ISerDes<K, byte[]>, ISerDes<V, byte[]>, bool)

Initialize a new instance of KNetShareConsumer<K, V, TJVMK, TJVMV>

public KNetShareConsumer(ConsumerConfigBuilder props, ISerDes<K, byte[]> keyDeserializer, ISerDes<V, byte[]> valueDeserializer, bool useJVMCallback = false)

Parameters

props ConsumerConfigBuilder

The properties to use, see ConsumerConfigBuilder

keyDeserializer ISerDes<K, byte[]>

Key serializer base on SerDes<T, TJVMT>

valueDeserializer ISerDes<V, byte[]>

Value serializer base on SerDes<T, TJVMT>

useJVMCallback bool

true to active callback based mode

KNetShareConsumer(ConsumerConfigBuilder, bool)

Initialize a new instance of KNetShareConsumer<K, V, TJVMK, TJVMV>

public KNetShareConsumer(ConsumerConfigBuilder configBuilder, bool useJVMCallback = false)

Parameters

configBuilder ConsumerConfigBuilder

An instance of ConsumerConfigBuilder

useJVMCallback bool

true to active callback based mode

Edit this page