Interface SourceConfig
-
- All Superinterfaces:
Serializable
- All Known Implementing Classes:
BaseSourceConfig,Db2SourceConfig,JdbcSourceConfig,MongoDBSourceConfig,OracleSourceConfig,PostgresSourceConfig,SqlServerSourceConfig
@Experimental public interface SourceConfig extends Serializable
The source configuration which offers basic source configuration.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interfaceSourceConfig.Factory<C extends SourceConfig>Factory for theSourceConfig.
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description intgetSplitMetaGroupSize()intgetSplitSize()StartupOptionsgetStartupOptions()booleanisAssignUnboundedChunkFirst()booleanisCloseIdleReaders()booleanisIncludeSchemaChanges()default booleanisReleaseSnapshotMetadataEnabled()Whether releasing the snapshot split metadata held by the source coordinator once the stream split is assembled and checkpoint-covered is enabled.booleanisScanNewlyAddedTableEnabled()booleanisSkipSnapshotBackfill()
-
-
-
Method Detail
-
getStartupOptions
StartupOptions getStartupOptions()
-
getSplitSize
int getSplitSize()
-
getSplitMetaGroupSize
int getSplitMetaGroupSize()
-
isIncludeSchemaChanges
boolean isIncludeSchemaChanges()
-
isCloseIdleReaders
boolean isCloseIdleReaders()
-
isSkipSnapshotBackfill
boolean isSkipSnapshotBackfill()
-
isScanNewlyAddedTableEnabled
boolean isScanNewlyAddedTableEnabled()
-
isAssignUnboundedChunkFirst
boolean isAssignUnboundedChunkFirst()
-
isReleaseSnapshotMetadataEnabled
default boolean isReleaseSnapshotMetadataEnabled()
Whether releasing the snapshot split metadata held by the source coordinator once the stream split is assembled and checkpoint-covered is enabled. Defaultfalseso existing jobs and configs that do not set the option are unaffected.
-
-