public void foreachPartition ( final Action1 < PartitionState > action ) { int len = partitionStates . length ( ) ; for ( int i = 0 ; i < len ; i ++ ) { PartitionState ps = partitionStates . get ( i ) ; if ( ps == null ) { continue ; } action . call ( ps ) ; } }
Provides an iterator over all partitions calling the callback for each one .