METHOD_0 ( ) { int IDENT_0 = 0 ; long offset = INT_0 ; java . util . List < org . apache . IDENT_1 . kafka . offset . hdfs . IDENT_2 . IDENT_3 > IDENT_4 = new java . util . METHOD_1 ( ) ; for ( int i = 0 ; i < 100 ; i ++ ) { IDENT_4 . add ( IDENT_2 . IDENT_3 . Builder . METHOD_2 ( ) . METHOD_3 ( ( STRING_0 + i ) ) . METHOD_4 ( IDENT_0 ) . METHOD_5 ( offset ) . build ( ) ) ; } org . apache . IDENT_1 . kafka . offset . hdfs . IDENT_2 IDENT_5 = IDENT_2 . Builder . METHOD_2 ( ) . METHOD_6 ( 10 ) . METHOD_7 ( IDENT_4 ) . build ( ) ; org . apache . commons . io . output . ByteArrayOutputStream IDENT_6 = new org . apache . commons . io . output . ByteArrayOutputStream ( ) ; org . apache . IDENT_1 . kafka . offset . hdfs . IDENT_7 . mapper . METHOD_8 ( IDENT_6 , IDENT_5 ) ; org . apache . IDENT_1 . kafka . offset . hdfs . IDENT_2 IDENT_8 = org . apache . IDENT_1 . kafka . offset . hdfs . IDENT_7 . mapper . METHOD_9 ( IDENT_6 . toByteArray ( ) , org . apache . IDENT_1 . kafka . offset . hdfs . IDENT_2 . class ) ; "<AssertPlaceHolder>" ; } build ( ) { return new org . apache . IDENT_1 . IDENT_9 . io . jdbc . IDENT_10 < T > ( IDENT_11 , IDENT_12 , url , IDENT_13 , IDENT_14 , IDENT_15 , IDENT_16 ) ; }
org . junit . Assert . assertThat ( IDENT_8 , org . hamcrest . core . Is . is ( IDENT_5 ) )