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
KNetCore<T>
Implements
Derived
Inherited Members
SetupJVMWrapper<T>.ScopedOn
SetupJVMWrapper<T>.ScopedOnVersion
SetupJVMWrapper.Initialize()
SetupJVMWrapper.InitializeRemote()

Constructors

KNetCore()

Public initializer

public KNetCore()

Properties

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

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

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

ProcessCommandLine()

Process command line arguments

protected override string[] ProcessCommandLine()

Returns

string[]

The filtered residual arguments

Edit this page