components

package
Version: v0.0.0-...-41680d7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 20, 2018 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewInMemoryFS

func NewInMemoryFS(numOfNodes, size int) mapreduce.FileSystem

Types

type InMemoryFS

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

func (*InMemoryFS) Files

func (f *InMemoryFS) Files(route string, ctx context.Context, meta []byte) (map[string][]string, error)

func (*InMemoryFS) Reader

func (f *InMemoryFS) Reader(name string, ctx context.Context, meta []byte) (func() ([]byte, error), error)

type InProcessNetwork

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

func NewInProcessNetwork

func NewInProcessNetwork(e *mapreduce.Executor) *InProcessNetwork

func (*InProcessNetwork) Execute

func (n *InProcessNetwork) Execute(file, algName, nodeID string, ctx context.Context, meta []byte) (result map[string][]byte, err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL