Class KNetPredicate

Namespace

MASES.KNet.Connect.Transforms.Predicates

Assembly

MASES.KNet.dll

The generic class which is the base of all predicates in .NET

public abstract class KNetPredicate : KNetCommon, IKNetCommon, IKNetConnectLogging, IKNetPredicate, IPredicate, IVersion

Inheritance

object

KNetCommon

KNetPredicate

Implements

IKNetCommon

IKNetConnectLogging

IKNetPredicate

IPredicate

IVersion

Inherited Members

KNetCommon.UniqueId

KNetCommon.ExecuteOnRemote(string, params object[])

KNetCommon.ExecuteOnRemote<T>(string, params object[])

KNetCommon.DataToExchange<T>()

KNetCommon.DataToExchange(object)

KNetCommon.ReflectedRemoteObjectClassName

KNetCommon.Name

KNetCommon.IsTraceEnabled

KNetCommon.LogTrace(string)

KNetCommon.LogTrace(string, JVMBridgeException)

KNetCommon.LogTrace(string, params object[])

KNetCommon.IsDebugEnabled

KNetCommon.LogDebug(string)

KNetCommon.LogDebug(string, JVMBridgeException)

KNetCommon.LogDebug(string, params object[])

KNetCommon.IsInfoEnabled

KNetCommon.LogInfo(string)

KNetCommon.LogInfo(string, JVMBridgeException)

KNetCommon.LogInfo(string, params object[])

KNetCommon.IsWarnEnabled

KNetCommon.LogWarn(string)

KNetCommon.LogWarn(string, JVMBridgeException)

KNetCommon.LogWarn(string, params object[])

KNetCommon.IsErrorEnabled

KNetCommon.LogError(string)

KNetCommon.LogError(string, JVMBridgeException)

KNetCommon.LogError(string, params object[])

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Properties

Properties

The properties retrieved from Configure(Map<String, object>)

public IReadOnlyDictionary<string, object> Properties { get; }

Property Value

IReadOnlyDictionary<string, object>

Methods

Close()

Implement the method to execute the close action

public virtual void Close()

CloseInternal()

Public method used from Java to trigger Close()

public void CloseInternal()

Config()

Not implemented

public ConfigDef Config()

Returns

ConfigDef

Exceptions

NotImplementedException

Invoked in Java before any initialization

Configure(Map<String, object>)

Not implemented

public virtual void Configure(Map<String, object> props)

Parameters

props Map<String, object>

Exceptions

NotImplementedException

Local version with a different signature

Configure(IReadOnlyDictionary<string, object>)

Implement the method to execute the start action

public abstract void Configure(IReadOnlyDictionary<string, object> props)

Parameters

props IReadOnlyDictionary<string, object>

The set of properties returned from Apache Kafka Connect framework: the IReadOnlyDictionary<TKey, TValue> contains the same info from configuration file.

ConfigureInternal()

Public method used from Java to trigger Configure(Map<String, object>)

public void ConfigureInternal()

Test(ConnectRecord)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.1.1/org/apache/kafka/connect/transforms/predicates/Predicate.html#test(org.apache.kafka.connect.connector.ConnectRecord)

public virtual bool Test(ConnectRecord record)

Parameters

record ConnectRecord

Returns

bool

bool

Test(SinkRecord)

Implements the behavior of Test(ConnectRecord) for record

public virtual bool Test(SinkRecord record)

Parameters

record SinkRecord

The SinkRecord to test

Returns

bool

Follow specifications of Test(ConnectRecord)

Remarks

If the method is overridden never invoke the base method othrwise an exception is raised within the JVM.

Test(SourceRecord)

Implements the behavior of Test(ConnectRecord) for record

public virtual bool Test(SourceRecord record)

Parameters

record SourceRecord

The SourceRecord to test

Returns

bool

Follow specifications of Test(ConnectRecord)

Remarks

If the method is overridden never invoke the base method othrwise an exception is raised within the JVM.

TestInternal()

Public method used from Java to trigger Test(ConnectRecord)

public bool TestInternal()

Returns

bool

ToStringInternal()

Public method used from Java to trigger ToStringInternal()

public string ToStringInternal()

Returns

string

ToStringPredicate()

Returns a formatted string used from Predicate

public virtual string ToStringPredicate()

Returns

string

The formatted string

Version()

Not implemented

public string Version()

Returns

string

Exceptions

NotImplementedException

Invoked in Java before any initialization