Class TopicNameExtractor<K, V, TJVMK, TJVMV>
KNet implementation of TopicNameExtractor<K, V>
public class TopicNameExtractor<K, V, TJVMK, TJVMV> : TopicNameExtractor<TJVMK, TJVMV>, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, ITopicNameExtractor<TJVMK, TJVMV>, ITopicNameExtractor, IJVMBridgeBase, IJVMBridgeDefinition, IGenericSerDesFactoryApplier
Type Parameters
K
The key type
V
The value type
TJVMK
The JVM key type
TJVMV
The JVM value type
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<JVMBridgeListener>JVMBridgeListenerTopicNameExtractor<TJVMK, TJVMV>TopicNameExtractor<K, V, TJVMK, TJVMV>
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticITopicNameExtractor<TJVMK, TJVMV>IJVMBridgeBaseIJVMBridgeDefinition
- Derived
- Inherited Members
-
JVMBridgeListener.Dispose()JVMBridgeListener.BridgeClassNameJVMBridgeListener.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
Factory
Returns the current IGenericSerDesFactory
protected IGenericSerDesFactory Factory { get; }
Property Value
Key
The K
content
public virtual K Key { get; }
Property Value
- K
OnExtract
public Func<TopicNameExtractor<K, V, TJVMK, TJVMV>, string> OnExtract { get; set; }
Property Value
- Func<TopicNameExtractor<K, V, TJVMK, TJVMV>, string>
Remarks
RecordContext
Current RecordContext metadata of the record
public virtual RecordContext RecordContext { get; }
Property Value
Value
The V
content
public virtual V Value { get; }
Property Value
- V
Methods
Extract()
public virtual string Extract()
Returns
Extract(TJVMK, TJVMV, RecordContext)
public override sealed String Extract(TJVMK arg0, TJVMV arg1, RecordContext arg2)
Parameters
arg0
TJVMKK
arg1
TJVMVV
arg2
RecordContext