Class SinkRefStageImpl<In>

  • All Implemented Interfaces:
    Graph<SinkShape<In>,​SourceRef<In>>

    public final class SinkRefStageImpl<In>
    extends GraphStageWithMaterializedValue<SinkShape<In>,​SourceRef<In>>
    INTERNAL API: Actual operator implementation backing SinkRefs.

    If initialPartnerRef is set, then the remote side is already set up. If it is none, then we are the side creating the ref.