Class KNetConnector<TConnector>

Namespace

MASES.KNet.Connect

Assembly

MASES.KNet.dll

The base connector class which is the base of both source or sink connectors and receives information about implementing class with TConnector

public abstract class KNetConnector<TConnector> : KNetConnector, IKNetConnector, IConnector, IVersion, IKNetConnectLogging where TConnector : KNetConnector<TConnector>

Type Parameters

TConnector

The class which extends KNetConnector<TConnector>

Inheritance

object

KNetConnector

KNetConnector<TConnector>

Implements

IKNetConnector

IConnector

IVersion

IKNetConnectLogging

Derived

KNetSinkConnector<TSinkConnector, TTask>

KNetSourceConnector<TSourceConnector, TTask>

Inherited Members

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

KNetConnector.TaskClassType

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

ConnectorName

Set the ConnectorName of the connector to the value defined from TConnector

public override string ConnectorName { get; }

Property Value

string