entry

Documentation

Index

• Variables
• func Context(ctx ...context.Context) context.Context
• func Fields() (f []arrow.Field)
• func NewFileReader(r parquet.ReaderAtSeeker) *file.Reader
• func NewFileWriter(w io.Writer) *file.Writer
• type Entry
  • func NewEntry() *Entry
  • func (e *Entry) Clone() *Entry
  • func (e *Entry) Hit()
  • func (e *Entry) Release()
  • func (s *Entry) Update(e *Entry)
• type MultiEntry
  • func NewMulti() *MultiEntry
  • func (m *MultiEntry) Append(e *Entry)
  • func (m *MultiEntry) Len() int
  • func (m *MultiEntry) Release()
  • func (m *MultiEntry) Reset()
  • func (m *MultiEntry) Write(f *file.Writer, hash func(storev1.Column, parquet.ByteArray))
• type ReadResult
  • func ReadColumns(r *file.Reader, columns []storev1.Column, groups []int) (o []ReadResult)
• type Request

Variables

var All = Fields()

var ParquetSchema = parquetSchema()

var Pool = memory.NewGoAllocator()

var Schema = arrow.NewSchema(All, nil)

Functions

func Context

func Context(ctx ...context.Context) context.Context

func Fields

func Fields() (f []arrow.Field)

Fields for constructing arrow schema on Entry.

func NewFileReader

func NewFileReader(r parquet.ReaderAtSeeker) *file.Reader

func NewFileWriter

func NewFileWriter(w io.Writer) *file.Writer

Types

type Entry

type Entry struct {
	Bounce         int64
	Session        int64
	Browser        string
	BrowserVersion string
	City           string
	Country        string
	Domain         string
	Duration       time.Duration
	EntryPage      string
	ExitPage       string
	Host           string
	ID             uint64
	Event          string
	Os             string
	OsVersion      string
	Path           string
	Referrer       string
	ReferrerSource string
	Region         string
	Screen         string
	Timestamp      int64
	UtmCampaign    string
	UtmContent     string
	UtmMedium      string
	UtmSource      string
	UtmTerm        string
}

func NewEntry

func NewEntry() *Entry

func (*Entry) Clone

func (e *Entry) Clone() *Entry

func (*Entry) Hit

func (e *Entry) Hit()

func (*Entry) Release

func (e *Entry) Release()

func (*Entry) Update

func (s *Entry) Update(e *Entry)

type MultiEntry

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

func NewMulti

func NewMulti() *MultiEntry

func (*MultiEntry) Append

func (m *MultiEntry) Append(e *Entry)

func (*MultiEntry) Len

func (m *MultiEntry) Len() int

func (*MultiEntry) Release

func (m *MultiEntry) Release()

func (*MultiEntry) Reset

func (m *MultiEntry) Reset()

func (*MultiEntry) Write

func (m *MultiEntry) Write(f *file.Writer, hash func(storev1.Column, parquet.ByteArray))

type ReadResult

type ReadResult interface {
	Col() storev1.Column
	Len() int
	Value(int) any
}

func ReadColumns

func ReadColumns(r *file.Reader, columns []storev1.Column, groups []int) (o []ReadResult)

type Request

type Request = v1.Event