Class SinkRecord<TKey, TValue>

Namespace: Org.Apache.Kafka.Connect.Sink

Assembly: MASES.KNet.dll

Extension of ConnectRecord<R, TKey, TValue>

public class SinkRecord<TKey, TValue> : ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition

Type Parameters

TKey
TValue

Inheritance: object

DynamicObject

JVMBridgeBase

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>

SinkRecord<TKey, TValue>

Implements: IDynamicMetaObjectProvider

IJVMBridgeCore

IDisposable

IJVMBridgeBaseStatic

IJVMBridgeBase

IJVMBridgeDefinition

Inherited Members: ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.IsBridgeAbstract

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.BridgeClassName

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.Topic

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.KafkaPartition

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.Key

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.KeySchema

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.Value

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.ValueSchema

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.Timestamp

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.Headers

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.NewRecord(string, int, Schema, TKey, Schema, TValue, DateTime)

ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>.NewRecord(string, int, Schema, TKey, Schema, TValue, DateTime, Headers)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TReturn>(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TReturn>(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute(Type, IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature(Type, IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute(Type, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature(Type, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TNewClass, TReturn>(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TNewClass, TReturn>(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TReturn>(Type, IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TReturn>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TReturn>(Type, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TReturn>(Type, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TNewClass, TReturn, TConverter>(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TReturn, TConverter>(Type, IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TReturn, TConverter>(Type, IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecute<TReturn, TConverter>(Type, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignature<TReturn, TConverter>(Type, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteArray<T>(IJavaType, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignatureArray<T>(IJavaType, string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteArray<T>(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SGetField(IJavaType, string)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SGetField(string)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SGetField<TReturn>(IJavaType, string)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SGetField<TReturn>(string)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SGetFieldArray<TReturn>(IJavaType, string)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SGetFieldArray<TReturn>(string)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SSetField(IJavaType, string, object)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SSetField(string, object)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SSetField<TValue>(IJavaType, string, TValue)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SSetField<TValue>(string, TValue)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.IsAssignableFrom(string)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.IsAssignableFrom(IJavaType)

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.IsAssignableFrom<T>()

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.New(params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.NewWithSignature(string, params object[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.Execute<T>(params T[])

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.DynBridgeClazz

JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.BridgeClazz

JVMBridgeBase.ClazzOf<TClass>(bool)

JVMBridgeBase.ClazzOf(string, bool)

JVMBridgeBase.RuntimeClassNameOf<T>()

JVMBridgeBase.ClassNameOf<T>()

JVMBridgeBase.ClassOf<T>()

JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps<TNewClass>(IJavaObject)

JVMBridgeBase.Wraps(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)

JVMBridgeBase.Wraps<TReturn>(Type, IJavaObject, string)

JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)

JVMBridgeBase.Wraps<TReturn, TConverter>(Type, IJavaObject)

JVMBridgeBase.MonitorEnter()

JVMBridgeBase.MonitorExit()

JVMBridgeBase.IsInstanceOf(string)

JVMBridgeBase.IsInstanceOf(IJavaType)

JVMBridgeBase.IsInstanceOf<T>()

JVMBridgeBase.RuntimeIsInstanceOf<T>()

JVMBridgeBase.CastTo<TNewClass>()

JVMBridgeBase.CastDirect<TNewClass>()

JVMBridgeBase.Execute<T>(params T[])

JVMBridgeBase.Dispose()

JVMBridgeBase.ToString()

JVMBridgeBase.Equals(object)

JVMBridgeBase.GetHashCode()

JVMBridgeBase.Notify()

JVMBridgeBase.NotifyAll()

JVMBridgeBase.Wait()

JVMBridgeBase.Wait(long)

JVMBridgeBase.Wait(long, int)

JVMBridgeBase.IExecute(string, params object[])

JVMBridgeBase.IExecuteWithSignature(string, string, params object[])

JVMBridgeBase.IExecute<TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn>(string, string, params object[])

JVMBridgeBase.IExecute<TNewClass, TReturn, TConverter>(string, params object[])

JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])

JVMBridgeBase.IExecuteArray<T>(string, params object[])

JVMBridgeBase.IExecuteWithSignatureArray<T>(string, string, params object[])

JVMBridgeBase.IGetField(string)

JVMBridgeBase.IGetField<TReturn>(string)

JVMBridgeBase.IGetFieldArray<TReturn>(string)

JVMBridgeBase.ISetField(string, object)

JVMBridgeBase.ISetField<TValue>(string, TValue)

JVMBridgeBase.DynBridgeInstance

JVMBridgeBase.BridgeInstance

JVMBridgeBase.IsBridgeInterface

JVMBridgeBase.IsBridgeStatic

JVMBridgeBase.IsBridgeCloseable

JVMBridgeBase.IsBridgeListener

DynamicObject.TryGetMember(GetMemberBinder, out object)

DynamicObject.TrySetMember(SetMemberBinder, object)

DynamicObject.TryDeleteMember(DeleteMemberBinder)

DynamicObject.TryInvokeMember(InvokeMemberBinder, object[], out object)

DynamicObject.TryConvert(ConvertBinder, out object)

DynamicObject.TryCreateInstance(CreateInstanceBinder, object[], out object)

DynamicObject.TryInvoke(InvokeBinder, object[], out object)

DynamicObject.TryBinaryOperation(BinaryOperationBinder, object, out object)

DynamicObject.TryUnaryOperation(UnaryOperationBinder, out object)

DynamicObject.TryGetIndex(GetIndexBinder, object[], out object)

DynamicObject.TrySetIndex(SetIndexBinder, object[], object)

DynamicObject.TryDeleteIndex(DeleteIndexBinder, object[])

DynamicObject.GetDynamicMemberNames()

DynamicObject.GetMetaObject(Expression)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetType()

object.MemberwiseClone()

Constructors

SinkRecord()

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

public SinkRecord()

SinkRecord(string, int, Schema, TKey, Schema, TValue, long)

https://www.javadoc.io/doc/org.apache.kafka/connect-api/3.5.0/org/apache/kafka/connect/connector/ConnectRecord.html#org.apache.kafka.connect.connector.ConnectRecord(java.lang.String,java.lang.Integer,org.apache.kafka.connect.data.Schema,java.lang.Object,org.apache.kafka.connect.data.Schema,java.lang.Object,java.lang.Long)

public SinkRecord(string topic, int partition, Schema keySchema, TKey key, Schema valueSchema, TValue value, long kafkaOffset)

Parameters

topic string
partition int
keySchema Schema
key TKey
valueSchema Schema
value TValue
kafkaOffset long

SinkRecord(string, int, Schema, TKey, Schema, TValue, long, DateTime, TimestampType)

public SinkRecord(string topic, int partition, Schema keySchema, TKey key, Schema valueSchema, TValue value, long kafkaOffset, DateTime timestamp, TimestampType timestampType)

Parameters

topic string
partition int
keySchema Schema
key TKey
valueSchema Schema
value TValue
kafkaOffset long
timestamp DateTime
timestampType TimestampType

SinkRecord(string, int, Schema, TKey, Schema, TValue, long, DateTime, TimestampType, Headers)

public SinkRecord(string topic, int partition, Schema keySchema, TKey key, Schema valueSchema, TValue value, long kafkaOffset, DateTime timestamp, TimestampType timestampType, Headers headers)

Parameters

topic string
partition int
keySchema Schema
key TKey
valueSchema Schema
value TValue
kafkaOffset long
timestamp DateTime
timestampType TimestampType
headers Headers

Properties

BridgeClassName

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm

public override string BridgeClassName { get; }

Property Value

string

IsBridgeAbstract

https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_IsBridgeAbstract.htm

public override bool IsBridgeAbstract { get; }

Property Value

bool

KafkaOffset

Offset in Kafka

public long KafkaOffset { get; }

Property Value

long

TimestampType

The TimestampType

public TimestampType TimestampType { get; }

Property Value

TimestampType

Operators

implicit operator SinkRecord(SinkRecord<TKey, TValue>)

Converts an SinkRecord<TKey, TValue> in SinkRecord

public static implicit operator SinkRecord(SinkRecord<TKey, TValue> source)

Parameters

source SinkRecord<TKey, TValue>: The SinkRecord<TKey, TValue> to convert

Returns

SinkRecord

Table of Contents

Class SinkRecord<TKey, TValue>

Type Parameters

Constructors

SinkRecord()

SinkRecord(string, int, Schema, TKey, Schema, TValue, long)

Parameters

SinkRecord(string, int, Schema, TKey, Schema, TValue, long, DateTime, TimestampType)

Parameters

SinkRecord(string, int, Schema, TKey, Schema, TValue, long, DateTime, TimestampType, Headers)

Parameters

Properties

BridgeClassName

Property Value

IsBridgeAbstract

Property Value

KafkaOffset

Property Value

TimestampType

Property Value

Operators

implicit operator SinkRecord(SinkRecord<TKey, TValue>)

Parameters

Returns