Class KNetTask

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

The generic class which is the base of both source or sink task

public abstract class KNetTask : KNetCommon, IKNetTask, ITask, IKNetCommon, IKNetConnectLogging

Inheritance

object

KNetCommon

KNetTask

Implements

IKNetTask

ITask

IKNetCommon

IKNetConnectLogging

Derived

KNetTask<TTask>

Inherited Members

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

Connector

The associated IConnector

public IKNetConnector Connector { get; }

Property Value

IKNetConnector

ReflectedRemoteObjectClassName

The unique name used to map objects between JVM and .NET

protected override sealed string ReflectedRemoteObjectClassName { get; }

Property Value

string

Remarks

This value is used when KNet Connect SDK is hosted in the CLR. When KNet Connect SDK starts from the JVM it is ignored.

ReflectedTaskClassName

The unique name used to map objects between JVM and .NET

protected abstract string ReflectedTaskClassName { get; }

Property Value

string

TaskId

The id received during initialization

public long TaskId { get; }

Property Value

long

Methods

Context<T>()

An helper function to read the data from Java side

protected T Context<T>()

Returns

T

The T

Type Parameters

T

The expected return Type

Exceptions

InvalidOperationException

Start(Map<String, String>)

Not implemented

public void Start(Map<String, String> props)

Parameters

props Map<String, String>

Exceptions

NotImplementedException

Local version with a different signature

Start(IKNetConnectConfiguration)

Implement the method to execute the start action

public abstract void Start(IKNetConnectConfiguration props)

Parameters

props IKNetConnectConfiguration

The IKNetConnectConfiguration to access the properties returned from Apache Kafka Connect framework: the Properties contains the info from TaskConfigs(int, int, IKNetTaskConfiguration).

Stop()

Implement the method to execute the stop action

public abstract void Stop()

Version()

Implement the method to execute the version action

public abstract string Version()

Returns

string