ObjectIdDiscoverer (flink-cdc-parent 3.8-SNAPSHOT API)

All Superinterfaces:

AutoCloseable, Serializable

All Known Subinterfaces:

TableDiscoverer

All Known Implementing Classes:

FlussDefaultDiscoverer, JdbcTableDiscoverer
```
@PublicEvolving
public interface ObjectIdDiscoverer<T>
extends Serializable, AutoCloseable
```
Pluggable abstraction for discovering a set of object identifiers.

Nested Class Summary

Nested Classes
Modifier and Type Interface Description

static interface ObjectIdDiscoverer.Context
Context providing runtime information for the discoverer.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`close()`	Closes this discoverer and releases any resources.
`Set<T>`	`discover()`	Discovers and returns the complete current set of object identifiers selected by the caller configuration.
`void`	`open(ObjectIdDiscoverer.Context context)`	Opens this discoverer and initializes any resources needed for discovery.

- Method Detail
  - open
```
void open(ObjectIdDiscoverer.Context context)
   throws Exception
```
    Opens this discoverer and initializes any resources needed for discovery.
    
    Throws:
    
    Exception
  - discover
```
Set<T> discover()
         throws Exception
```
    Discovers and returns the complete current set of object identifiers selected by the caller configuration.
    A successful result is authoritative: identifiers absent from it are no longer selected, and an empty result selects no identifiers. A failed discovery does not describe a new set.
    
    Throws:
    
    Exception
  - close
```
void close()
    throws Exception
```
    Closes this discoverer and releases any resources.
    
    Specified by:
    
    close in interface AutoCloseable
    
    Throws:
    
    Exception