Interface PipelineScopeBody

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
interface PipelineScopeBody

What runs inside a pipeline scope (StreamPipelineMachinery.withPipelineScope(List, boolean, String, DebugInfo, List, PipelineScopeBody)): given the scope, the element slot declared in it and the stages' pre-loop state (already emitted), it emits the pipeline's loop or drain.

Method Summary

Modifier and Type	Method	Description
void	emit(String pipelineScopeId, String pipelineItemVar, StageSetupResult stageSetup)

Method Details

emit

void emit(String pipelineScopeId,
 String pipelineItemVar,
 StageSetupResult stageSetup)