package xlangx

import "github.com/apache/beam/sdks/go/pkg/beam/core/runtime/xlangx"

Index ¶

• func Expand(edge *graph.MultiEdge, ext *graph.ExternalTransform) error
• func ResolveArtifacts(ctx context.Context, edges []*graph.MultiEdge, p *pipepb.Pipeline)

Package Files ¶

expand.go namespace.go resolve.go

func Expand ¶ Uses

func Expand(edge *graph.MultiEdge, ext *graph.ExternalTransform) error

Expand expands an unexpanded graph.ExternalTransform as a graph.ExpandedTransform and assigns it to the ExternalTransform's Expanded field. This requires querying an expansion service based on the configuration details within the ExternalTransform.

func ResolveArtifacts ¶ Uses

func ResolveArtifacts(ctx context.Context, edges []*graph.MultiEdge, p *pipepb.Pipeline)

ResolveArtifacts acquires all dependencies for a cross-language transform