Documentation
¶
Index ¶
- Variables
- func Emit(anyObject ...interface{}) error
- func Init()
- func ListRegisteredFunctions()
- func ToBytes(val interface{}) []byte
- func ToFloat64(val interface{}) float64
- func ToInt64(val interface{}) int64
- func ToString(val interface{}) string
- func TsEmit(ts int64, anyObject ...interface{}) error
- func TsEmitKV(ts int64, keys, values []interface{}) error
- type Mapper
- type MapperId
- type MapperObject
- type Reducer
- type ReducerId
- type ReducerObject
Constants ¶
This section is empty.
Variables ¶
View Source
var (
HasInitalized bool
)
Functions ¶
func Emit ¶
func Emit(anyObject ...interface{}) error
Emit encode and write a row of data to os.Stdout
func Init ¶
func Init()
Init determines whether the driver program will execute the mapper/reducer or not. If the command line invokes the mapper or reducer, execute it and exit. This function will invoke flag.Parse() first.
func ListRegisteredFunctions ¶
func ListRegisteredFunctions()
ListRegisteredFunctions lists out all registered mappers and reducers
Types ¶
type MapperId ¶
type MapperId string
func RegisterMapper ¶
RegisterMapper register a mapper function to process a command
type MapperObject ¶
func GetMapper ¶
func GetMapper(mapperId MapperId) (mapper MapperObject, found bool)
type ReducerObject ¶
func GetReducer ¶
func GetReducer(reducerId ReducerId) (reducer ReducerObject, found bool)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.