Class ProcessingContext
public class ProcessingContext : JVMBridgeBase<ProcessingContext>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IProcessingContext- Inheritance
-
ProcessingContext
- Implements
- Derived
- Inherited Members
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
argsobject[]
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
IsBridgeAbstract
true if the BridgeClassName is an abstract class, i.e. cannot be created an instance
public override bool IsBridgeAbstract { get; }Property Value
IsBridgeCloseable
true if the BridgeClassName implements Closeable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
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
GetStateStore<S>(String)
public S GetStateStore<S>(String arg0) where S : IStateStore, new()Parameters
Returns
- S
S
Type Parameters
KeySerde()
public Serde<object> KeySerde()Returns
KeySerdeDirect()
public Serde<object> KeySerdeDirect()Returns
Metrics()
public StreamsMetrics Metrics()Returns
RecordMetadata()
public Optional<RecordMetadata> RecordMetadata()Returns
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
ValueSerde()
public Serde<object> ValueSerde()Returns
ValueSerdeDirect()
public Serde<object> ValueSerdeDirect()