server

Documentation

Index

• type Aggregate
  • func NewAggregate(maprLines chan<- string, queryStr string) (*Aggregate, error)
  • func (a *Aggregate) Close()
  • func (a *Aggregate) Serialize()

Types

type Aggregate

type Aggregate struct {
	// Log lines to process (parsing MAPREDUCE lines).
	Lines chan fs.LineRead
	// contains filtered or unexported fields
}

Aggregate is for aggregating mapreduce data on the DTail server side.

func NewAggregate

func NewAggregate(maprLines chan<- string, queryStr string) (*Aggregate, error)

NewAggregate return a new server side aggregator.

func (*Aggregate) Close

func (a *Aggregate) Close()

Close the aggregator.

func (*Aggregate) Serialize

func (a *Aggregate) Serialize()

Serialize all the aggregated data.