public < T extends Comparable < T > > Graph < T , NullValue , NullValue > simplify ( Graph < T , NullValue , NullValue > graph , int parallelism ) throws Exception { switch ( value ) { case DIRECTED : graph = graph . run ( new org . apache . flink . graph . asm . simple . directed . Simplify < T , NullValue , NullValue > ( ) . setParallelism ( parallelism ) ) ; break ; case UNDIRECTED : graph = graph . run ( new org . apache . flink . graph . asm . simple . undirected . Simplify < T , NullValue , NullValue > ( false ) . setParallelism ( parallelism ) ) ; break ; case UNDIRECTED_CLIP_AND_FLIP : graph = graph . run ( new org . apache . flink . graph . asm . simple . undirected . Simplify < T , NullValue , NullValue > ( true ) . setParallelism ( parallelism ) ) ; break ; } return graph ; }
Simplify the given graph based on the configured value .