Class StreamPartitionerNoValue<K, TJVMK>
KNet implementation of StreamPartitioner<K, V, TJVMK, TJVMV>
public class StreamPartitionerNoValue<K, TJVMK> : StreamPartitioner<K, string, TJVMK, Void>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IStreamPartitioner<TJVMK, Void>, IJVMBridgeBase, IJVMBridgeDefinition, IGenericSerDesFactoryApplierType Parameters
KThe key type
TJVMKThe JVM type of
K
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<JVMBridgeListener>JVMBridgeListenerStreamPartitioner<TJVMK, Void>StreamPartitionerNoValue<K, TJVMK>
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIStreamPartitioner<TJVMK, Void>IJVMBridgeBaseIJVMBridgeDefinition
- Derived
- Inherited Members
-
JVMBridgeListener.Dispose()JVMBridgeListener.BridgeClassNameJVMBridgeListener.AutoInitJVMBridgeListener.IsBridgeStaticJVMBridgeListener.IsBridgeCloseableJVMBridgeListener.IsBridgeListenerJVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])JVMBridgeBase<JVMBridgeListener>.DynBridgeClazzJVMBridgeBase<JVMBridgeListener>.BridgeClazzJVMBridgeBase.RuntimeClassNameOf<T>()JVMBridgeBase.ClassNameOf<T>()JVMBridgeBase.ClassOf<T>()JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)JVMBridgeBase.MonitorEnter()JVMBridgeBase.MonitorExit()JVMBridgeBase.IsInstanceOf(IJavaType)JVMBridgeBase.IsInstanceOf<T>()JVMBridgeBase.RuntimeIsInstanceOf<T>()JVMBridgeBase.CastTo<TNewClass>()JVMBridgeBase.CastDirect<TNewClass>()JVMBridgeBase.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeInterfaceJVMBridgeBase.IsBridgeAbstract
Properties
Key
The K content
public override K Key { get; }Property Value
- K
NumPartitions
The total number of partitions
public override int NumPartitions { get; }Property Value
OnPartitions
public Func<string, K, int, ICollection<int?>> OnPartitions { get; set; }Property Value
- Func<string, K, int, ICollection<int?>>
Remarks
If OnPartitions has a value it takes precedence over corresponding class method
Topic
The topic name this record is sent to
public override string Topic { get; }Property Value
Value
The string content
public override string Value { get; }Property Value
Methods
Partitions(String, TJVMK, Void, int)
public override Optional<Set<Integer>> Partitions(String arg0, TJVMK arg1, Void arg2, int arg3)Parameters
Returns
Remarks
The method invokes the default implementation in the JVM interface using PartitionsDefault(String, K, V, int); override the method to implement a different behavior
Partitions(string, K, int)
public virtual ICollection<int?> Partitions(string arg0, K arg1, int arg2)Parameters
arg0stringThe topic name this record is sent to
arg1KThe key of the record
arg2intThe total number of partitions
Returns
- ICollection<int?>
An Optional of Set of Integers between 0 and numPartitions-1, Empty optional means using default partitioner Optional of an empty set means the record won't be sent to any partitions i.e drop it. Optional of Set of integers means the partitions to which the record should be sent to.