Table of Contents

Class ProcessorWrapper

Namespace
Org.Apache.Kafka.Streams.Processor.Api
Assembly
MASES.KNet.dll

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/ProcessorWrapper.html

public class ProcessorWrapper : Configurable, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition, IProcessorWrapper, IConfigurable
Inheritance
ProcessorWrapper
Implements
Inherited Members

Constructors

ProcessorWrapper()

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

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

ProcessorWrapper(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("ProcessorWrapper 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 ProcessorWrapper(params object[] args)

Parameters

args object[]

Properties

BridgeClassName

Java class name to be instantiated

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

true if the BridgeClassName is an abstract class, i.e. cannot be created an instance

public override bool IsBridgeAbstract { get; }

Property Value

bool

IsBridgeCloseable

true if the BridgeClassName implements Closeable

public override bool IsBridgeCloseable { get; }

Property Value

bool

IsBridgeInterface

true if the BridgeClassName is an interface, i.e. does not have any public constructor

public override bool IsBridgeInterface { get; }

Property Value

bool

IsBridgeStatic

true if the BridgeClassName is a static class, i.e. does not have any public constructor

public override bool IsBridgeStatic { get; }

Property Value

bool

Methods

AsWrappedFixedKey<KIn, VIn, VOut>(FixedKeyProcessorSupplier<KIn, VIn, VOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/ProcessorWrapper.html#asWrappedFixedKey(org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier)

public static WrappedFixedKeyProcessorSupplier<KIn, VIn, VOut> AsWrappedFixedKey<KIn, VIn, VOut>(FixedKeyProcessorSupplier<KIn, VIn, VOut> arg0)

Parameters

arg0 FixedKeyProcessorSupplier<KIn, VIn, VOut>

FixedKeyProcessorSupplier

Returns

WrappedFixedKeyProcessorSupplier<KIn, VIn, VOut>

WrappedFixedKeyProcessorSupplier

Type Parameters

KIn
VIn
VOut

AsWrapped<KIn, VIn, KOut, VOut>(ProcessorSupplier<KIn, VIn, KOut, VOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/ProcessorWrapper.html#asWrapped(org.apache.kafka.streams.processor.api.ProcessorSupplier)

public static WrappedProcessorSupplier<KIn, VIn, KOut, VOut> AsWrapped<KIn, VIn, KOut, VOut>(ProcessorSupplier<KIn, VIn, KOut, VOut> arg0)

Parameters

arg0 ProcessorSupplier<KIn, VIn, KOut, VOut>

ProcessorSupplier

Returns

WrappedProcessorSupplier<KIn, VIn, KOut, VOut>

WrappedProcessorSupplier

Type Parameters

KIn
VIn
KOut
VOut

Configure(Map<String, object>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/ProcessorWrapper.html#configure(java.util.Map)

public void Configure(Map<String, object> arg0)

Parameters

arg0 Map<String, object>

Map

WrapFixedKeyProcessorSupplier<KIn, VIn, VOut>(String, FixedKeyProcessorSupplier<KIn, VIn, VOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/ProcessorWrapper.html#wrapFixedKeyProcessorSupplier(java.lang.String,org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier)

public WrappedFixedKeyProcessorSupplier<KIn, VIn, VOut> WrapFixedKeyProcessorSupplier<KIn, VIn, VOut>(String arg0, FixedKeyProcessorSupplier<KIn, VIn, VOut> arg1)

Parameters

arg0 String

String

arg1 FixedKeyProcessorSupplier<KIn, VIn, VOut>

FixedKeyProcessorSupplier

Returns

WrappedFixedKeyProcessorSupplier<KIn, VIn, VOut>

WrappedFixedKeyProcessorSupplier

Type Parameters

KIn
VIn
VOut

WrapProcessorSupplier<KIn, VIn, KOut, VOut>(String, ProcessorSupplier<KIn, VIn, KOut, VOut>)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.0.0/org/apache/kafka/streams/processor/api/ProcessorWrapper.html#wrapProcessorSupplier(java.lang.String,org.apache.kafka.streams.processor.api.ProcessorSupplier)

public WrappedProcessorSupplier<KIn, VIn, KOut, VOut> WrapProcessorSupplier<KIn, VIn, KOut, VOut>(String arg0, ProcessorSupplier<KIn, VIn, KOut, VOut> arg1)

Parameters

arg0 String

String

arg1 ProcessorSupplier<KIn, VIn, KOut, VOut>

ProcessorSupplier

Returns

WrappedProcessorSupplier<KIn, VIn, KOut, VOut>

WrappedProcessorSupplier

Type Parameters

KIn
VIn
KOut
VOut
Edit this page