Class KNetConnectSinkTask

Namespace

MASES.KNet.Template.KNetConnect

Assembly

knetConnectSink.dll

public class KNetConnectSinkTask : KNetSinkTask<KNetConnectSinkTask>, IKNetSinkTask, IKNetTask, ITask, IKNetCommon, IKNetConnectLogging

Inheritance

object

KNetCommon

KNetTask

KNetTask<KNetConnectSinkTask>

KNetSinkTask<KNetConnectSinkTask>

KNetConnectSinkTask

Implements

IKNetSinkTask

IKNetTask

ITask

IKNetCommon

IKNetConnectLogging

Inherited Members

KNetSinkTask<KNetConnectSinkTask>.UsePrefetch

KNetSinkTask<KNetConnectSinkTask>.UseThread

KNetSinkTask<KNetConnectSinkTask>.ThreadPriority

KNetSinkTask<KNetConnectSinkTask>.Context

KNetSinkTask<KNetConnectSinkTask>.ReflectedTaskClassName

KNetTask<KNetConnectSinkTask>.Version()

KNetTask.ReflectedRemoteObjectClassName

KNetTask.Context<T>()

KNetTask.Connector

KNetTask.TaskId

KNetTask.Start(Map<String, String>)

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

Methods

Put(IEnumerable<SinkRecord>)

Implement the method to execute the Put action

public override void Put(IEnumerable<SinkRecord> collection)

Parameters

collection IEnumerable<SinkRecord>

The set of SinkRecord from Apache Kafka Connect framework

Start(IKNetConfigurationFromMap)

Implement the method to execute the start action

public override void Start(IKNetConfigurationFromMap props)

Parameters

props IKNetConfigurationFromMap

The IKNetConfigurationFromMap 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 override void Stop()