Documentation ¶
Index ¶
- type ShardReduce
- func (sr *ShardReduce) Filter(fFunc func(string, interface{}) bool) *ShardReduce
- func (sr *ShardReduce) Get() *map[string]*interface{}
- func (sr *ShardReduce) Map(mapFunc func(string, interface{}) interface{}) *ShardReduce
- func (sr *ShardReduce) NewInput(input *map[string]*interface{}) *ShardReduce
- func (sr *ShardReduce) Reduce(reduceFunc func(string, interface{}, string, interface{}) interface{}) interface{}
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ShardReduce ¶
type ShardReduce struct {
// contains filtered or unexported fields
}
func NewShardReduce ¶
func NewShardReduce(input *map[string]*interface{}) *ShardReduce
func (*ShardReduce) Filter ¶
func (sr *ShardReduce) Filter(fFunc func(string, interface{}) bool) *ShardReduce
func (*ShardReduce) Get ¶
func (sr *ShardReduce) Get() *map[string]*interface{}
func (*ShardReduce) Map ¶
func (sr *ShardReduce) Map(mapFunc func(string, interface{}) interface{}) *ShardReduce
func (*ShardReduce) NewInput ¶
func (sr *ShardReduce) NewInput(input *map[string]*interface{}) *ShardReduce
func (*ShardReduce) Reduce ¶
func (sr *ShardReduce) Reduce(reduceFunc func(string, interface{}, string, interface{}) interface{}) interface{}
Click to show internal directories.
Click to hide internal directories.