Package org.debezium.connector.mongodb.transforms

Class MongoDataConverter

java.lang.Object

org.debezium.connector.mongodb.transforms.MongoDataConverter

public class MongoDataConverter
extends Object

MongoDataConverter handles translating MongoDB strings to Kafka Connect schemas and row data to Kafka Connect records.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SCHEMA_NAME_REGEX

Constructor Summary

Constructors

Constructor	Description
MongoDataConverter(ArrayEncoding arrayEncoding)

Method Summary

Modifier and Type	Method	Description
void	addFieldSchema(Map.Entry<String,org.bson.BsonValue> keyValuesForSchema, org.apache.kafka.connect.data.SchemaBuilder builder)
protected String	arrayElementStructName(int index)
void	convertFieldValue(Map.Entry<String,org.bson.BsonValue> keyValueForStruct, org.apache.kafka.connect.data.Struct struct, org.apache.kafka.connect.data.Schema schema)
org.apache.kafka.connect.data.Struct	convertRecord(Map.Entry<String,org.bson.BsonValue> keyValueForStruct, org.apache.kafka.connect.data.Schema schema, org.apache.kafka.connect.data.Struct struct)

Methods inherited from class java.lang.Object

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

Field Details

SCHEMA_NAME_REGEX

public static final String SCHEMA_NAME_REGEX

See Also:

• Constant Field Values

Constructor Details

MongoDataConverter

public MongoDataConverter(ArrayEncoding arrayEncoding)

Method Details

convertRecord

public org.apache.kafka.connect.data.Struct convertRecord(Map.Entry<String,org.bson.BsonValue> keyValueForStruct,
 org.apache.kafka.connect.data.Schema schema,
 org.apache.kafka.connect.data.Struct struct)

convertFieldValue

public void convertFieldValue(Map.Entry<String,org.bson.BsonValue> keyValueForStruct,
 org.apache.kafka.connect.data.Struct struct,
 org.apache.kafka.connect.data.Schema schema)

arrayElementStructName

protected String arrayElementStructName(int index)

addFieldSchema

public void addFieldSchema(Map.Entry<String,org.bson.BsonValue> keyValuesForSchema,
 org.apache.kafka.connect.data.SchemaBuilder builder)