bulk-cdk-core-load/io.airbyte.cdk.load.util

Package-level declarations

Types

BigDecimalUtil

open class BigDecimalUtil

CloseableCoroutine

interface CloseableCoroutine

Jsons

object Jsons : ObjectMapper

TimeStringUtility

object TimeStringUtility

Collection of time/date string to time/date object conversion utilities.

UUIDGenerator

@Singleton

class UUIDGenerator

Custom UUID generator to avoid locking caused by the use of java.security.SecureRandom by the JDK UUID implementation by using better-performing UUID generators.

Functions

closeFinally

inline suspend fun CloseableCoroutine.closeFinally(cause: Throwable?)

deserializeToClass

fun <T> String.deserializeToClass(klass: Class<T>): T

deserializeToNode

fun String.deserializeToNode(): JsonNode

deserializeToPrettyPrintedString

fun <T> T.deserializeToPrettyPrintedString(): String

normalizedPrecision

fun BigDecimal.normalizedPrecision(): Int

Calculate the precision (i.e. number of digits) in this BigDecimal, according to how Bigquery represents it.

normalizedScale

fun BigDecimal.normalizedScale(): Int

Calculate the scale (i.e. number of decimal points) in this BigDecimal, according to how Bigquery represents it.

readIntoClass

fun <T> InputStream.readIntoClass(klass: Class<T>): T

serializeToJsonBytes

fun Any.serializeToJsonBytes(): ByteArray

serializeToString

fun <T> T.serializeToString(): String

setOnce

fun AtomicBoolean.setOnce(): Boolean

Set the latch exactly once. Return true iff this is the first time we've set it.

use

inline suspend fun <T : CloseableCoroutine, R> T.use(block: (T) -> R): R

write

fun OutputStream.write(string: String)