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.LogCheckInterval

KNetCommon.UniqueId

KNetCommon.Properties

KNetCommon.ExecuteOnRemote(string, params object[])

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

KNetCommon.DataToExchange<T>()

KNetCommon.DataToExchange(object)

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

ReflectedRemoteObjectClassName

Set the ReflectedRemoteObjectClassName of the connector to a fixed value

protected override sealed string ReflectedRemoteObjectClassName { get; }

Property Value

string

Methods

Close()

Implement the method to execute the close action

public virtual void Close()

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(IKNetConfigurationFromMap)

Implement the method to execute the start action

public abstract void Configure(IKNetConfigurationFromMap configuration)

Parameters

configuration IKNetConfigurationFromMap

The IKNetConfigurationFromMap to access the properties returned from Apache Kafka Connect framework: the Properties contains the same info from configuration file.

Test(ConnectRecord)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.2.0/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.

ToStringPredicate()

Returns a formatted string used from Predicate

public virtual string ToStringPredicate()

Returns

string

The formatted string