2019-08-05 05:27
浏览 143


I have a Beam pipeline written in Go and I'd like to transform this input:

{"name": "Bob", "age": 32}

to a valid "object".

The go sdk has this function in the encoding package :

// UnmarshalJSON sets the state of this instance from the passed in JSON.
func (w *EncodedType) UnmarshalJSON(buf []byte) error {
    var s string
    if err := json.Unmarshal(buf, &s); err != nil {
        return err
    t, err := graphx.DecodeType(s)
    if err != nil {
        return err
    w.T = t
    return nil

But I don't understand how to use it as a step of my pipeline.

  • 写回答
  • 好问题 提建议
  • 追加酬金
  • 关注问题
  • 邀请回答

1条回答 默认 最新

相关推荐 更多相似问题