termfreqio

Documentation

Overview

termfreqio provides IO functions to write term frequency information to Firestore

Index

• type UpdateTermFreqDoc
  • func (f *UpdateTermFreqDoc) ProcessElement(ctx context.Context, entries []termfreq.TermFreqDoc)
  • func (f *UpdateTermFreqDoc) Setup()

Types

type UpdateTermFreqDoc

type UpdateTermFreqDoc struct {
	FbCol     string
	ProjectID string
	// contains filtered or unexported fields
}

UpdateTermFreqDoc is a ParDo that writes entries to Firestore

func (*UpdateTermFreqDoc) ProcessElement

func (f *UpdateTermFreqDoc) ProcessElement(ctx context.Context, entries []termfreq.TermFreqDoc)

ProcessElement writes the given entry to Firestore if it does not exist already

func (*UpdateTermFreqDoc) Setup

func (f *UpdateTermFreqDoc) Setup()

Setup establishes the client connection