METHOD_0 ( ) { com . IDENT_0 . driver . core . ResultSet rs = org . apache . nifi . IDENT_1 . cassandra . IDENT_2 . METHOD_1 ( ) ; java . io . ByteArrayOutputStream IDENT_3 = new java . io . ByteArrayOutputStream ( ) ; long IDENT_4 = org . apache . nifi . IDENT_1 . cassandra . IDENT_5 . METHOD_2 ( rs , IDENT_3 , IDENT_6 . UTF_8 , 0 , null ) ; "<AssertPlaceHolder>" ; } METHOD_2 ( com . IDENT_0 . driver . core . ResultSet , java . io . IDENT_7 , java . nio . IDENT_8 . IDENT_9 , long , java . util . concurrent . TimeUnit ) { try { IDENT_10 . write ( STRING_0 . getBytes ( IDENT_8 ) ) ; final com . IDENT_0 . driver . core . IDENT_11 IDENT_12 = rs . METHOD_3 ( ) ; long IDENT_13 = 0 ; if ( IDENT_12 != null ) { do { int IDENT_14 = rs . METHOD_4 ( ) ; if ( IDENT_14 == 0 ) { if ( ( IDENT_15 <= 0 ) || ( IDENT_16 == null ) ) { rs . METHOD_5 ( ) . get ( ) ; } else { rs . METHOD_5 ( ) . get ( IDENT_15 , IDENT_16 ) ; } } for ( com . IDENT_0 . driver . core . IDENT_17 row : rs ) { if ( IDENT_13 != 0 ) { IDENT_10 . write ( STRING_1 FLOAT_0 getBytes ( IDENT_8 ) ) ; } IDENT_10 . write ( STRING_1 . getBytes ( IDENT_8 ) ) ; for ( int i = 0 ; i < ( IDENT_12 . size ( ) ) ; i ++ ) { final com . IDENT_0 . driver . core . IDENT_18 IDENT_19 = IDENT_12 . getType ( i ) ; final java . lang . String IDENT_20 = IDENT_12 . getName ( i ) ; if ( i != 0 ) { IDENT_10 . write ( STRING_1 FLOAT_0 getBytes ( IDENT_8 ) ) ; } if ( row . METHOD_6 ( i ) ) { IDENT_10 . write ( ( ( ( STRING_2 + IDENT_20 ) + STRING_2 ) + STRING_1 1 ) . getBytes ( IDENT_8 ) ) ; } else { java . lang . Object value = METHOD_7 ( row , i , IDENT_19 ) ; java . lang . String IDENT_21 ; if ( ( value instanceof java . util . List ) || ( value instanceof java . util . Set ) ) { boolean first = true ; java . lang . StringBuilder sb = new java . lang . StringBuilder ( STRING_3 ) ; for ( java . lang . Object element : ( ( java . util . Collection ) ( value ) ) ) { if ( ! first ) { sb . append ( STRING_1 2 ) ; } sb . append ( org . apache . nifi . IDENT_1 . cassandra . IDENT_5 . METHOD_8 ( element ) ) ; first = false ; } sb . append ( "]" ) ; IDENT_21 = sb . toString ( ) ; } else if ( value instanceof java . util . Map ) { boolean first = true ; java . lang . StringBuilder sb = new java . lang . StringBuilder ( STRING_1 ) ; for ( java . lang . Object element : ( ( java . util . Map ) ( value ) ) . entrySet ( ) ) { java . util . Map . Entry entry = ( ( java . util . Map . Entry ) ( element ) ) ; java . lang . Object IDENT_22 = entry . getKey ( ) ; java . lang . Object IDENT_23 = entry . getValue ( ) ; if ( ! first ) { sb . append ( STRING_1 2 ) ; } sb . append ( org . apache . nifi . IDENT_1 . cassandra . IDENT_5 . METHOD_8 ( IDENT_22 ) ) ; sb . append ( STRING_4 ) ; sb . append ( org . apache . nifi . IDENT_1 . cassandra . IDENT_5 . METHOD_8 ( IDENT_23 ) ) ; first = false ; } sb . append ( STRING_5 ) ; IDENT_21 = sb . toString ( ) ; } else { IDENT_21 = org . apache . nifi . IDENT_1 . cassandra . IDENT_5 . METHOD_8 ( value ) ; } IDENT_10 . write ( ( ( ( ( STRING_2 + IDENT_20 ) + STRING_6 ) + IDENT_21 ) + "" ) . getBytes ( IDENT_8 ) ) ; } } IDENT_13 += 1 ; IDENT_10 . write ( STRING_5 . getBytes ( IDENT_8 ) ) ; } } while ( ! ( rs . METHOD_9 ( ) ) ) ; } return IDENT_13 ; } finally { IDENT_10 . write ( STRING_7 . getBytes ( ) ) ; } }
org . junit . Assert . assertEquals ( 2 , IDENT_4 )