private void execute ( ) throws Exception { if ( result == null ) { env . execute ( executionName ) ; } else { output . write ( executionName . toString ( ) , System . out , result ) ; } System . out . println ( ) ; algorithm . printAnalytics ( System . out ) ; if ( jobDetailsPath . getValue ( ) != null ) { writeJobDetails ( env , jobDetailsPath . getValue ( ) ) ; } }
Execute the Flink job .