Class KNetSinkConnector<TSinkConnector, TTask>

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

An implementation of KNetConnector<TConnector> for sink connectors

public abstract class KNetSinkConnector<TSinkConnector, TTask> : KNetConnector<TSinkConnector>, IKNetConnector, IConnector, IVersion, IKNetConnectLogging where TSinkConnector : KNetSinkConnector<TSinkConnector, TTask> where TTask : KNetSinkTask<TTask>

Type Parameters

TSinkConnector

The connector class inherited from KNetSinkConnector<TSinkConnector, TTask>

TTask

The task class inherited from KNetSinkTask<TTask>

Inheritance

object

KNetConnector

KNetConnector<TSinkConnector>

KNetSinkConnector<TSinkConnector, TTask>

Implements

IKNetConnector

IConnector

IVersion

IKNetConnectLogging

Derived

KNetConnectSink

Inherited Members

KNetConnector<TSinkConnector>.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 SinkConnectorContext

public SinkConnectorContext Context { get; }

Property Value

SinkConnectorContext

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