v1

Jul 31, 2024

Changes in this version

type ProfileRow

+ func (p ProfileRow) SetStacktracePartitionID(v uint64)

type Samples

+ func (s Samples) Range(n, m int) Samples

Jan 18, 2024

Changes in this version

+ const SamplesColumnName

+ const TotalValueColumnName

+ var DownsampledProfilesSchema = parquet.NewSchema("DownsampledProfile", phlareparquet.Group{ ... })

+ var SampleValueColumnPath = strings.Split("Samples.list.element.Value", ".")

+ type DownsampledProfileRow parquet.Row

+ func (p DownsampledProfileRow) ForValues(fn func([]parquet.Value))

type ProfileRow

+ func (p ProfileRow) ForStacktraceIdsAndValues(fn func([]parquet.Value, []parquet.Value))

Dec 15, 2023

Changes in this version

+ const SeriesIndexColumnName

+ const StacktracePartitionColumnName

+ const TimeNanosColumnName

Nov 16, 2023

Changes in this version

+ var ErrColumnNotFound = fmt.Errorf("column path not found")

+ func ResolveColumnByPath(schema *parquet.Schema, path []string) (parquet.LeafColumn, error)

type Sample

+ SpanID uint64

+ type SampleColumns struct

+ SpanID parquet.LeafColumn

+ StacktraceID parquet.LeafColumn

+ Value parquet.LeafColumn

+ func (c *SampleColumns) HasSpanID() bool

+ func (c *SampleColumns) Resolve(schema *parquet.Schema) error

type Samples

+ Spans []uint64

+ type SamplesBySpanID Samples

+ func (s SamplesBySpanID) Len() int

+ func (s SamplesBySpanID) Less(i, j int) bool

+ func (s SamplesBySpanID) Swap(i, j int)

Oct 10, 2023

Changes in this version

type InMemoryFunction

+ func (f *InMemoryFunction) Clone() *InMemoryFunction

type InMemoryLocation

+ func (l *InMemoryLocation) Clone() *InMemoryLocation

type InMemoryMapping

+ func (m *InMemoryMapping) Clone() *InMemoryMapping

Aug 29, 2023

Changes in this version

+ var ProfilesSchema = parquet.NewSchema("Profile", phlareparquet.Group{ ... })

+ func NewMergeProfilesRowReader(rowGroups []parquet.RowReader) parquet.RowReader

+ type FunctionPersister struct

+ func (*FunctionPersister) Deconstruct(row parquet.Row, _ uint64, fn *InMemoryFunction) parquet.Row

+ func (*FunctionPersister) Name() string

+ func (*FunctionPersister) Reconstruct(row parquet.Row) (uint64, *InMemoryFunction, error)

+ func (*FunctionPersister) Schema() *parquet.Schema

+ func (*FunctionPersister) SortingColumns() parquet.SortingOption

+ type InMemoryFunction struct

+ Filename uint32

+ Id uint64

+ Name uint32

+ StartLine uint32

+ SystemName uint32

+ type InMemoryLine struct

+ FunctionId uint32

+ Line int32

+ type InMemoryLocation struct

+ Address uint64

+ Id uint64

+ IsFolded bool

+ Line []InMemoryLine

+ MappingId uint32

+ type InMemoryMapping struct

+ BuildId uint32

+ FileOffset uint64

+ Filename uint32

+ HasFilenames bool

+ HasFunctions bool

+ HasInlineFrames bool

+ HasLineNumbers bool

+ Id uint64

+ MemoryLimit uint64

+ MemoryStart uint64

+ type InMemoryProfile struct

+ Comments []int64

+ DefaultSampleType int64

+ DropFrames int64

+ DurationNanos int64

+ ID uuid.UUID

+ KeepFrames int64

+ Period int64

+ Samples Samples

+ SeriesFingerprint model.Fingerprint

+ SeriesIndex uint32

+ StacktracePartition uint64

+ TimeNanos int64

+ TotalValue uint64

+ func (p InMemoryProfile) Size() uint64

+ func (p InMemoryProfile) Timestamp() model.Time

+ func (p InMemoryProfile) Total() int64

+ type LocationPersister struct

+ func (*LocationPersister) Deconstruct(row parquet.Row, _ uint64, loc *InMemoryLocation) parquet.Row

+ func (*LocationPersister) Name() string

+ func (*LocationPersister) Reconstruct(row parquet.Row) (uint64, *InMemoryLocation, error)

+ func (*LocationPersister) Schema() *parquet.Schema

+ func (*LocationPersister) SortingColumns() parquet.SortingOption

+ type MappingPersister struct

+ func (*MappingPersister) Deconstruct(row parquet.Row, _ uint64, m *InMemoryMapping) parquet.Row

+ func (*MappingPersister) Name() string

+ func (*MappingPersister) Reconstruct(row parquet.Row) (uint64, *InMemoryMapping, error)

+ func (*MappingPersister) Schema() *parquet.Schema

+ func (*MappingPersister) SortingColumns() parquet.SortingOption

+ type Models interface

+ type Persister interface

+ Deconstruct func(parquet.Row, uint64, T) parquet.Row

+ Reconstruct func(parquet.Row) (uint64, T, error)

+ Schema func() *parquet.Schema

+ SortingColumns func() parquet.SortingOption

+ type PersisterName interface

+ Name func() string

+ type Profile struct

+ Comments []int64

+ DefaultSampleType int64

+ DropFrames int64

+ DurationNanos int64

+ ID uuid.UUID

+ KeepFrames int64

+ Period int64

+ Samples []*Sample

+ SeriesFingerprint model.Fingerprint

+ SeriesIndex uint32

+ StacktracePartition uint64

+ TimeNanos int64

+ TotalValue uint64

+ func (p Profile) Timestamp() model.Time

+ func (p Profile) Total() int64

+ type ProfilePersister struct

+ func (*ProfilePersister) Deconstruct(row parquet.Row, id uint64, s *Profile) parquet.Row

+ func (*ProfilePersister) Name() string

+ func (*ProfilePersister) Reconstruct(row parquet.Row) (id uint64, s *Profile, err error)

+ func (*ProfilePersister) Schema() *parquet.Schema

+ func (*ProfilePersister) SortingColumns() parquet.SortingOption

+ type ProfileRow parquet.Row

+ func (p ProfileRow) ForStacktraceIDsValues(fn func([]parquet.Value))

+ func (p ProfileRow) SeriesIndex() uint32

+ func (p ProfileRow) SetSeriesIndex(v uint32)

+ func (p ProfileRow) StacktracePartitionID() uint64

+ func (p ProfileRow) TimeNanos() int64

+ type ReadWriter struct

+ func (*ReadWriter[T, P]) ReadParquetFile(file io.ReaderAt) ([]T, error)

+ func (*ReadWriter[T, P]) WriteParquetFile(file io.Writer, elements []T) error

+ type Sample struct

+ Labels []*profilev1.Label

+ StacktraceID uint64

+ Value int64

+ type SampleMap map[uint64]map[uint32]int64

+ func (m SampleMap) AddSamples(partition uint64, samples Samples)

+ func (m SampleMap) Partition(p uint64) map[uint32]int64

+ func (m SampleMap) WriteSamples(partition uint64, dst *Samples)

+ type Samples struct

+ StacktraceIDs []uint32

+ Values []uint64

+ func NewSamples(size int) Samples

+ func NewSamplesFromMap(m map[uint32]int64) Samples

+ func (s Samples) Clone() Samples

+ func (s Samples) Compact(dedupe bool) Samples

+ func (s Samples) Len() int

+ func (s Samples) Less(i, j int) bool

+ func (s Samples) Sum() uint64

+ func (s Samples) Swap(i, j int)

+ type SliceRowReader struct

+ func NewInMemoryProfilesRowReader(slice []InMemoryProfile) *SliceRowReader[InMemoryProfile]

+ func NewProfilesRowReader(slice []*Profile) *SliceRowReader[*Profile]

+ func (r *SliceRowReader[T]) ReadRows(rows []parquet.Row) (n int, err error)

+ type Stacktrace struct

+ LocationIDs []uint64

+ type StacktracePersister struct

+ func (*StacktracePersister) Deconstruct(row parquet.Row, id uint64, s *Stacktrace) parquet.Row

+ func (*StacktracePersister) Name() string

+ func (*StacktracePersister) Reconstruct(row parquet.Row) (id uint64, s *Stacktrace, err error)

+ func (*StacktracePersister) Schema() *parquet.Schema

+ func (*StacktracePersister) SortingColumns() parquet.SortingOption

+ type StringPersister struct

+ func (*StringPersister) Deconstruct(row parquet.Row, id uint64, s string) parquet.Row

+ func (*StringPersister) Name() string

+ func (*StringPersister) Reconstruct(row parquet.Row) (id uint64, s string, err error)

+ func (*StringPersister) Schema() *parquet.Schema

+ func (*StringPersister) SortingColumns() parquet.SortingOption