org.apache.flink.cdc.common.schema

接口 TableFilter

函数接口:

这是一个函数接口, 因此可用作 lambda 表达式或方法引用的赋值目标。

@FunctionalInterface
public interface TableFilter

A filter for tables.

方法概要

限定符和类型	方法和说明
static TableFilter	fromPredicate(java.util.function.Predicate<TableId> predicate) Creates a TableFilter from the given predicate.
static TableFilter	includeAll() Creates a TableFilter that includes all tables.
boolean	isIncluded(TableId tableId) Determines whether the given table should be included.

方法详细资料

isIncluded

boolean isIncluded(TableId tableId)

Determines whether the given table should be included.

fromPredicate

static TableFilter fromPredicate(java.util.function.Predicate<TableId> predicate)

Creates a TableFilter from the given predicate.

includeAll

static TableFilter includeAll()

Creates a TableFilter that includes all tables.