Table of Contents

Class KNetCore<T>

Namespace
MASES.KNet
Assembly
MASES.KNet.dll

Public entry point of KNetCore<T>

public class KNetCore<T> : JNetCore<T>, IJVMWrapperManagement, IJVMBridgeCore where T : KNetCore<T>

Type Parameters

T

A class which inherits from KNetCore<T>

Inheritance
SetupJVMWrapper
SetupJVMWrapper<T>
KNetCore<T>
Implements
IJVMWrapperManagement
IJVMBridgeCore
Derived
Inherited Members
SetupJVMWrapper<T>.CreateGlobalInstance()
SetupJVMWrapper<T>.HasGlobalInstance
SetupJVMWrapper<T>.GlobalInstance
SetupJVMWrapper<T>.ScopedOn
SetupJVMWrapper<T>.ScopedOnVersion
SetupJVMWrapper.Initialize()
SetupJVMWrapper.InitializeListener(IJVMBridgeBase)
SetupJVMWrapper.GetListener(IJavaObject)
SetupJVMWrapper.ReleaseListener(IJVMBridgeBase)
SetupJVMWrapper.ReleaseJCGraphicContainer(IJCGraphicContainer)
SetupJVMWrapper.InitializeRemote()
SetupJVMWrapper.FilteredArgs
SetupJVMWrapper.IsContainer
SetupJVMWrapper.ContainerId
SetupJVMWrapper.FeatureLevel
SetupJVMWrapper.EnableCriticalMethods
SetupJVMWrapper.EnableCriticalMethodsOnGetThreshold
SetupJVMWrapper.EnableCriticalMethodsOnGet
SetupJVMWrapper.EnableCriticalMethodsOnSetThreshold
SetupJVMWrapper.EnableCriticalMethodsOnSet
SetupJVMWrapper.JVM
SetupJVMWrapper.Management
SetupJVMWrapper.JVMStats
SetupJVMWrapper.DynJVM
SetupJVMWrapper.RemoteBridge
SetupJVMWrapper.RemoteJCOBridge
SetupJVMWrapper.ModulePath
SetupJVMWrapper.JVMPackages
SetupJVMWrapper.SuppressFinalize
SetupJVMWrapper.Globalize
SetupJVMWrapper.LastBindingException

Constructors

KNetCore()

Public initializer

public KNetCore()

Fields

_classToRun

value can be overridden in subclasses

protected string _classToRun

Field Value

string

Properties

ApplicationClassToRun

Sets the global value of class to run

public static string ApplicationClassToRun { get; set; }

Property Value

string

ApplicationDisableJMX

Sets the global value to disable JMX

public static bool? ApplicationDisableJMX { get; set; }

Property Value

bool?

ApplicationJarRootPath

Sets the global value of Jar root path

public static string ApplicationJarRootPath { get; set; }

Property Value

string

ApplicationLog4JPath

Sets the global value of log4j path

public static string ApplicationLog4JPath { get; set; }

Property Value

string

ApplicationLogPath

Sets the global value of log path

public static string ApplicationLogPath { get; set; }

Property Value

string

ApplicationScalaVersion

Sets the global value of scala version

public static string ApplicationScalaVersion { get; set; }

Property Value

string

ClassToRun

The class to run in CLI version

public virtual string ClassToRun { get; }

Property Value

string

CommandLineArguments

IEnumerable<T> for command line

public override IEnumerable<IArgumentMetadata> CommandLineArguments { get; }

Property Value

IEnumerable<IArgumentMetadata>

DisableJMX

Disable JMX

public virtual bool DisableJMX { get; }

Property Value

bool

JarRootPath

The root path where Apache Kafka is installed

public virtual string JarRootPath { get; }

Property Value

string

Log4JOpts

The log4j configuration

public virtual string Log4JOpts { get; }

Property Value

string

Log4JPath

The log4j folder

public virtual string Log4JPath { get; }

Property Value

string

LogDir

The log folder

public virtual string LogDir { get; }

Property Value

string

MainClassToRun

Sets the Type to be invoked at startup

public static Type MainClassToRun { get; protected set; }

Property Value

Type

Options

Adds options to the JVM

protected override IDictionary<string, string> Options { get; }

Property Value

IDictionary<string, string>

PathToParse

A list of paths to be used in initialization of JVM ClassPath

protected override IList<string> PathToParse { get; }

Property Value

IList<string>

PerformanceOptions

Default performance options used in initialization

protected override IList<string> PerformanceOptions { get; }

Property Value

IList<string>

ScalaBinaryVersion

The Scala binary version to be used

public virtual string ScalaBinaryVersion { get; }

Property Value

string

ScalaVersion

The Scala version to be used

public virtual string ScalaVersion { get; }

Property Value

string

Methods

DefaultLog4JConfiguration()

Returns the default configuration file to use when initializing command line defaults

protected virtual string DefaultLog4JConfiguration()

Returns

string

The configuration file to use for logging

Remarks

Overrides in derived classes to give another default file

PrepareMainClassToRun(string)

Prepare MainClassToRun property

protected virtual void PrepareMainClassToRun(string className)

Parameters

className string

The class to search

Exceptions

ArgumentException

If className does not have a corresponding implemented Type

ProcessCommandLine()

protected override string[] ProcessCommandLine()

Returns

string[]