public void fit ( IGraph < V , E > graph , int walkLength ) { if ( ! initCalled ) initialize ( graph ) ; //First: create iterators, one for each thread GraphWalkIteratorProvider < V > iteratorProvider = new RandomWalkGraphIteratorProvider <> ( graph , walkLength , seed , NoEdgeHandling . SELF_LOOP_ON_DISCONNECTED ) ; fit ( iteratorProvider ) ; }
Fit the model in parallel . This creates a set of GraphWalkIterators which are then distributed one to each thread