private ListIterator < List < Emit < E > > > elements ( SchemaTable schemaTable , SchemaTableTree rootSchemaTableTree ) { this . sqlgGraph . tx ( ) . readWrite ( ) ; if ( this . sqlgGraph . getSqlDialect ( ) . supportsBatchMode ( ) && this . sqlgGraph . tx ( ) . getBatchManager ( ) . isStreaming ( ) ) { throw new IllegalStateException ( "streaming is in progress, first flush or commit before querying." ) ; } this . replacedStepTree . maybeAddLabelToLeafNodes ( ) ; rootSchemaTableTree . setParentIdsAndIndexes ( this . schemaTableParentIds . get ( schemaTable ) ) ; Set < SchemaTableTree > rootSchemaTableTrees = new HashSet <> ( ) ; rootSchemaTableTrees . add ( rootSchemaTableTree ) ; return new SqlgCompiledResultListIterator <> ( new SqlgCompiledResultIterator <> ( this . sqlgGraph , rootSchemaTableTrees , true ) ) ; }
Called from SqlgVertexStepCompiler which compiled VertexStep and HasSteps . This is only called when not in BatchMode