Class TimestampExtractor<K, V, TJVMK, TJVMV>
KNet extension of TimestampExtractor
public class TimestampExtractor<K, V, TJVMK, TJVMV> : TimestampExtractor, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, ITimestampExtractor, IJVMBridgeBase, IJVMBridgeDefinition, IGenericSerDesFactoryApplierType Parameters
KThe key type
VThe value type
TJVMKThe JVM type of
KTJVMVThe JVM type of
V
- Inheritance
-
TimestampExtractor<K, V, TJVMK, TJVMV>
- Implements
- Inherited Members
Properties
OnExtract
public Func<TimestampExtractor<K, V, TJVMK, TJVMV>, DateTime> OnExtract { get; set; }Property Value
- Func<TimestampExtractor<K, V, TJVMK, TJVMV>, DateTime>
Remarks
If OnExtract has a value it takes precedence over corresponding class method
PartitionTime
public DateTime? PartitionTime { get; }Property Value
Record
The ConsumerRecord<K, V, TJVMK, TJVMV> to be used
public ConsumerRecord<K, V, TJVMK, TJVMV> Record { get; }Property Value
- ConsumerRecord<K, V, TJVMK, TJVMV>
Methods
Extract()
KNet implementation of Extract(ConsumerRecord<object, object>, long)
public virtual DateTime Extract()Returns
Extract(ConsumerRecord<object, object>, long)
public override sealed long Extract(ConsumerRecord<object, object> arg0, long arg1)Parameters
arg0ConsumerRecord<object, object>arg1long