Package org.apache.flink.cdc.connectors.mongodb.internal

Class MongoDBEnvelope

java.lang.Object

org.apache.flink.cdc.connectors.mongodb.internal.MongoDBEnvelope

public class MongoDBEnvelope
extends Object

An immutable descriptor for the structure of ChangeStreamDocument envelopes.

Field Summary

Fields

Modifier and Type	Field	Description
static org.bson.BsonValue	BSON_MAX_KEY
static org.bson.BsonValue	BSON_MIN_KEY
static String	CLUSTER_TIME_FIELD
static String	COPY_KEY_FIELD
static String	DATA_FIELD
static String	DOCUMENT_KEY_FIELD
static String	DROPPED_FIELD
static String	FULL_DOCUMENT_BEFORE_CHANGE_FIELD
static String	FULL_DOCUMENT_FIELD
static String	HEARTBEAT_KEY_FIELD
static String	HEARTBEAT_TOPIC_NAME
static org.apache.kafka.connect.data.Schema	HEARTBEAT_VALUE_SCHEMA
static String	ID_FIELD
static org.bson.BsonDocument	ID_INDEX
static org.bson.json.JsonWriterSettings	JSON_WRITER_SETTINGS_STRICT
static String	KEY_FIELD
static String	MAX_FIELD
static String	MIN_FIELD
static String	MONGODB_SCHEME
static String	MONGODB_SRV_SCHEME
static String	NAMESPACE_COLLECTION_FIELD
static String	NAMESPACE_DATABASE_FIELD
static String	NAMESPACE_FIELD
static String	OPERATION_TYPE_FIELD
static String	OUTPUT_SCHEMA
static String	SNAPSHOT_KEY_FIELD
static String	SOURCE_FIELD
static org.apache.kafka.connect.data.Schema	SOURCE_RECORD_KEY_SCHEMA
static org.apache.kafka.connect.data.Schema	SOURCE_RECORD_VALUE_SCHEMA
static String	TIMESTAMP_KEY_FIELD
static String	UUID_FIELD
static String	WATERMARK_TOPIC_NAME

Constructor Summary

Constructors

Constructor	Description
MongoDBEnvelope()

Method Summary

Modifier and Type	Method	Description
static String	encodeValue(String value)

Methods inherited from class java.lang.Object

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

Field Detail

MONGODB_SCHEME

public static final String MONGODB_SCHEME

See Also:

Constant Field Values

MONGODB_SRV_SCHEME

public static final String MONGODB_SRV_SCHEME

See Also:

Constant Field Values

ID_FIELD

public static final String ID_FIELD

See Also:

Constant Field Values

DATA_FIELD

public static final String DATA_FIELD

See Also:

Constant Field Values

UUID_FIELD

public static final String UUID_FIELD

See Also:

Constant Field Values

DROPPED_FIELD

public static final String DROPPED_FIELD

See Also:

Constant Field Values

KEY_FIELD

public static final String KEY_FIELD

See Also:

Constant Field Values

MAX_FIELD

public static final String MAX_FIELD

See Also:

Constant Field Values

MIN_FIELD

public static final String MIN_FIELD

See Also:

Constant Field Values

CLUSTER_TIME_FIELD

public static final String CLUSTER_TIME_FIELD

See Also:

Constant Field Values

FULL_DOCUMENT_FIELD

public static final String FULL_DOCUMENT_FIELD

See Also:

Constant Field Values

FULL_DOCUMENT_BEFORE_CHANGE_FIELD

public static final String FULL_DOCUMENT_BEFORE_CHANGE_FIELD

See Also:

Constant Field Values

DOCUMENT_KEY_FIELD

public static final String DOCUMENT_KEY_FIELD

See Also:

Constant Field Values

OPERATION_TYPE_FIELD

public static final String OPERATION_TYPE_FIELD

See Also:

Constant Field Values

NAMESPACE_FIELD

public static final String NAMESPACE_FIELD

See Also:

Constant Field Values

NAMESPACE_DATABASE_FIELD

public static final String NAMESPACE_DATABASE_FIELD

See Also:

Constant Field Values

NAMESPACE_COLLECTION_FIELD

public static final String NAMESPACE_COLLECTION_FIELD

See Also:

Constant Field Values

COPY_KEY_FIELD

public static final String COPY_KEY_FIELD

See Also:

Constant Field Values

SNAPSHOT_KEY_FIELD

public static final String SNAPSHOT_KEY_FIELD

See Also:

Constant Field Values

SOURCE_FIELD

public static final String SOURCE_FIELD

See Also:

Constant Field Values

TIMESTAMP_KEY_FIELD

public static final String TIMESTAMP_KEY_FIELD

See Also:

Constant Field Values

HEARTBEAT_KEY_FIELD

public static final String HEARTBEAT_KEY_FIELD

See Also:

Constant Field Values

HEARTBEAT_TOPIC_NAME

public static final String HEARTBEAT_TOPIC_NAME

See Also:

Constant Field Values

WATERMARK_TOPIC_NAME

public static final String WATERMARK_TOPIC_NAME

See Also:

Constant Field Values

OUTPUT_SCHEMA

public static final String OUTPUT_SCHEMA

See Also:

Constant Field Values

HEARTBEAT_VALUE_SCHEMA

public static final org.apache.kafka.connect.data.Schema HEARTBEAT_VALUE_SCHEMA

SOURCE_RECORD_KEY_SCHEMA

public static final org.apache.kafka.connect.data.Schema SOURCE_RECORD_KEY_SCHEMA

SOURCE_RECORD_VALUE_SCHEMA

public static final org.apache.kafka.connect.data.Schema SOURCE_RECORD_VALUE_SCHEMA

JSON_WRITER_SETTINGS_STRICT

public static final org.bson.json.JsonWriterSettings JSON_WRITER_SETTINGS_STRICT

ID_INDEX

public static final org.bson.BsonDocument ID_INDEX

BSON_MIN_KEY

public static final org.bson.BsonValue BSON_MIN_KEY

BSON_MAX_KEY

public static final org.bson.BsonValue BSON_MAX_KEY

Constructor Detail

MongoDBEnvelope

public MongoDBEnvelope()

Method Detail

encodeValue

public static String encodeValue(String value)