Class ProcessorContext
public class ProcessorContext : JVMBridgeBase<ProcessorContext>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IProcessorContext- Inheritance
-
JVMBridgeBaseJVMBridgeBase<ProcessorContext>ProcessorContext
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<ProcessorContext>.IsAssignableFrom(IJavaType)JVMBridgeBase<ProcessorContext>.IsAssignableFrom<T>()JVMBridgeBase<ProcessorContext>.Execute<T>(params T[])JVMBridgeBase<ProcessorContext>.DynBridgeClazzJVMBridgeBase<ProcessorContext>.BridgeClazzJVMBridgeBase.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.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
Constructors
ProcessorContext()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
[Obsolete("ProcessorContext 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 ProcessorContext()ProcessorContext(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("ProcessorContext 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 ProcessorContext(params object[] args)Parameters
argsobject[]
Properties
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }Property Value
Methods
AppConfigs()
public Map<String, object> AppConfigs()Returns
AppConfigsWithPrefix(String)
public Map<String, object> AppConfigsWithPrefix(String arg0)Parameters
Returns
ApplicationId()
public String ApplicationId()Returns
Commit()
public void Commit()CurrentStreamTimeMs()
public long CurrentStreamTimeMs()Returns
CurrentSystemTimeMs()
public long CurrentSystemTimeMs()Returns
Forward<K, V>(K, V)
public void Forward<K, V>(K arg0, V arg1)Parameters
arg0KKarg1VV
Type Parameters
KV
Forward<K, V>(K, V, To)
public void Forward<K, V>(K arg0, V arg1, To arg2)Parameters
Type Parameters
KV
GetStateStore<S>(String)
public S GetStateStore<S>(String arg0) where S : IStateStore, new()Parameters
Returns
- S
S
Type Parameters
Headers()
public Headers Headers()Returns
KeySerde()
public Serde<object> KeySerde()Returns
KeySerdeDirect()
public Serde<object> KeySerdeDirect()Returns
Metrics()
public StreamsMetrics Metrics()Returns
Offset()
public long Offset()Returns
Partition()
public int Partition()Returns
Register(StateStore, StateRestoreCallback)
public void Register(StateStore arg0, StateRestoreCallback arg1)Parameters
Schedule(Duration, PunctuationType, Punctuator)
public Cancellable Schedule(Duration arg0, PunctuationType arg1, Punctuator arg2)Parameters
arg0Durationarg1PunctuationTypearg2Punctuator
Returns
StateDir()
public File StateDir()Returns
TaskId()
public TaskId TaskId()Returns
Timestamp()
public long Timestamp()Returns
Topic()
public String Topic()Returns
ValueSerde()
public Serde<object> ValueSerde()Returns
ValueSerdeDirect()
public Serde<object> ValueSerdeDirect()