Class KNetSinkTask<TTask>

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

An implementation of KNetTask<TTask> for sink task

public abstract class KNetSinkTask<TTask> : KNetTask<TTask>, IKNetSinkTask, IKNetTask, ITask, IKNetCommon, IKNetConnectLogging where TTask : KNetSinkTask<TTask>

Type Parameters

TTask

The class which extends KNetSinkTask<TTask>

Inheritance

object

KNetCommon

KNetTask

KNetTask<TTask>

KNetSinkTask<TTask>

Implements

IKNetSinkTask

IKNetTask

ITask

IKNetCommon

IKNetConnectLogging

Derived

KNetConnectSinkTask

Inherited Members

KNetTask<TTask>.Version()

KNetTask.ReflectedRemoteObjectClassName

KNetTask.Context<T>()

KNetTask.Properties

KNetTask.Connector

KNetTask.TaskId

KNetTask.Start(Map<String, String>)

KNetTask.Start(IReadOnlyDictionary<string, string>)

KNetTask.Stop()

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

Context

The SinkTaskContext

public SinkTaskContext Context { get; }

Property Value

SinkTaskContext

ReflectedTaskClassName

Set the ReflectedTaskClassName of the connector to a fixed value

protected override string ReflectedTaskClassName { get; }

Property Value

string

ThreadPriority

The ThreadPriority to be used when UseThread is true

protected virtual ThreadPriority ThreadPriority { get; set; }

Property Value

ThreadPriority

UsePrefetch

The Put(IEnumerable<SinkRecord>) uses the WithPrefetch<TEnumerable>(TEnumerable, bool)

protected virtual bool UsePrefetch { get; set; }

Property Value

bool

UseThread

The Put(IEnumerable<SinkRecord>) uses the WithThread<TEnumerable>(TEnumerable, bool, ThreadPriority)

protected virtual bool UseThread { get; set; }

Property Value

bool

Methods

Put(IEnumerable<SinkRecord>)

Implement the method to execute the Put action

public abstract void Put(IEnumerable<SinkRecord> collection)

Parameters

collection IEnumerable<SinkRecord>

The set of SinkRecord from Apache Kafka Connect framework