Class TopologyConfig
public class TopologyConfig : AbstractConfig, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition
- Inheritance
-
JVMBridgeBaseJVMBridgeBase<AbstractConfig>TopologyConfig
- Implements
-
IJVMBridgeCoreIJVMBridgeBaseStaticIJVMBridgeBaseIJVMBridgeDefinition
- Inherited Members
-
JVMBridgeBase<AbstractConfig>.IsAssignableFrom(IJavaType)JVMBridgeBase<AbstractConfig>.IsAssignableFrom<T>()JVMBridgeBase<AbstractConfig>.Execute<T>(params T[])JVMBridgeBase<AbstractConfig>.DynBridgeClazzJVMBridgeBase<AbstractConfig>.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.Dispose()JVMBridgeBase.ToString()JVMBridgeBase.GetHashCode()JVMBridgeBase.Notify()JVMBridgeBase.NotifyAll()JVMBridgeBase.Wait()JVMBridgeBase.IExecuteWithSignature<TNewClass, TReturn, TConverter>(string, string, params object[])JVMBridgeBase.DynBridgeInstanceJVMBridgeBase.BridgeInstanceJVMBridgeBase.IsBridgeListener
Constructors
TopologyConfig()
Default constructor: even if the corresponding Java class does not have one, it is mandatory for JCOBridge
public TopologyConfig()
TopologyConfig(String, StreamsConfig, Properties)
public TopologyConfig(String arg0, StreamsConfig arg1, Properties arg2)
Parameters
arg0
Stringarg1
StreamsConfigarg2
Properties
TopologyConfig(StreamsConfig)
public TopologyConfig(StreamsConfig arg0)
Parameters
TopologyConfig(params object[])
Generic constructor: it is useful for JCOBridge when there is a derived class which needs to pass arguments to the highest JVMBridgeBase class
public TopologyConfig(params object[] args)
Parameters
args
object[]
Properties
BridgeClassName
https://www.jcobridge.com/api-clr/html/P_MASES_JCOBridge_C2JBridge_JVMBridgeBase_BridgeClassName.htm
public override string BridgeClassName { get; }
Property Value
GetTaskConfig
public TopologyConfig.TaskConfig GetTaskConfig { get; }
Property Value
IsBridgeAbstract
public override bool IsBridgeAbstract { get; }
Property Value
IsBridgeCloseable
public override bool IsBridgeCloseable { get; }
Property Value
IsBridgeInterface
public override bool IsBridgeInterface { get; }
Property Value
IsBridgeStatic
public override bool IsBridgeStatic { get; }
Property Value
applicationConfigs
public StreamsConfig applicationConfigs { get; }
Property Value
cacheSize
public long cacheSize { get; }
Property Value
deserializationExceptionHandlerSupplier
public Supplier deserializationExceptionHandlerSupplier { get; }
Property Value
dslStoreSuppliers
public Class dslStoreSuppliers { get; }
Property Value
eosEnabled
public bool eosEnabled { get; }
Property Value
maxBufferedSize
public int maxBufferedSize { get; }
Property Value
maxTaskIdleMs
public long maxTaskIdleMs { get; }
Property Value
processingExceptionHandlerSupplier
public Supplier processingExceptionHandlerSupplier { get; }
Property Value
storeType
public String storeType { get; }
Property Value
taskTimeoutMs
public long taskTimeoutMs { get; }
Property Value
timestampExtractorSupplier
public Supplier timestampExtractorSupplier { get; }
Property Value
topologyName
public String topologyName { get; }
Property Value
topologyOverrides
public Properties topologyOverrides { get; }
Property Value
Methods
IsNamedTopology()
public bool IsNamedTopology()
Returns
ResolveDslStoreSuppliers()
public Optional<DslStoreSuppliers> ResolveDslStoreSuppliers()