Class KNetCore<T>
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
-
SetupJVMWrapperSetupJVMWrapper<T>JNetCoreBase<T>JNetCore<T>KNetCore<T>
- Implements
-
IJVMWrapperManagementIJVMBridgeCore
- Derived
- Inherited Members
-
SetupJVMWrapper<T>.CreateGlobalInstance()SetupJVMWrapper<T>.HasGlobalInstanceSetupJVMWrapper<T>.GlobalInstanceSetupJVMWrapper<T>.ScopedOnSetupJVMWrapper<T>.ScopedOnVersionSetupJVMWrapper.Initialize()SetupJVMWrapper.InitializeListener(IJVMBridgeBase)SetupJVMWrapper.GetListener(IJavaObject)SetupJVMWrapper.ReleaseListener(IJVMBridgeBase)SetupJVMWrapper.ReleaseJCGraphicContainer(IJCGraphicContainer)SetupJVMWrapper.InitializeRemote()SetupJVMWrapper.FilteredArgsSetupJVMWrapper.IsContainerSetupJVMWrapper.ContainerIdSetupJVMWrapper.FeatureLevelSetupJVMWrapper.EnableCriticalMethodsSetupJVMWrapper.EnableCriticalMethodsOnGetThresholdSetupJVMWrapper.EnableCriticalMethodsOnGetSetupJVMWrapper.EnableCriticalMethodsOnSetThresholdSetupJVMWrapper.EnableCriticalMethodsOnSetSetupJVMWrapper.JVMSetupJVMWrapper.ManagementSetupJVMWrapper.JVMStatsSetupJVMWrapper.DynJVMSetupJVMWrapper.RemoteBridgeSetupJVMWrapper.RemoteJCOBridgeSetupJVMWrapper.ModulePathSetupJVMWrapper.JVMPackagesSetupJVMWrapper.SuppressFinalizeSetupJVMWrapper.GlobalizeSetupJVMWrapper.LastBindingException
Constructors
KNetCore()
Public initializer
public KNetCore()
Fields
_classToRun
value can be overridden in subclasses
protected string _classToRun
Field Value
Properties
ApplicationClassToRun
Sets the global value of class to run
public static string ApplicationClassToRun { get; set; }
Property Value
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
ApplicationLog4JPath
Sets the global value of log4j path
public static string ApplicationLog4JPath { get; set; }
Property Value
ApplicationLogPath
Sets the global value of log path
public static string ApplicationLogPath { get; set; }
Property Value
ApplicationScalaVersion
Sets the global value of scala version
public static string ApplicationScalaVersion { get; set; }
Property Value
ClassToRun
The class to run in CLI version
public virtual string ClassToRun { get; }
Property Value
CommandLineArguments
IEnumerable<T> for command line
public override IEnumerable<IArgumentMetadata> CommandLineArguments { get; }
Property Value
DisableJMX
Disable JMX
public virtual bool DisableJMX { get; }
Property Value
JarRootPath
The root path where Apache Kafka is installed
public virtual string JarRootPath { get; }
Property Value
Log4JOpts
The log4j configuration
public virtual string Log4JOpts { get; }
Property Value
Log4JPath
The log4j folder
public virtual string Log4JPath { get; }
Property Value
LogDir
The log folder
public virtual string LogDir { get; }
Property Value
MainClassToRun
Sets the Type to be invoked at startup
public static Type MainClassToRun { get; protected set; }
Property Value
Options
Adds options to the JVM
protected override IDictionary<string, string> Options { get; }
Property Value
PathToParse
A list of paths to be used in initialization of JVM ClassPath
protected override IList<string> PathToParse { get; }
Property Value
PerformanceOptions
Default performance options used in initialization
protected override IList<string> PerformanceOptions { get; }
Property Value
ScalaBinaryVersion
The Scala binary version to be used
public virtual string ScalaBinaryVersion { get; }
Property Value
ScalaVersion
The Scala version to be used
public virtual string ScalaVersion { get; }
Property Value
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
stringThe class to search
Exceptions
- ArgumentException
If
className
does not have a corresponding implemented Type
ProcessCommandLine()
protected override string[] ProcessCommandLine()
Returns
- string[]