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

Apply(ConnectRecord)

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

ApplyInternal()

Public method used from Java to trigger Apply(ConnectRecord)

public void ApplyInternal()

Close()

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

Version()

Not implemented

public string Version()

Returns

string

Exceptions

NotImplementedException

Invoked in Java before any initialization