Class KNetConnectSinkTask

Namespace

MASES.KNetTemplate.KNetConnect

Assembly

knetConnectSink.dll

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

Inheritance

object

KNetTask

KNetTask<KNetConnectSinkTask>

KNetSinkTask<KNetConnectSinkTask>

KNetConnectSinkTask

Implements

IKNetTask

ITask

IKNetConnectLogging

Inherited Members

KNetSinkTask<KNetConnectSinkTask>.Context

KNetSinkTask<KNetConnectSinkTask>.ReflectedTaskClassName

KNetSinkTask<KNetConnectSinkTask>.PutInternal()

KNetTask<KNetConnectSinkTask>.Version()

KNetTask.ExecuteOnTask(string, params object[])

KNetTask.ExecuteOnTask<T>(string, params object[])

KNetTask.DataToExchange<T>()

KNetTask.DataToExchange(object)

KNetTask.Context<T>()

KNetTask.Properties

KNetTask.Connector

KNetTask.TaskId

KNetTask.StartInternal()

KNetTask.Start(Map<String, String>)

KNetTask.StopInternal()

KNetTask.VersionInternal()

KNetTask.IsTraceEnabled

KNetTask.IsDebugEnabled

KNetTask.IsInfoEnabled

KNetTask.IsWarnEnabled

KNetTask.IsErrorEnabled

KNetTask.LogTrace(string)

KNetTask.LogTrace(string, JVMBridgeException)

KNetTask.LogDebug(string)

KNetTask.LogDebug(string, JVMBridgeException)

KNetTask.LogInfo(string)

KNetTask.LogInfo(string, JVMBridgeException)

KNetTask.LogWarn(string)

KNetTask.LogWarn(string, JVMBridgeException)

KNetTask.LogError(string)

KNetTask.LogError(string, JVMBridgeException)

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

Implement the method to execute the start action

public override 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 TaskConfigs(int, IDictionary<string, string>).

Stop()

Implement the method to execute the stop action

public override void Stop()