METHOD_0 ( ) { com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . redis . IDENT_2 conf = METHOD_1 ( ) ; conf . cache . IDENT_3 = false ; conf . uri = ( ( STRING_0 + ( com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . redis . IDENT_4 . redis . METHOD_2 ( ) ) ) + STRING_1 ) + ( com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . redis . IDENT_4 . redis . METHOD_3 ( com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . redis . IDENT_4 . IDENT_5 ) ) ; conf . IDENT_6 = com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . IDENT_7 . IDENT_8 ; com . streamsets . pipeline . api . IDENT_9 processor = new com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . redis . METHOD_4 ( conf ) ; com . streamsets . pipeline . sdk . IDENT_10 runner = new com . streamsets . pipeline . sdk . IDENT_10 . Builder ( com . streamsets . pipeline . IDENT_0 . processor . IDENT_1 . redis . IDENT_11 . class , processor ) . METHOD_5 ( STRING_2 ) . METHOD_6 ( IDENT_12 . IDENT_13 ) . build ( ) ; runner . METHOD_7 ( ) ; java . util . List < com . streamsets . pipeline . api . IDENT_14 > IDENT_15 = new java . util . ArrayList ( ) ; com . streamsets . pipeline . api . IDENT_14 record = com . streamsets . pipeline . sdk . IDENT_16 . create ( ) ; java . util . Map < java . lang . String , com . streamsets . pipeline . api . Field > fields = new java . util . HashMap ( ) ; fields . put ( STRING_3 , com . streamsets . pipeline . api . Field . create ( STRING_4 ) ) ; record . set ( com . streamsets . pipeline . api . Field . create ( fields ) ) ; IDENT_15 . add ( record ) ; runner . METHOD_8 ( IDENT_15 ) ; "<AssertPlaceHolder>" ; } METHOD_9 ( ) { return IDENT_17 ; }
org . junit . Assert . assertTrue ( ( ! ( runner . METHOD_9 ( ) . isEmpty ( ) ) ) )