Package com.scaleoutsoftware.digitaltwin.datasource.kafka

Class ConnectorGridMetadata

java.lang.Object

com.scaleoutsoftware.digitaltwin.datasource.kafka.ConnectorGridMetadata

All Implemented Interfaces:

java.io.Serializable

public class ConnectorGridMetadata
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ConnectorGridMetadata(java.lang.String connectorName, com.scaleoutsoftware.digitaltwin.common.ConnectionType connectionType, java.util.Map<java.lang.String,java.lang.Object> kafkaProperties, java.util.Map<java.lang.String,java.lang.String> modelToKafkaTopicMap, java.util.Map<java.lang.String,java.lang.String> modelToProduceTopicMap)

Method Summary

Modifier and Type	Method	Description
static ConnectorGridMetadata	fromBytes(byte[] bytes)
java.lang.String	getConnectorNameInit()
com.scaleoutsoftware.digitaltwin.common.ConnectionType	getConnectorTypeInit()
java.util.Map<java.lang.String,java.lang.Object>	getKafkaProperties()
java.util.Map<java.lang.String,java.lang.String>	getModelToProduceTopicMap()
java.util.Map<java.lang.String,java.lang.String>	getModelToTopicMap()
static byte[]	toBytes(ConnectorGridMetadata metadata)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ConnectorGridMetadata

public ConnectorGridMetadata(java.lang.String connectorName,
                             com.scaleoutsoftware.digitaltwin.common.ConnectionType connectionType,
                             java.util.Map<java.lang.String,java.lang.Object> kafkaProperties,
                             java.util.Map<java.lang.String,java.lang.String> modelToKafkaTopicMap,
                             java.util.Map<java.lang.String,java.lang.String> modelToProduceTopicMap)

Method Detail

getConnectorNameInit

public java.lang.String getConnectorNameInit()

getConnectorTypeInit

public com.scaleoutsoftware.digitaltwin.common.ConnectionType getConnectorTypeInit()

getKafkaProperties

public java.util.Map<java.lang.String,java.lang.Object> getKafkaProperties()

getModelToTopicMap

public java.util.Map<java.lang.String,java.lang.String> getModelToTopicMap()

getModelToProduceTopicMap

public java.util.Map<java.lang.String,java.lang.String> getModelToProduceTopicMap()

toBytes

public static byte[] toBytes(ConnectorGridMetadata metadata)
                      throws java.io.IOException

Throws:

java.io.IOException

fromBytes

public static ConnectorGridMetadata fromBytes(byte[] bytes)
                                       throws java.io.IOException,
                                              java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object