Class KNetSourceConnector<TSourceConnector, TTask>

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

An implementation of KNetConnector<TConnector> for source connectors

public abstract class KNetSourceConnector<TSourceConnector, TTask> : KNetConnector<TSourceConnector>, IKNetConnector, IConnector, IVersion, IKNetConnectLogging where TSourceConnector : KNetSourceConnector<TSourceConnector, TTask> where TTask : KNetSourceTask<TTask>

Type Parameters

TSourceConnector

The connector class inherited from KNetSinkConnector<TSinkConnector, TTask>

TTask

The task class inherited from KNetSourceTask<TTask>

Inheritance

object

KNetConnector

KNetConnector<TSourceConnector>

KNetSourceConnector<TSourceConnector, TTask>

Implements

IKNetConnector

IConnector

IVersion

IKNetConnectLogging

Derived

KNetConnectSource

Inherited Members

KNetConnector<TSourceConnector>.ConnectorName

KNetConnector.taskDictionary

KNetConnector.ExecuteOnConnector(string, params object[])

KNetConnector.ExecuteOnConnector<T>(string, params object[])

KNetConnector.DataToExchange<T>()

KNetConnector.DataToExchange(object)

KNetConnector.Context<T>()

KNetConnector.Properties

KNetConnector.AllocateTask(long)

KNetConnector.Initialize(ConnectorContext)

KNetConnector.Initialize(ConnectorContext, List<Map<String, String>>)

KNetConnector.StartInternal()

KNetConnector.Start(Map<String, String>)

KNetConnector.Start(IReadOnlyDictionary<string, string>)

KNetConnector.Reconfigure(Map<String, String>)

KNetConnector.TaskClass()

KNetConnector.TaskConfigsInternal(int)

KNetConnector.TaskConfigs(int, IDictionary<string, string>)

KNetConnector.TaskConfigs(int)

KNetConnector.StopInternal()

KNetConnector.Stop()

KNetConnector.Validate(Map<String, String>)

KNetConnector.Config()

KNetConnector.Version()

KNetConnector.IsTraceEnabled

KNetConnector.IsDebugEnabled

KNetConnector.IsInfoEnabled

KNetConnector.IsWarnEnabled

KNetConnector.IsErrorEnabled

KNetConnector.LogTrace(string)

KNetConnector.LogTrace(string, JVMBridgeException)

KNetConnector.LogDebug(string)

KNetConnector.LogDebug(string, JVMBridgeException)

KNetConnector.LogInfo(string)

KNetConnector.LogInfo(string, JVMBridgeException)

KNetConnector.LogWarn(string)

KNetConnector.LogWarn(string, JVMBridgeException)

KNetConnector.LogError(string)

KNetConnector.LogError(string, JVMBridgeException)

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

Properties

Context

The SourceConnectorContext

public SourceConnectorContext Context { get; }

Property Value

SourceConnectorContext

ExactlyOnceSupport

Implement the method to return the ExactlyOnceSupport value

public virtual ExactlyOnceSupport ExactlyOnceSupport { get; }

Property Value

ExactlyOnceSupport

ReflectedConnectorClassName

Set the ReflectedConnectorClassName of the connector to a fixed value

public override sealed string ReflectedConnectorClassName { get; }

Property Value

string

TaskClassType

Set the TaskClassType of the connector to the value defined from TTask

public override sealed Type TaskClassType { get; }

Property Value

Type

Methods

CanDefineTransactionBoundaries()

Implement the method to return the ConnectorTransactionBoundaries value

public virtual ConnectorTransactionBoundaries CanDefineTransactionBoundaries()

Returns

ConnectorTransactionBoundaries

CanDefineTransactionBoundariesInternal()

Public method used from Java to trigger CanDefineTransactionBoundaries()

public ConnectorTransactionBoundaries CanDefineTransactionBoundariesInternal()

Returns

ConnectorTransactionBoundaries

ExactlyOnceSupportInternal()

Public method used from Java to trigger ExactlyOnceSupport

public ExactlyOnceSupport ExactlyOnceSupportInternal()

Returns

ExactlyOnceSupport