Class TopologyConfig
public class TopologyConfig : AbstractConfig, IDynamicMetaObjectProvider, IJVMBridgeCore, IDisposable, IJVMBridgeBaseStatic, IJVMBridgeBase, IJVMBridgeDefinition- Inheritance
-
TopologyConfig
- Implements
- Inherited Members
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
arg0Stringarg1StreamsConfigarg2Properties
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
argsobject[]
Properties
BridgeClassName
Java class name to be instantiated
public override string BridgeClassName { get; }Property Value
GetTaskConfig
public TopologyConfig.TaskConfig GetTaskConfig { 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
IsBridgeCloseable
true if the BridgeClassName implements Closeable
public override bool IsBridgeCloseable { get; }Property Value
IsBridgeInterface
true if the BridgeClassName is an interface, i.e. does not have any public constructor
public override bool IsBridgeInterface { get; }Property Value
IsBridgeStatic
true if the BridgeClassName is a static class, i.e. does not have any public constructor
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()