String function ( final String arg0 ) { if ( arg0 == null ) { throw new RuntimeException ( "srini_string" + "srini_string" ) ; } return arg0 ; }
in flink , jar files are submitted directly when a program is started . thus , this method does nothing . the returned value is parameter localjar , because this give the best integration of storm behavior within a flink environment . concode_field_sep Logger logger concode_field_sep void submitTopologyWithProgressBar concode_elem_sep void submitTopology concode_elem_sep void submitTopology