You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by he...@apache.org on 2018/07/30 16:05:13 UTC

[beam] 01/01: [BEAM-4726] Cache fixed per function Invoke values

This is an automated email from the ASF dual-hosted git repository.

herohde pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit 320183ba048a457e05fd1f84dd8a88fcc501d5e2
Merge: ff95a82 48454cc
Author: Henning Rohde <he...@seekerror.org>
AuthorDate: Mon Jul 30 09:05:08 2018 -0700

    [BEAM-4726] Cache fixed per function Invoke values

 sdks/go/pkg/beam/core/runtime/exec/fn.go         |  94 ++++++++++++----
 sdks/go/pkg/beam/core/runtime/exec/fn_test.go    | 136 +++++++++++++++++++++++
 sdks/go/pkg/beam/core/runtime/exec/pardo.go      |  53 +++++++--
 sdks/go/pkg/beam/core/runtime/exec/pardo_test.go |   2 +-
 4 files changed, 253 insertions(+), 32 deletions(-)