extractor

Documentation

Index

• type BQExtractor
  • func NewBQExtractor(client DDLViewGetter, l log.Logger) (*BQExtractor, error)
  • func (e BQExtractor) Extract(ctx context.Context, resourceURNs []bigquery.ResourceURN) (urnToDDLAll map[bigquery.ResourceURN]string, err error)
• type DDLViewGetter

Types

type BQExtractor

type BQExtractor struct {
	// contains filtered or unexported fields
}

func NewBQExtractor

func NewBQExtractor(client DDLViewGetter, l log.Logger) (*BQExtractor, error)

func (BQExtractor) Extract

func (e BQExtractor) Extract(ctx context.Context, resourceURNs []bigquery.ResourceURN) (urnToDDLAll map[bigquery.ResourceURN]string, err error)

Extract returns map of urns and its query string given list of urns It extract the corresponding query only if the urn is considered as a view

type DDLViewGetter

type DDLViewGetter interface {
	BulkGetDDLView(ctx context.Context, dataset bigquery.ProjectDataset, names []string) (map[bigquery.ResourceURN]string, error)
}