Table of Contents

Class StateStoreContext

Namespace
Org.Apache.Kafka.Streams.Processor
Assembly
MASES.KNet.dll
public class StateStoreContext : JVMBridgeBase<StateStoreContext>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IStateStoreContext
Inheritance
JVMBridgeBase
JVMBridgeBase<StateStoreContext>
StateStoreContext
Implements
IJVMBridgeCore
IJVMBridgeBaseStatic
IJVMBridgeBase
IJVMBridgeDefinition
Inherited Members
JVMBridgeBase<StateStoreContext>.IsAssignableFrom(IJavaType)
JVMBridgeBase<StateStoreContext>.IsAssignableFrom<T>()
JVMBridgeBase<StateStoreContext>.Execute<T>(params T[])
JVMBridgeBase<StateStoreContext>.DynBridgeClazz
JVMBridgeBase<StateStoreContext>.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

StateStoreContext()

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

[Obsolete("StateStoreContext 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 StateStoreContext()

StateStoreContext(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("StateStoreContext 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 StateStoreContext(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

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

Register(StateStore, StateRestoreCallback)

public void Register(StateStore arg0, StateRestoreCallback arg1)

Parameters

arg0 StateStore

StateStore

arg1 StateRestoreCallback

StateRestoreCallback

Register(StateStore, StateRestoreCallback, CommitCallback)

public void Register(StateStore arg0, StateRestoreCallback arg1, CommitCallback arg2)

Parameters

arg0 StateStore

StateStore

arg1 StateRestoreCallback

StateRestoreCallback

arg2 CommitCallback

CommitCallback

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