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

Properties

The properties retrieved from MASES.KNet.Connect.KNetTask.StartInternal()

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

Property Value

IReadOnlyDictionary<string, string>

ReflectedRemoteObjectClassName

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

protected override sealed string ReflectedRemoteObjectClassName { get; }

Property Value

string

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(IReadOnlyDictionary<string, string>)

Implement the method to execute the start action

public abstract void Start(IReadOnlyDictionary<string, string> props)

Parameters

props IReadOnlyDictionary<string, string>

The set of properties returned from Apache Kafka Connect framework: the IReadOnlyDictionary<TKey, TValue> contains the info from KNetConnector.TaskConfigs(int, IDictionary<string, string>).

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