()
| 293 | } |
| 294 | |
| 295 | func (n *NamespacedContextReader) Row() map[string]value.Value { |
| 296 | wraprow := make(map[string]value.Value) |
| 297 | sb := bytes.Buffer{} |
| 298 | |
| 299 | for k, v := range n.basereader.Row() { |
| 300 | sb.Reset() |
| 301 | sb.WriteString(n.namespace) |
| 302 | sb.WriteString(".") |
| 303 | sb.WriteString(k) |
| 304 | wraprow[sb.String()] = v |
| 305 | } |
| 306 | |
| 307 | return wraprow |
| 308 | } |
| 309 | |
| 310 | func (n *NamespacedContextReader) Ts() time.Time { |
| 311 | return n.basereader.Ts() |