4
4
5
5
package io.airbyte.cdk.load.data
6
6
7
- import com.fasterxml.jackson.databind.node.JsonNodeFactory
8
7
import io.airbyte.cdk.load.command.Append
9
8
import io.airbyte.cdk.load.command.DestinationStream
10
9
import io.airbyte.cdk.load.message.EnrichedDestinationRecordAirbyteValue
@@ -28,50 +27,6 @@ class EnrichedDestinationRecordAirbyteValueTest {
28
27
29
28
private val emittedAtMs = 1234567890L
30
29
31
- @Test
32
- fun `test constructor with all parameters` () {
33
- val declaredFields =
34
- mapOf (
35
- " field1" to EnrichedAirbyteValue (StringValue (" value1" ), StringType , " field1" ),
36
- " field2" to EnrichedAirbyteValue (IntegerValue (42 ), IntegerType , " field2" )
37
- )
38
-
39
- val undeclaredFields =
40
- mapOf (
41
- " undeclared1" to JsonNodeFactory .instance.textNode(" value1" ),
42
- " undeclared2" to JsonNodeFactory .instance.numberNode(42 )
43
- )
44
-
45
- val meta =
46
- Meta (
47
- changes =
48
- listOf (
49
- Meta .Change (
50
- " field1" ,
51
- Change .TRUNCATED ,
52
- Reason .DESTINATION_RECORD_SIZE_LIMITATION
53
- )
54
- )
55
- )
56
-
57
- val record =
58
- EnrichedDestinationRecordAirbyteValue (
59
- stream = destinationStream,
60
- declaredFields = declaredFields,
61
- undeclaredFields = undeclaredFields,
62
- emittedAtMs = emittedAtMs,
63
- meta = meta,
64
- serializedSizeBytes = 1024L
65
- )
66
-
67
- assertEquals(destinationStream, record.stream)
68
- assertEquals(declaredFields, record.declaredFields)
69
- assertEquals(undeclaredFields, record.undeclaredFields)
70
- assertEquals(emittedAtMs, record.emittedAtMs)
71
- assertEquals(meta, record.meta)
72
- assertEquals(1024L , record.serializedSizeBytes)
73
- }
74
-
75
30
@Test
76
31
fun `test airbyteMetaFields property` () {
77
32
val record =
0 commit comments