code: func (cf *countFunction) GetStreamResult() (d types.Datum) {
  	if cf.streamCtx == nil {
  		return types.NewDatum(0)
  	}
  	d.SetInt64(cf.streamCtx.Count)
  	cf.streamCtx = nil
  	return
  }
docs: // GetStreamResult implements AggregationFunction interface.