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, IGenericSerDesFactoryApplier
Type Parameters
K
The key type
V
The value type
TJVMK
The JVM type of
K
TJVMV
The JVM type of
V
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<JVMBridgeListener>JVMBridgeListenerTimestampExtractor<K, V, TJVMK, TJVMV>
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeListener.Dispose()JVMBridgeListener.AutoInitJVMBridgeListener.IsBridgeStaticJVMBridgeListener.IsBridgeCloseableJVMBridgeListener.IsBridgeListenerJVMBridgeBase<JVMBridgeListener>.IsAssignableFrom(IJavaType)JVMBridgeBase<JVMBridgeListener>.IsAssignableFrom<T>()JVMBridgeBase<JVMBridgeListener>.Execute<T>(params T[])JVMBridgeBase<JVMBridgeListener>.DynBridgeClazzJVMBridgeBase<JVMBridgeListener>.BridgeClazzJVMBridgeBase.RuntimeClassNameOf<T>()JVMBridgeBase.ClassNameOf<T>()JVMBridgeBase.ClassOf<T>()JVMBridgeBase.WrapsDirect<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn>(IJavaObject)JVMBridgeBase.Wraps<TNewClass, TReturn, TConverter>(IJavaObject)JVMBridgeBase.MonitorEnter()JVMBridgeBase.MonitorExit()JVMBridgeBase.IsInstanceOf(IJavaType)JVMBridgeBase.IsInstanceOf<T>()JVMBridgeBase.RuntimeIsInstanceOf<T>()JVMBridgeBase.CastTo<TNewClass>()JVMBridgeBase.CastDirect<TNewClass>()JVMBridgeBase.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeInterfaceJVMBridgeBase.IsBridgeAbstract
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
arg0
ConsumerRecord<object, object>arg1
long