Table of Contents

Class ProcessingContext

Namespace
Org.Apache.Kafka.Streams.Processor.Api
Assembly
MASES.KNet.dll
public class ProcessingContext : JVMBridgeBase<ProcessingContext>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IProcessingContext
Inheritance
JVMBridgeBase
JVMBridgeBase<ProcessingContext>
ProcessingContext
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Derived
Inherited Members
JVMBridgeBase<ProcessingContext>.IsAssignableFrom(IJavaType)
JVMBridgeBase<ProcessingContext>.IsAssignableFrom<T>()
JVMBridgeBase<ProcessingContext>.Execute<T>(params T[])
JVMBridgeBase<ProcessingContext>.DynBridgeClazz
JVMBridgeBase<ProcessingContext>.BridgeClazz
JVMBridgeBase.RuntimeClassNameOf<T>()
JVMBridgeBase.ClassNameOf<T>()
JVMBridgeBase.ClassOf<T>()
JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)
JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)
JVMBridgeBase.MonitorEnter()
JVMBridgeBase.MonitorExit()
JVMBridgeBase.IsInstanceOf(IJavaType)
JVMBridgeBase.IsInstanceOf<T>()
JVMBridgeBase.RuntimeIsInstanceOf<T>()
JVMBridgeBase.CastTo<TNewClass>()
JVMBridgeBase.CastDirect<TNewClass>()
JVMBridgeBase.Dispose()
JVMBridgeBase.ToString()
JVMBridgeBase.GetHashCode()
JVMBridgeBase.Notify()
JVMBridgeBase.NotifyAll()
JVMBridgeBase.Wait()
JVMBridgeBase.DynBridgeInstance
JVMBridgeBase.BridgeInstance
JVMBridgeBase.IsBridgeListener

Constructors

ProcessingContext()

Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge

[Obsolete("ProcessingContext class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public ProcessingContext()

ProcessingContext(params object[])

Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class

[Obsolete("ProcessingContext class represents, in .NET, an instance of a JVM interface or abstract class. This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public ProcessingContext(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

AppConfigs()

public Map<String, object> AppConfigs()

Returns

Map<String, object>

Map

AppConfigsWithPrefix(String)

public Map<String, object> AppConfigsWithPrefix(String arg0)

Parameters

arg0 String

String

Returns

Map<String, object>

Map

ApplicationId()

public String ApplicationId()

Returns

String

String

Commit()

public void Commit()

CurrentStreamTimeMs()

public long CurrentStreamTimeMs()

Returns

long

long

CurrentSystemTimeMs()

public long CurrentSystemTimeMs()

Returns

long

long

GetStateStore<S>(String)

public S GetStateStore<S>(String arg0) where S : IStateStore, new()

Parameters

arg0 String

String

Returns

S

S

Type Parameters

S

IStateStore

KeySerde()

public Serde<object> KeySerde()

Returns

Serde<object>

Serde

KeySerdeDirect()

public Serde<object> KeySerdeDirect()

Returns

Serde<object>

Serde

Metrics()

public StreamsMetrics Metrics()

Returns

StreamsMetrics

StreamsMetrics

RecordMetadata()

public Optional<RecordMetadata> RecordMetadata()

Returns

Optional<RecordMetadata>

Optional

Schedule(Duration, PunctuationType, Punctuator)

public Cancellable Schedule(Duration arg0, PunctuationType arg1, Punctuator arg2)

Parameters

arg0 Duration

Duration

arg1 PunctuationType

PunctuationType

arg2 Punctuator

Punctuator

Returns

Cancellable

Cancellable

StateDir()

public File StateDir()

Returns

File

File

TaskId()

public TaskId TaskId()

Returns

TaskId

TaskId

ValueSerde()

public Serde<object> ValueSerde()

Returns

Serde<object>

Serde

ValueSerdeDirect()

public Serde<object> ValueSerdeDirect()

Returns

Serde<object>

Serde