beam: github.com/apache/beam/sdks/go/pkg/beam/core/runtime/xlangx Index | Files

package xlangx

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

Index

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

Package xlangx imports 13 packages (graph) and is imported by 2 packages. Updated 2020-12-07. Refresh now. Tools for package owners.