Class KNetConnectSourceTask

Namespace

MASES.KNetTemplate.KNetConnect

Assembly

knetConnectSource.dll

public class KNetConnectSourceTask : KNetSourceTask<KNetConnectSourceTask>, IKNetTask, ITask, IKNetConnectLogging

Inheritance

object

KNetTask

KNetTask<KNetConnectSourceTask>

KNetSourceTask<KNetConnectSourceTask>

KNetConnectSourceTask

Implements

IKNetTask

ITask

IKNetConnectLogging

Inherited Members

KNetSourceTask<KNetConnectSourceTask>.OffsetForKey<T>(String, T)

KNetSourceTask<KNetConnectSourceTask>.OffsetAt<TKeySource, TOffset>(String, TKeySource)

KNetSourceTask<KNetConnectSourceTask>.Context

KNetSourceTask<KNetConnectSourceTask>.ReflectedTaskClassName

KNetSourceTask<KNetConnectSourceTask>.PollInternal()

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKey, TValue>(string, int?, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKey, TValue>(string, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKey, TValue>(string, Schema, TKey, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKey, TValue>(string, int?, Schema, TKey, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TValue>(string, Schema, TValue, DateTime)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TValue>(string, int?, Schema, TValue, DateTime)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKey, TValue>(string, int?, Schema, TKey, Schema, TValue, DateTime)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKey, TValue>(string, int?, Schema, TKey, Schema, TValue, DateTime, Headers)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, int?, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, Schema, TKey, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, int?, Schema, TKey, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKeySource, TOffset, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, Schema, TValue, DateTime)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKeySource, TOffset, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, int?, Schema, TValue, DateTime)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, int?, Schema, TKey, Schema, TValue, DateTime)

KNetSourceTask<KNetConnectSourceTask>.CreateRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, int?, Schema, TKey, Schema, TValue, DateTime, Headers)

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

Poll()

Implement the method to execute the Poll action

public override IList<SourceRecord> Poll()

Returns

IList<SourceRecord>

The list of SourceRecord to return to 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()