RecordDTO

constructor(fields: Map<String, AirbyteValue>, partitionKey: PartitionKey, sizeBytes: Long, emittedAtMs: Long)