Class SinkRecord<TKey, TValue>
Extension of ConnectRecord<R, TKey, TValue>
public class SinkRecord<TKey, TValue> : ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>, IDynamicMetaObjectProvider, IJVMBridgeCore, IEquatable<IJVMBridgeBase>, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinitionType Parameters
TKeyTValue
- Inheritance
-
ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>SinkRecord<TKey, TValue>
- Implements
- Inherited Members
-
JVMBridgeBase<ConnectRecord<SinkRecord<TKey, TValue>, TKey, TValue>>.SGetFieldArray<TReturn>(string)
Constructors
SinkRecord()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public SinkRecord()SinkRecord(IJVMBridgeBaseInitializer)
Internal constructor: used internally from JCOBridge
[Obsolete("This public initializer is needed for JCOBridge internal use, other uses can produce unidentible behaviors.")]
public SinkRecord(IJVMBridgeBaseInitializer initializer)Parameters
initializerIJVMBridgeBaseInitializer
SinkRecord(string, int, Schema, TKey, Schema, TValue, long)
public SinkRecord(string topic, int partition, Schema keySchema, TKey key, Schema valueSchema, TValue value, long kafkaOffset)Parameters
topicstringpartitionintkeySchemaSchemakeyTKeyvalueSchemaSchemavalueTValuekafkaOffsetlong
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
topicstringpartitionintkeySchemaSchemakeyTKeyvalueSchemaSchemavalueTValuekafkaOffsetlongtimestampDateTimetimestampTypeTimestampType
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
topicstringpartitionintkeySchemaSchemakeyTKeyvalueSchemaSchemavalueTValuekafkaOffsetlongtimestampDateTimetimestampTypeTimestampTypeheadersHeaders
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
KafkaOffset
Offset in Kafka
public long KafkaOffset { get; }Property Value
TimestampType
The TimestampType
public TimestampType TimestampType { get; }Property Value
Operators
implicit operator SinkRecord(SinkRecord<TKey, TValue>)
Converts an SinkRecord<TKey, TValue> in SinkRecord
public static implicit operator SinkRecord(SinkRecord<TKey, TValue> source)Parameters
sourceSinkRecord<TKey, TValue>The SinkRecord<TKey, TValue> to convert