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.Properties

KNetTask.Connector

KNetTask.TaskId

KNetTask.Start(Map<String, String>)

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

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

Stop()

Implement the method to execute the stop action

public override void Stop()