Package-level declarations
Types
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
data class ConnectionProfileMysqlProfile(val hostname: String, val password: String, val port: Int? = null, val sslConfig: ConnectionProfileMysqlProfileSslConfig? = null, val username: String)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
data class PrivateConnectionError(val details: Map<String, String>? = null, val message: String? = null)
Link copied to clipboard
Link copied to clipboard
data class StreamBackfillAll(val mysqlExcludedObjects: StreamBackfillAllMysqlExcludedObjects? = null, val oracleExcludedObjects: StreamBackfillAllOracleExcludedObjects? = null, val postgresqlExcludedObjects: StreamBackfillAllPostgresqlExcludedObjects? = null, val sqlServerExcludedObjects: StreamBackfillAllSqlServerExcludedObjects? = null)
Link copied to clipboard
data class StreamBackfillAllMysqlExcludedObjects(val mysqlDatabases: List<StreamBackfillAllMysqlExcludedObjectsMysqlDatabase>)
Link copied to clipboard
data class StreamBackfillAllMysqlExcludedObjectsMysqlDatabase(val database: String, val mysqlTables: List<StreamBackfillAllMysqlExcludedObjectsMysqlDatabaseMysqlTable>? = null)
Link copied to clipboard
data class StreamBackfillAllMysqlExcludedObjectsMysqlDatabaseMysqlTable(val mysqlColumns: List<StreamBackfillAllMysqlExcludedObjectsMysqlDatabaseMysqlTableMysqlColumn>? = null, val table: String)
Link copied to clipboard
Link copied to clipboard
data class StreamBackfillAllOracleExcludedObjects(val oracleSchemas: List<StreamBackfillAllOracleExcludedObjectsOracleSchema>)
Link copied to clipboard
data class StreamBackfillAllOracleExcludedObjectsOracleSchema(val oracleTables: List<StreamBackfillAllOracleExcludedObjectsOracleSchemaOracleTable>? = null, val schema: String)
Link copied to clipboard
data class StreamBackfillAllOracleExcludedObjectsOracleSchemaOracleTable(val oracleColumns: List<StreamBackfillAllOracleExcludedObjectsOracleSchemaOracleTableOracleColumn>? = null, val table: String)
Link copied to clipboard
data class StreamBackfillAllOracleExcludedObjectsOracleSchemaOracleTableOracleColumn(val column: String? = null, val dataType: String? = null, val encoding: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val precision: Int? = null, val primaryKey: Boolean? = null, val scale: Int? = null)
Link copied to clipboard
data class StreamBackfillAllPostgresqlExcludedObjects(val postgresqlSchemas: List<StreamBackfillAllPostgresqlExcludedObjectsPostgresqlSchema>)
Link copied to clipboard
data class StreamBackfillAllPostgresqlExcludedObjectsPostgresqlSchema(val postgresqlTables: List<StreamBackfillAllPostgresqlExcludedObjectsPostgresqlSchemaPostgresqlTable>? = null, val schema: String)
Link copied to clipboard
data class StreamBackfillAllPostgresqlExcludedObjectsPostgresqlSchemaPostgresqlTable(val postgresqlColumns: List<StreamBackfillAllPostgresqlExcludedObjectsPostgresqlSchemaPostgresqlTablePostgresqlColumn>? = null, val table: String)
Link copied to clipboard
data class StreamBackfillAllPostgresqlExcludedObjectsPostgresqlSchemaPostgresqlTablePostgresqlColumn(val column: String? = null, val dataType: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val precision: Int? = null, val primaryKey: Boolean? = null, val scale: Int? = null)
Link copied to clipboard
data class StreamBackfillAllSqlServerExcludedObjects(val schemas: List<StreamBackfillAllSqlServerExcludedObjectsSchema>)
Link copied to clipboard
data class StreamBackfillAllSqlServerExcludedObjectsSchema(val schema: String, val tables: List<StreamBackfillAllSqlServerExcludedObjectsSchemaTable>? = null)
Link copied to clipboard
data class StreamBackfillAllSqlServerExcludedObjectsSchemaTable(val columns: List<StreamBackfillAllSqlServerExcludedObjectsSchemaTableColumn>? = null, val table: String)
Link copied to clipboard
data class StreamBackfillAllSqlServerExcludedObjectsSchemaTableColumn(val column: String? = null, val dataType: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val precision: Int? = null, val primaryKey: Boolean? = null, val scale: Int? = null)
Link copied to clipboard
class StreamBackfillNone
Link copied to clipboard
data class StreamDestinationConfig(val bigqueryDestinationConfig: StreamDestinationConfigBigqueryDestinationConfig? = null, val destinationConnectionProfile: String, val gcsDestinationConfig: StreamDestinationConfigGcsDestinationConfig? = null)
Link copied to clipboard
data class StreamDestinationConfigBigqueryDestinationConfig(val appendOnly: StreamDestinationConfigBigqueryDestinationConfigAppendOnly? = null, val dataFreshness: String? = null, val merge: StreamDestinationConfigBigqueryDestinationConfigMerge? = null, val singleTargetDataset: StreamDestinationConfigBigqueryDestinationConfigSingleTargetDataset? = null, val sourceHierarchyDatasets: StreamDestinationConfigBigqueryDestinationConfigSourceHierarchyDatasets? = null)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
data class StreamDestinationConfigBigqueryDestinationConfigSingleTargetDataset(val datasetId: String)
Link copied to clipboard
Link copied to clipboard
data class StreamDestinationConfigBigqueryDestinationConfigSourceHierarchyDatasetsDatasetTemplate(val datasetIdPrefix: String? = null, val kmsKeyName: String? = null, val location: String)
Link copied to clipboard
data class StreamDestinationConfigGcsDestinationConfig(val avroFileFormat: StreamDestinationConfigGcsDestinationConfigAvroFileFormat? = null, val fileRotationInterval: String? = null, val fileRotationMb: Int? = null, val jsonFileFormat: StreamDestinationConfigGcsDestinationConfigJsonFileFormat? = null, val path: String? = null)
Link copied to clipboard
Link copied to clipboard
data class StreamDestinationConfigGcsDestinationConfigJsonFileFormat(val compression: String? = null, val schemaFileFormat: String? = null)
Link copied to clipboard
data class StreamSourceConfig(val mysqlSourceConfig: StreamSourceConfigMysqlSourceConfig? = null, val oracleSourceConfig: StreamSourceConfigOracleSourceConfig? = null, val postgresqlSourceConfig: StreamSourceConfigPostgresqlSourceConfig? = null, val sourceConnectionProfile: String, val sqlServerSourceConfig: StreamSourceConfigSqlServerSourceConfig? = null)
Link copied to clipboard
data class StreamSourceConfigMysqlSourceConfig(val excludeObjects: StreamSourceConfigMysqlSourceConfigExcludeObjects? = null, val includeObjects: StreamSourceConfigMysqlSourceConfigIncludeObjects? = null, val maxConcurrentBackfillTasks: Int? = null, val maxConcurrentCdcTasks: Int? = null)
Link copied to clipboard
data class StreamSourceConfigMysqlSourceConfigExcludeObjects(val mysqlDatabases: List<StreamSourceConfigMysqlSourceConfigExcludeObjectsMysqlDatabase>)
Link copied to clipboard
data class StreamSourceConfigMysqlSourceConfigExcludeObjectsMysqlDatabase(val database: String, val mysqlTables: List<StreamSourceConfigMysqlSourceConfigExcludeObjectsMysqlDatabaseMysqlTable>? = null)
Link copied to clipboard
data class StreamSourceConfigMysqlSourceConfigExcludeObjectsMysqlDatabaseMysqlTable(val mysqlColumns: List<StreamSourceConfigMysqlSourceConfigExcludeObjectsMysqlDatabaseMysqlTableMysqlColumn>? = null, val table: String)
Link copied to clipboard
data class StreamSourceConfigMysqlSourceConfigExcludeObjectsMysqlDatabaseMysqlTableMysqlColumn(val collation: String? = null, val column: String? = null, val dataType: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val primaryKey: Boolean? = null)
Link copied to clipboard
data class StreamSourceConfigMysqlSourceConfigIncludeObjects(val mysqlDatabases: List<StreamSourceConfigMysqlSourceConfigIncludeObjectsMysqlDatabase>)
Link copied to clipboard
data class StreamSourceConfigMysqlSourceConfigIncludeObjectsMysqlDatabase(val database: String, val mysqlTables: List<StreamSourceConfigMysqlSourceConfigIncludeObjectsMysqlDatabaseMysqlTable>? = null)
Link copied to clipboard
data class StreamSourceConfigMysqlSourceConfigIncludeObjectsMysqlDatabaseMysqlTable(val mysqlColumns: List<StreamSourceConfigMysqlSourceConfigIncludeObjectsMysqlDatabaseMysqlTableMysqlColumn>? = null, val table: String)
Link copied to clipboard
data class StreamSourceConfigMysqlSourceConfigIncludeObjectsMysqlDatabaseMysqlTableMysqlColumn(val collation: String? = null, val column: String? = null, val dataType: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val primaryKey: Boolean? = null)
Link copied to clipboard
data class StreamSourceConfigOracleSourceConfig(val dropLargeObjects: StreamSourceConfigOracleSourceConfigDropLargeObjects? = null, val excludeObjects: StreamSourceConfigOracleSourceConfigExcludeObjects? = null, val includeObjects: StreamSourceConfigOracleSourceConfigIncludeObjects? = null, val maxConcurrentBackfillTasks: Int? = null, val maxConcurrentCdcTasks: Int? = null, val streamLargeObjects: StreamSourceConfigOracleSourceConfigStreamLargeObjects? = null)
Link copied to clipboard
Link copied to clipboard
data class StreamSourceConfigOracleSourceConfigExcludeObjects(val oracleSchemas: List<StreamSourceConfigOracleSourceConfigExcludeObjectsOracleSchema>)
Link copied to clipboard
data class StreamSourceConfigOracleSourceConfigExcludeObjectsOracleSchema(val oracleTables: List<StreamSourceConfigOracleSourceConfigExcludeObjectsOracleSchemaOracleTable>? = null, val schema: String)
Link copied to clipboard
data class StreamSourceConfigOracleSourceConfigExcludeObjectsOracleSchemaOracleTable(val oracleColumns: List<StreamSourceConfigOracleSourceConfigExcludeObjectsOracleSchemaOracleTableOracleColumn>? = null, val table: String)
Link copied to clipboard
data class StreamSourceConfigOracleSourceConfigExcludeObjectsOracleSchemaOracleTableOracleColumn(val column: String? = null, val dataType: String? = null, val encoding: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val precision: Int? = null, val primaryKey: Boolean? = null, val scale: Int? = null)
Link copied to clipboard
data class StreamSourceConfigOracleSourceConfigIncludeObjects(val oracleSchemas: List<StreamSourceConfigOracleSourceConfigIncludeObjectsOracleSchema>)
Link copied to clipboard
data class StreamSourceConfigOracleSourceConfigIncludeObjectsOracleSchema(val oracleTables: List<StreamSourceConfigOracleSourceConfigIncludeObjectsOracleSchemaOracleTable>? = null, val schema: String)
Link copied to clipboard
data class StreamSourceConfigOracleSourceConfigIncludeObjectsOracleSchemaOracleTable(val oracleColumns: List<StreamSourceConfigOracleSourceConfigIncludeObjectsOracleSchemaOracleTableOracleColumn>? = null, val table: String)
Link copied to clipboard
data class StreamSourceConfigOracleSourceConfigIncludeObjectsOracleSchemaOracleTableOracleColumn(val column: String? = null, val dataType: String? = null, val encoding: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val precision: Int? = null, val primaryKey: Boolean? = null, val scale: Int? = null)
Link copied to clipboard
Link copied to clipboard
data class StreamSourceConfigPostgresqlSourceConfig(val excludeObjects: StreamSourceConfigPostgresqlSourceConfigExcludeObjects? = null, val includeObjects: StreamSourceConfigPostgresqlSourceConfigIncludeObjects? = null, val maxConcurrentBackfillTasks: Int? = null, val publication: String, val replicationSlot: String)
Link copied to clipboard
data class StreamSourceConfigPostgresqlSourceConfigExcludeObjects(val postgresqlSchemas: List<StreamSourceConfigPostgresqlSourceConfigExcludeObjectsPostgresqlSchema>)
Link copied to clipboard
data class StreamSourceConfigPostgresqlSourceConfigExcludeObjectsPostgresqlSchema(val postgresqlTables: List<StreamSourceConfigPostgresqlSourceConfigExcludeObjectsPostgresqlSchemaPostgresqlTable>? = null, val schema: String)
Link copied to clipboard
data class StreamSourceConfigPostgresqlSourceConfigExcludeObjectsPostgresqlSchemaPostgresqlTable(val postgresqlColumns: List<StreamSourceConfigPostgresqlSourceConfigExcludeObjectsPostgresqlSchemaPostgresqlTablePostgresqlColumn>? = null, val table: String)
Link copied to clipboard
data class StreamSourceConfigPostgresqlSourceConfigExcludeObjectsPostgresqlSchemaPostgresqlTablePostgresqlColumn(val column: String? = null, val dataType: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val precision: Int? = null, val primaryKey: Boolean? = null, val scale: Int? = null)
Link copied to clipboard
data class StreamSourceConfigPostgresqlSourceConfigIncludeObjects(val postgresqlSchemas: List<StreamSourceConfigPostgresqlSourceConfigIncludeObjectsPostgresqlSchema>)
Link copied to clipboard
data class StreamSourceConfigPostgresqlSourceConfigIncludeObjectsPostgresqlSchema(val postgresqlTables: List<StreamSourceConfigPostgresqlSourceConfigIncludeObjectsPostgresqlSchemaPostgresqlTable>? = null, val schema: String)
Link copied to clipboard
data class StreamSourceConfigPostgresqlSourceConfigIncludeObjectsPostgresqlSchemaPostgresqlTable(val postgresqlColumns: List<StreamSourceConfigPostgresqlSourceConfigIncludeObjectsPostgresqlSchemaPostgresqlTablePostgresqlColumn>? = null, val table: String)
Link copied to clipboard
data class StreamSourceConfigPostgresqlSourceConfigIncludeObjectsPostgresqlSchemaPostgresqlTablePostgresqlColumn(val column: String? = null, val dataType: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val precision: Int? = null, val primaryKey: Boolean? = null, val scale: Int? = null)
Link copied to clipboard
data class StreamSourceConfigSqlServerSourceConfig(val excludeObjects: StreamSourceConfigSqlServerSourceConfigExcludeObjects? = null, val includeObjects: StreamSourceConfigSqlServerSourceConfigIncludeObjects? = null, val maxConcurrentBackfillTasks: Int? = null, val maxConcurrentCdcTasks: Int? = null)
Link copied to clipboard
Link copied to clipboard
data class StreamSourceConfigSqlServerSourceConfigExcludeObjectsSchema(val schema: String, val tables: List<StreamSourceConfigSqlServerSourceConfigExcludeObjectsSchemaTable>? = null)
Link copied to clipboard
data class StreamSourceConfigSqlServerSourceConfigExcludeObjectsSchemaTable(val columns: List<StreamSourceConfigSqlServerSourceConfigExcludeObjectsSchemaTableColumn>? = null, val table: String)
Link copied to clipboard
data class StreamSourceConfigSqlServerSourceConfigExcludeObjectsSchemaTableColumn(val column: String? = null, val dataType: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val precision: Int? = null, val primaryKey: Boolean? = null, val scale: Int? = null)
Link copied to clipboard
Link copied to clipboard
data class StreamSourceConfigSqlServerSourceConfigIncludeObjectsSchema(val schema: String, val tables: List<StreamSourceConfigSqlServerSourceConfigIncludeObjectsSchemaTable>? = null)
Link copied to clipboard
data class StreamSourceConfigSqlServerSourceConfigIncludeObjectsSchemaTable(val columns: List<StreamSourceConfigSqlServerSourceConfigIncludeObjectsSchemaTableColumn>? = null, val table: String)
Link copied to clipboard
data class StreamSourceConfigSqlServerSourceConfigIncludeObjectsSchemaTableColumn(val column: String? = null, val dataType: String? = null, val length: Int? = null, val nullable: Boolean? = null, val ordinalPosition: Int? = null, val precision: Int? = null, val primaryKey: Boolean? = null, val scale: Int? = null)