Class Record<K, V, TJVMK, TJVMV>

Namespace

MASES.KNet.Streams.Processor.Api

Assembly

MASES.KNet.dll

KNet extension of Record<K, V>

public class Record<K, V, TJVMK, TJVMV> : IKNetInnerReference<Record<TJVMK, TJVMV>>, IDisposable

Type Parameters

K

The key type

V

The value type

TJVMK

The JVM type of K

TJVMV

The JVM type of V

Inheritance

object

Record<K, V, TJVMK, TJVMV>

Implements

IKNetInnerReference<Record<TJVMK, TJVMV>>

IDisposable

Properties

DateTime

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#timestamp()

public DateTime DateTime { get; }

Property Value

DateTime

Headers

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#headers()

public Headers Headers { get; }

Property Value

Headers

Headers

InnerReference

The underlying inner reference used from KNet object instance

public Record<TJVMK, TJVMV> InnerReference { get; }

Property Value

Record<TJVMK, TJVMV>

Key

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#key()

public K Key { get; }

Property Value

K

K

Timestamp

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#timestamp()

public long Timestamp { get; }

Property Value

long

Value

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#value()

public V Value { get; }

Property Value

V

V

Methods

CheckDisposed()

Test if this instance was disposed

protected void CheckDisposed()

Exceptions

ObjectDisposedException

When this instance was disposed

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

Dispose(bool)

Implements the pattern described in https://learn.microsoft.com/en-en/dotnet/standard/garbage-collection/implementing-dispose

protected virtual void Dispose(bool disposing)

Parameters

disposing bool

The disposing parameter is a bool that indicates whether the method call comes from a Dispose() method (its value is true) or from a finalizer (its value is false)

WithDateTime(DateTime)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#withTimestamp(long)

public Record<K, V, TJVMK, TJVMV> WithDateTime(DateTime arg0)

Parameters

arg0 DateTime

long

Returns

Record<K, V, TJVMK, TJVMV>

Record<K, V, TJVMK, TJVMV>

WithHeaders(Headers)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#withHeaders(org.apache.kafka.common.header.Headers)

public Record<K, V, TJVMK, TJVMV> WithHeaders(Headers arg0)

Parameters

arg0 Headers

Headers

Returns

Record<K, V, TJVMK, TJVMV>

Record<K, V, TJVMK, TJVMV>

WithKey<NewK, TJVMNewK>(NewK)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#withKey(java.lang.Object)

public Record<NewK, V, TJVMNewK, TJVMV> WithKey<NewK, TJVMNewK>(NewK arg0)

Parameters

arg0 NewK

NewK

Returns

Record<NewK, V, TJVMNewK, TJVMV>

Record<K, V, TJVMK, TJVMV>

Type Parameters

NewK

TJVMNewK

The JVM type of NewK

WithTimestamp(long)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#withTimestamp(long)

public Record<K, V, TJVMK, TJVMV> WithTimestamp(long arg0)

Parameters

arg0 long

long

Returns

Record<K, V, TJVMK, TJVMV>

Record<K, V, TJVMK, TJVMV>

WithValue<NewV, TJVMNewV>(NewV)

https://www.javadoc.io/doc/org.apache.kafka/kafka-streams/4.2.1/org/apache/kafka/streams/processor/api/Record.html#withValue(java.lang.Object)

public Record<K, NewV, TJVMK, TJVMNewV> WithValue<NewV, TJVMNewV>(NewV arg0)

Parameters

arg0 NewV

NewV

Returns

Record<K, NewV, TJVMK, TJVMNewV>

Record<K, V, TJVMK, TJVMV>

Type Parameters

NewV

TJVMNewV

The JVM type of NewV

Operators

implicit operator Record<TJVMK, TJVMV>(Record<K, V, TJVMK, TJVMV>)

Converter from Record<K, V, TJVMK, TJVMV> to Record<K, V>

public static implicit operator Record<TJVMK, TJVMV>(Record<K, V, TJVMK, TJVMV> t)

Parameters

t Record<K, V, TJVMK, TJVMV>

Returns

Record<TJVMK, TJVMV>