gio

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 ToBytes ¶

func ToBytes(val interface{}) []byte

func ToFloat64 ¶

func ToFloat64(val interface{}) float64

func ToInt64 ¶

func ToInt64(val interface{}) int64

func ToString ¶

func ToString(val interface{}) string

func TsEmit ¶

func TsEmit(ts int64, anyObject ...interface{}) error

TsEmit encode and write a row of data to os.Stdout with ts in milliseconds epoch time

func TsEmitKV ¶

func TsEmitKV(ts int64, keys, values []interface{}) error