[beam] branch asf-site updated: Publishing website 2021/10/13 06:06:04 at commit 71d7213
This is an automated email from the ASF dual-hosted git repository. git-site-role pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/asf-site by this push: new d0596f6 Publishing website 2021/10/13 06:06:04 at commit 71d7213 d0596f6 is described below commit d0596f6f645e53f75a02bf54291dd3807e323c46 Author: jenkins AuthorDate: Wed Oct 13 06:06:04 2021 + Publishing website 2021/10/13 06:06:04 at commit 71d7213 --- website/generated-content/documentation/index.xml | 121 - .../documentation/programming-guide/index.html | 36 +++--- website/generated-content/sitemap.xml | 2 +- 3 files changed, 138 insertions(+), 21 deletions(-) diff --git a/website/generated-content/documentation/index.xml b/website/generated-content/documentation/index.xml index e6c7c3d..73601a9 100644 --- a/website/generated-content/documentation/index.xml +++ b/website/generated-content/documentation/index.xml @@ -9600,12 +9600,17 @@ state. Merging windows are not currently supported when using state and timers.& care must be taken to remember that the elements in input PCollection have no guaranteed order and to ensure that the program logic is resilient to this. Unit tests written using the DirectRunner will shuffle the order of element processing, and are recommended to test for correctness. -In Java DoFn declares states to be accessed by creating final
StateSpec
member variables representing each state. Each +In Java, DoFn declares states to be accessed by creating final
-StateSpec
member variables representing each state. Each state must be named using theStateId
annotation; this name is unique to a ParDo in the graph and has no relation to other nodes in the graph. ADoFn
can declare multiple state variables.In Python DoFn declares states to be accessed by creating
StateSpec
class member variables representing each state. Each +In Python, DoFn declares states to be accessed by creating
+ +StateSpec
class member variables representing each state. EachStateSpec
is initialized with a name, this name is unique to a ParDo in the graph and has no relation to other nodes in the graph. ADoFn
can declare multiple state variables.++Note: The Beam SDK for Go does not yet support a State and Timer API. See BEAM-10660 to contribute.
+11.1. Types of state
Beam provides several types of state:
ValueState
@@ -9661,6 +9666,14 @@ accumulates the number of elements seen. | 'state pardo' >> beam.ParDo(ReadModifyWriteStateDoFn()))