@@ -53,6 +53,11 @@ public void appendLine() throws IOException {
53
53
.name ("a" ).type ("string" ).noDefault ()
54
54
.endRecord ();
55
55
56
+ Schema conflictSchema = SchemaBuilder .record ("simple" ).fields ()
57
+ .name ("a" ).type ("string" ).noDefault ()
58
+ .name ("b" ).type ("string" ).noDefault ()
59
+ .endRecord ();
60
+
56
61
GenericRecord record ;
57
62
58
63
try (FileCacheStore cache = new FileCacheStore (csvFactory , 2 , false , false )) {
@@ -74,9 +79,13 @@ record = new GenericRecordBuilder(simpleSchema).set("a", "f4").build();
74
79
assertEquals (cache .writeRecord (f4 , record ), FileCacheStore .NO_CACHE_AND_WRITE );
75
80
record = new GenericRecordBuilder (simpleSchema ).set ("a" , "f3" ).build ();
76
81
assertEquals (cache .writeRecord (f3 , record ), FileCacheStore .CACHE_AND_WRITE );
82
+ record = new GenericRecordBuilder (conflictSchema ).set ("a" , "f3" ). set ("b" , "conflict" ).build ();
83
+ assertEquals (cache .writeRecord (f3 , record ), FileCacheStore .CACHE_AND_NO_WRITE );
84
+ record = new GenericRecordBuilder (conflictSchema ).set ("a" , "f1" ). set ("b" , "conflict" ).build ();
85
+ assertEquals (cache .writeRecord (f1 , record ), FileCacheStore .NO_CACHE_AND_WRITE );
77
86
}
78
87
79
- assertEquals ("a\n something\n somethingElse\n third\n " , new String (Files .readAllBytes (f1 )));
88
+ assertEquals ("a\n something\n somethingElse\n third\n f1,conflict \ n " , new String (Files .readAllBytes (f1 )));
80
89
assertEquals ("a\n something\n f2\n " , new String (Files .readAllBytes (f2 )));
81
90
assertEquals ("a\n f3\n f3\n f3\n " , new String (Files .readAllBytes (f3 )));
82
91
assertEquals ("a\n f4\n " , new String (Files .readAllBytes (f4 )));
0 commit comments