Package-level declarations
Types
Link copied to clipboard
data class EndpointElasticsearchSettings(val endpointUri: String, val errorRetryDuration: Int? = null, val fullLoadErrorPercentage: Int? = null, val serviceAccessRoleArn: String)
Link copied to clipboard
data class EndpointKafkaSettings(val broker: String, val includeControlDetails: Boolean? = null, val includeNullAndEmpty: Boolean? = null, val includePartitionValue: Boolean? = null, val includeTableAlterOperations: Boolean? = null, val includeTransactionDetails: Boolean? = null, val messageFormat: String? = null, val messageMaxBytes: Int? = null, val noHexPrefix: Boolean? = null, val partitionIncludeSchemaTable: Boolean? = null, val saslPassword: String? = null, val saslUsername: String? = null, val securityProtocol: String? = null, val sslCaCertificateArn: String? = null, val sslClientCertificateArn: String? = null, val sslClientKeyArn: String? = null, val sslClientKeyPassword: String? = null, val topic: String? = null)
Link copied to clipboard
data class EndpointKinesisSettings(val includeControlDetails: Boolean? = null, val includeNullAndEmpty: Boolean? = null, val includePartitionValue: Boolean? = null, val includeTableAlterOperations: Boolean? = null, val includeTransactionDetails: Boolean? = null, val messageFormat: String? = null, val partitionIncludeSchemaTable: Boolean? = null, val serviceAccessRoleArn: String? = null, val streamArn: String? = null)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
data class EndpointS3Settings(val addColumnName: Boolean? = null, val bucketFolder: String? = null, val bucketName: String? = null, val cannedAclForObjects: String? = null, val cdcInsertsAndUpdates: Boolean? = null, val cdcInsertsOnly: Boolean? = null, val cdcMaxBatchInterval: Int? = null, val cdcMinFileSize: Int? = null, val cdcPath: String? = null, val compressionType: String? = null, val csvDelimiter: String? = null, val csvNoSupValue: String? = null, val csvNullValue: String? = null, val csvRowDelimiter: String? = null, val dataFormat: String? = null, val dataPageSize: Int? = null, val datePartitionDelimiter: String? = null, val datePartitionEnabled: Boolean? = null, val datePartitionSequence: String? = null, val dictPageSizeLimit: Int? = null, val enableStatistics: Boolean? = null, val encodingType: String? = null, val encryptionMode: String? = null, val externalTableDefinition: String? = null, val ignoreHeaderRows: Int? = null, val ignoreHeadersRow: Int? = null, val includeOpForFullLoad: Boolean? = null, val maxFileSize: Int? = null, val parquetTimestampInMillisecond: Boolean? = null, val parquetVersion: String? = null, val preserveTransactions: Boolean? = null, val rfc4180: Boolean? = null, val rowGroupLength: Int? = null, val serverSideEncryptionKmsKeyId: String? = null, val serviceAccessRoleArn: String? = null, val timestampColumnName: String? = null, val useCsvNoSupValue: Boolean? = null, val useTaskStartTimeForFullLoadTimestamp: Boolean? = null)