master

Documentation

Index

• type Context
  • func NewContext(isLocal bool, minWorkers int, masterPath string) *Context
  • func (c *Context) DoAction(plan []*protos.IPartition) []*protos.IPartitionResult
  • func (c *Context) InitContext()
• type Mafream
  • func NewDataFrame(c *Context, columns []string, numPartitions int) *Mafream
  • func (w *Mafream) Count() *Mafream
  • func (w *Mafream) Show() *Mafream
• type Master
  • func NewMaster(isLocal bool, host string, port int, minWorkers int) *Master
  • func (m *Master) Load() *Mafream
  • func (m *Master) Parallelize(data [][]string, option common.Options) *Mafream
  • func (m *Master) RegisterHandler(c *gin.Context)

Types

type Context

type Context struct {
	IsLocal bool
	Workers map[string]string
	// contains filtered or unexported fields
}

func NewContext

func NewContext(isLocal bool, minWorkers int, masterPath string) *Context

func (*Context) DoAction

func (c *Context) DoAction(plan []*protos.IPartition) []*protos.IPartitionResult

func (*Context) InitContext

func (c *Context) InitContext()

type Mafream

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

func NewDataFrame

func NewDataFrame(c *Context, columns []string, numPartitions int) *Mafream

func (*Mafream) Count

func (w *Mafream) Count() *Mafream

func (*Mafream) Show

func (w *Mafream) Show() *Mafream

type Master

type Master struct {
	MasterPath string

	Http *gin.Engine
	// contains filtered or unexported fields
}

func NewMaster

func NewMaster(isLocal bool, host string, port int, minWorkers int) *Master

func (*Master) Load

func (m *Master) Load() *Mafream

func (*Master) Parallelize

func (m *Master) Parallelize(data [][]string, option common.Options) *Mafream

func (*Master) RegisterHandler

func (m *Master) RegisterHandler(c *gin.Context)