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

Class MongoDBSource

java.lang.Object

org.apache.flink.cdc.connectors.mongodb.MongoDBSource

@Deprecated
public class MongoDBSource
extends Object

Deprecated.

A builder to build a SourceFunction which can read snapshot and continue to consume change stream events.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MongoDBSource.Builder<T>	Deprecated. Builder class of MongoDBSource.

Field Summary

Fields

Modifier and Type	Field	Description
static String	FULL_DOCUMENT_REQUIRED	Deprecated.
static String	FULL_DOCUMENT_UPDATE_LOOKUP	Deprecated.
static String	OUTPUT_FORMAT_SCHEMA	Deprecated.

Constructor Summary

Constructors

Constructor	Description
MongoDBSource()	Deprecated.

Method Summary

Modifier and Type	Method	Description
static <T> MongoDBSource.Builder<T>	builder()	Deprecated.

Methods inherited from class java.lang.Object

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

Field Detail

FULL_DOCUMENT_UPDATE_LOOKUP

public static final String FULL_DOCUMENT_UPDATE_LOOKUP

Deprecated.

FULL_DOCUMENT_REQUIRED

public static final String FULL_DOCUMENT_REQUIRED

Deprecated.

OUTPUT_FORMAT_SCHEMA

public static final String OUTPUT_FORMAT_SCHEMA

Deprecated.

Constructor Detail

MongoDBSource

public MongoDBSource()

Deprecated.

Method Detail

builder

public static <T> MongoDBSource.Builder<T> builder()

Deprecated.