* true if the snapshotter should stream after taking a snapshot * true if the snapshotter should take a snapshot Void init(PostgresConnectorConfig config, OffsetState sourceInfo, * Implementations must return true for either #shouldSnapshot()} or #shouldStream()} * can provide more advanced functionality, such as partial snapshots. * a custom implementation of this interface can be provided by the implementor, which * While many default snapshot modes are provided with Debezium, * - What queries should be used to snapshot * This interface is used to determine details about the snapshot process: If you do not specify a type value, the signal fails to stop the incremental snapshot. If this component of the data field is omitted, the signal stops the entire incremental snapshot that is in progress.Ī required component of the data field of a signal that specifies the kind of snapshot operation that is to be stopped.Ĭurrently, the only valid option is incremental. Specifies type parameter specifies the operation that the signal is intended to trigger.Īn optional component of the data field of a signal that specifies an array of table names or regular expressions to match table names to remove from the snapshot. Descriptions of fields in a SQL command for sending a stop incremental snapshot signal to the signaling table Item The following table describes the parameters in the example: Table 5. In earlier Debezium releases, an explicit filter parameter was not defined for snapshot signals instead, filter criteria were implied by the values that were specified for the now deprecated additional-condition parameter. The values that you assign to the filter parameter are the same types of values that you might specify in the WHERE clause of SELECT statements when you set the property for a blocking snapshot. You can apply different filters to each table.įilter:: Specifies column values that must be present in a database record for the snapshot to include it, for example, "color='blue'". You can set the following parameters for each additional condition:ĭata-collection:: The fully-qualified name of the table that the filter applies to. * The data-collection property is the fully-qualified name of the data collection for which the filter will be applied.įor more information about the additional-conditions parameter, see Ad hoc incremental snapshots with additional-conditions.Īn optional array of additional conditions that specifies criteria that the connector evaluates to designate a subset of records to include in a snapshot.Įach additional condition is an object that specifies the criteria for filtering the data that an ad hoc snapshot captures. ![]() You can specify different filters for each data collection. If you do not specify a value, the connector runs an incremental snapshot.Īn optional array that specifies a set of additional conditions that the connector evaluates to determine the subset of records to include in a snapshot.Įach additional condition is an object with data-collection and filter properties. The array lists regular expressions which match tables by their fully-qualified names, using the same format as you use to specify the name of the connector’s signaling table in the configuration property.Īn optional type component of the data field of a signal that specifies the kind of snapshot operation to run.Ĭurrently, the only valid option is the default value, incremental. The type parameter specifies the operation that the signal is intended to trigger.Ī required component of the data field of a signal that specifies an array of table names or regular expressions to match table names to include in the snapshot. Rather, during the snapshot, Debezium generates its own id string as a watermarking signal. Use this string to identify logging messages to entries in the signaling table. The id parameter specifies an arbitrary string that is assigned as the id identifier for the signal request. Specifies the fully-qualified name of the signaling table on the source database. ![]() Descriptions of fields in a SQL command for sending an incremental snapshot signal to the signaling table Item ![]() The following table describes the parameters in the example: Table 3.
0 Comments
Leave a Reply. |
AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |