Class Partitioner
public class Partitioner : JVMBridgeListener, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IPartitioner, IConfigurable, ICloseable, IAutoCloseable
- Inheritance
-
Partitioner
- Implements
- Derived
- Inherited Members
Constructors
Partitioner()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public Partitioner()
Partitioner(params object[])
Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
public Partitioner(params object[] args)
Parameters
args
object[]
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }
Property Value
OnClose
public Action OnClose { get; set; }
Property Value
Remarks
If OnClose has a value it takes precedence over corresponding class method
OnConfigure
public Action<Map<String, object>> OnConfigure { get; set; }
Property Value
Remarks
If OnConfigure has a value it takes precedence over corresponding class method
OnPartition
public Func<String, object, byte[], object, byte[], Cluster, int> OnPartition { get; set; }
Property Value
Remarks
If OnPartition has a value it takes precedence over corresponding class method
Methods
Close()
public virtual void Close()
Configure(Map<String, object>)
public virtual void Configure(Map<String, object> arg0)
Parameters
InitializeHandlers()
Handlers initializer for Partitioner
protected virtual void InitializeHandlers()
Partition(String, object, byte[], object, byte[], Cluster)
public virtual int Partition(String arg0, object arg1, byte[] arg2, object arg3, byte[] arg4, Cluster arg5)