Class KNetTransformation

Namespace

MASES.KNet.Connect.Transforms

Assembly

MASES.KNet.dll

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

public abstract class KNetTransformation : KNetCommon, IKNetCommon, IKNetConnectLogging, IKNetTransformation, ITransformation, IVersion

Inheritance

object

KNetCommon

KNetTransformation

Implements

IKNetCommon

IKNetConnectLogging

IKNetTransformation

ITransformation

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

Apply(ConnectRecord)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/4.2.0/org/apache/kafka/connect/transforms/Transformation.html#apply(org.apache.kafka.connect.connector.ConnectRecord)

public virtual ConnectRecord Apply(ConnectRecord record)

Parameters

record ConnectRecord

Returns

ConnectRecord

ConnectRecord

Apply(SinkRecord)

Implements the behavior of Apply(ConnectRecord) for record

public virtual SinkRecord Apply(SinkRecord record)

Parameters

record SinkRecord

The SinkRecord to test

Returns

SinkRecord

Follow specifications of Apply(ConnectRecord)

Remarks

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

Apply(SourceRecord)

Implements the behavior of Apply(ConnectRecord) for record

public virtual SourceRecord Apply(SourceRecord record)

Parameters

record SourceRecord

The SourceRecord to test

Returns

SourceRecord

Follow specifications of Apply(ConnectRecord)

Remarks

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

Close()

Implement the method to execute the stop 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.