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

Class CollectionDiscoveryUtils

java.lang.Object

org.apache.flink.cdc.connectors.mongodb.source.utils.CollectionDiscoveryUtils

public class CollectionDiscoveryUtils
extends Object

Utilities to discovery matched collections.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	CollectionDiscoveryUtils.CollectionDiscoveryInfo	Container class to hold discovered result.

Field Summary

Fields

Modifier and Type	Field	Description
static org.bson.conversions.Bson	ADD_NS_FIELD
static String	ADD_NS_FIELD_NAME
static String	REGEX_META_CHARACTERS

Method Summary

Modifier and Type	Method	Description
static java.util.function.Predicate<String>	anyMatch(List<Pattern> patterns)
static String	bsonListToJson(List<org.bson.conversions.Bson> bsonList)
static List<String>	collectionNames(com.mongodb.client.MongoClient mongoClient, List<String> databaseNames, java.util.function.Predicate<String> collectionFilter)
static <T> List<T>	collectionNames(com.mongodb.client.MongoClient mongoClient, List<String> databaseNames, java.util.function.Predicate<String> collectionFilter, java.util.function.Function<String,T> conversion)
static java.util.function.Predicate<String>	collectionsFilter(List<String> collectionList)
static Pattern	completionPattern(String pattern)
static boolean	containsRegexMetaCharacters(String literal)
static boolean	containsRegexRange(String literal)
static java.util.function.Predicate<String>	databaseFilter(List<String> databaseList)
static List<String>	databaseNames(com.mongodb.client.MongoClient mongoClient, java.util.function.Predicate<String> databaseFilter)
static Pattern	includeListAsFlatPattern(List<String> includeList)
static Pattern	includeListAsFlatPattern(List<String> includeList, java.util.function.Function<String,Pattern> conversion)
static List<Pattern>	includeListAsPatterns(List<String> includeList)
static List<Pattern>	includeListAsPatterns(List<String> includeList, java.util.function.Function<String,Pattern> convertion)
static boolean	inferIsRegularExpression(String literal)
static boolean	isIncludeListExplicitlySpecified(List<String> includeList, List<String> discoveredList)
static boolean	isNotBuiltInCollections(String fullName)
static boolean	isNotBuiltInDatabase(String databaseName)

Methods inherited from class java.lang.Object

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

Field Detail

REGEX_META_CHARACTERS

public static final String REGEX_META_CHARACTERS

See Also:

Constant Field Values

ADD_NS_FIELD_NAME

public static final String ADD_NS_FIELD_NAME

See Also:

Constant Field Values

ADD_NS_FIELD

public static final org.bson.conversions.Bson ADD_NS_FIELD

Method Detail

databaseNames

public static List<String> databaseNames(com.mongodb.client.MongoClient mongoClient,
                                         java.util.function.Predicate<String> databaseFilter)

collectionNames

public static List<String> collectionNames(com.mongodb.client.MongoClient mongoClient,
                                           List<String> databaseNames,
                                           java.util.function.Predicate<String> collectionFilter)

collectionNames

public static <T> List<T> collectionNames(com.mongodb.client.MongoClient mongoClient,
                                          List<String> databaseNames,
                                          java.util.function.Predicate<String> collectionFilter,
                                          java.util.function.Function<String,T> conversion)

databaseFilter

public static java.util.function.Predicate<String> databaseFilter(List<String> databaseList)

collectionsFilter

public static java.util.function.Predicate<String> collectionsFilter(List<String> collectionList)

anyMatch

public static java.util.function.Predicate<String> anyMatch(List<Pattern> patterns)

includeListAsFlatPattern

public static Pattern includeListAsFlatPattern(List<String> includeList)

includeListAsFlatPattern

public static Pattern includeListAsFlatPattern(List<String> includeList,
                                               java.util.function.Function<String,Pattern> conversion)

includeListAsPatterns

public static List<Pattern> includeListAsPatterns(List<String> includeList)

includeListAsPatterns

public static List<Pattern> includeListAsPatterns(List<String> includeList,
                                                  java.util.function.Function<String,Pattern> convertion)

isIncludeListExplicitlySpecified

public static boolean isIncludeListExplicitlySpecified(List<String> includeList,
                                                       List<String> discoveredList)

isNotBuiltInCollections

public static boolean isNotBuiltInCollections(String fullName)

isNotBuiltInDatabase

public static boolean isNotBuiltInDatabase(String databaseName)

containsRegexMetaCharacters

public static boolean containsRegexMetaCharacters(String literal)

containsRegexRange

public static boolean containsRegexRange(String literal)

inferIsRegularExpression

public static boolean inferIsRegularExpression(String literal)

completionPattern

public static Pattern completionPattern(String pattern)

bsonListToJson

public static String bsonListToJson(List<org.bson.conversions.Bson> bsonList)