3333public class ValidatingRecordConsumerTest {
3434
3535 private static final RecordConsumer NOOP = new RecordConsumer () {
36- @ Override public void startMessage () {}
37- @ Override public void endMessage () {}
38- @ Override public void startField (String field , int index ) {}
39- @ Override public void endField (String field , int index ) {}
40- @ Override public void startGroup () {}
41- @ Override public void endGroup () {}
42- @ Override public void addInteger (int value ) {}
43- @ Override public void addLong (long value ) {}
44- @ Override public void addBoolean (boolean value ) {}
45- @ Override public void addBinary (Binary value ) {}
46- @ Override public void addFloat (float value ) {}
47- @ Override public void addDouble (double value ) {}
36+ @ Override
37+ public void startMessage () {}
38+
39+ @ Override
40+ public void endMessage () {}
41+
42+ @ Override
43+ public void startField (String field , int index ) {}
44+
45+ @ Override
46+ public void endField (String field , int index ) {}
47+
48+ @ Override
49+ public void startGroup () {}
50+
51+ @ Override
52+ public void endGroup () {}
53+
54+ @ Override
55+ public void addInteger (int value ) {}
56+
57+ @ Override
58+ public void addLong (long value ) {}
59+
60+ @ Override
61+ public void addBoolean (boolean value ) {}
62+
63+ @ Override
64+ public void addBinary (Binary value ) {}
65+
66+ @ Override
67+ public void addFloat (float value ) {}
68+
69+ @ Override
70+ public void addDouble (double value ) {}
4871 };
4972
5073 @ Test
5174 public void testNoPreviousFieldLeakAfterMessage () throws Exception {
5275 MessageType schema = new MessageType (
53- "test" ,
54- new PrimitiveType (REQUIRED , INT32 , "a" ),
55- new PrimitiveType (REQUIRED , INT32 , "b" ));
76+ "test" , new PrimitiveType (REQUIRED , INT32 , "a" ), new PrimitiveType (REQUIRED , INT32 , "b" ));
5677
5778 ValidatingRecordConsumer consumer = new ValidatingRecordConsumer (NOOP , schema );
5879 Field previousFieldField = ValidatingRecordConsumer .class .getDeclaredField ("previousField" );
@@ -70,9 +91,7 @@ public void testNoPreviousFieldLeakAfterMessage() throws Exception {
7091
7192 Deque <?> previousField = (Deque <?>) previousFieldField .get (consumer );
7293 assertEquals (
73- "previousField deque should be empty after endMessage (row " + row + ")" ,
74- 0 ,
75- previousField .size ());
94+ "previousField deque should be empty after endMessage (row " + row + ")" , 0 , previousField .size ());
7695 }
7796 }
7897}
0 commit comments