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));
    }
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