code: func TsEmit(ts int64, anyObject ...interface{}) error {
  	stat.Stats[0].OutputCounter++
  	return util.NewRow(ts, anyObject...).WriteTo(os.Stdout)
  }
docs: // TsEmit encode and write a row of data to os.Stdout
  // with ts in milliseconds epoch time