client

Documentation

Index

• type Aggregate
  • func NewAggregate(server string, query *mapr.Query, globalGroup *mapr.GlobalGroupSet) *Aggregate
  • func (a *Aggregate) Aggregate(parts []string)
  • func (a *Aggregate) Stop()

Types

type Aggregate

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

Aggregate mapreduce data on the DTail client side.

func NewAggregate

func NewAggregate(server string, query *mapr.Query, globalGroup *mapr.GlobalGroupSet) *Aggregate

NewAggregate create new client aggregator.

func (*Aggregate) Aggregate

func (a *Aggregate) Aggregate(parts []string)

Aggregate data from mapr log line into local (and global) group sets.

func (*Aggregate) Stop

func (a *Aggregate) Stop()

Stop the client side mapreduce aggregator.