Class KNetConnectSourceTask

Namespace

MASES.KNet.Template.KNetConnect

Assembly

knetConnectSource.dll

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

Inheritance

object

KNetCommon

KNetTask

KNetTask<KNetConnectSourceTask>

KNetSourceTask<KNetConnectSourceTask>

KNetConnectSourceTask

Implements

IKNetSourceTask

IKNetTask

ITask

IKNetCommon

IKNetConnectLogging

Inherited Members

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

KNetSourceTask<KNetConnectSourceTask>.PartitionOrOffsetForKey<T>(string, T)

KNetSourceTask<KNetConnectSourceTask>.PartitionOrOffsetForKeys<T>(params Tuple<string, T>[])

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

KNetSourceTask<KNetConnectSourceTask>.Context

KNetSourceTask<KNetConnectSourceTask>.ReflectedTaskClassName

KNetSourceTask<KNetConnectSourceTask>.PushRecordAsync(SourceRecord)

KNetSourceTask<KNetConnectSourceTask>.UseOnlyAsync

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

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecord<TKey, TValue>(string, int?, Schema, TValue, Map<String, object>, Map<String, object>)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<TKey, TValue>(string, int?, Schema, TValue, Map<String, object>, Map<String, object>)

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

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecord<TKey, TValue>(string, Schema, TValue, Map<String, object>, Map<String, object>)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<TKey, TValue>(string, Schema, TValue, Map<String, object>, Map<String, object>)

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

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecord<TKey, TValue>(string, Schema, TKey, Schema, TValue, Map<String, object>, Map<String, object>)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<TKey, TValue>(string, Schema, TKey, Schema, TValue, Map<String, object>, Map<String, object>)

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

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecord<TKey, TValue>(string, int?, Schema, TKey, Schema, TValue, Map<String, object>, Map<String, object>)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<TKey, TValue>(string, int?, Schema, TKey, Schema, TValue, Map<String, object>, Map<String, object>)

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

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecord<TValue>(string, Schema, TValue, DateTime, Map<String, object>, Map<String, object>)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<TValue>(string, Schema, TValue, DateTime, Map<String, object>, Map<String, object>)

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

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecord<TValue>(string, int?, Schema, TValue, DateTime, Map<String, object>, Map<String, object>)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<TValue>(string, int?, Schema, TValue, DateTime, Map<String, object>, Map<String, object>)

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

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecord<TKey, TValue>(string, int?, Schema, TKey, Schema, TValue, DateTime, Map<String, object>, Map<String, object>)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<TKey, TValue>(string, int?, Schema, TKey, Schema, TValue, DateTime, Map<String, object>, Map<String, object>)

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

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecord<TKey, TValue>(string, int?, Schema, TKey, Schema, TValue, DateTime, Headers, Map<String, object>, Map<String, object>)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<TKey, TValue>(string, int?, Schema, TKey, Schema, TValue, DateTime, Headers, Map<String, object>, Map<String, object>)

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

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

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<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>.CreateAndPushRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<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>.CreateAndPushRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, Schema, TKey, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<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>.CreateAndPushRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, int?, Schema, TKey, Schema, TValue)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<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>.CreateAndPushRecord<TKeySource, TOffset, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, Schema, TValue, DateTime)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<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>.CreateAndPushRecord<TKeySource, TOffset, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, int?, Schema, TValue, DateTime)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<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>.CreateAndPushRecord<TKeySource, TOffset, TKey, TValue>(Map<String, TKeySource>, Map<String, TOffset>, string, int?, Schema, TKey, Schema, TValue, DateTime)

KNetSourceTask<KNetConnectSourceTask>.CreateAndPushRecordAsync<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)

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

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

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

Poll()

Implement the method to execute the Poll action

public override IEnumerable<SourceRecord> Poll()

Returns

IEnumerable<SourceRecord>

The set of SourceRecord to return to Apache Kafka Connect framework or null if SourceRecord are accumulated using CreateAndPushRecord methods

Remarks

The method shall be implemented, however if UseOnlyAsync is set to true the JVM side never invokes Poll()

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