[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[
https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541809&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541809
]
ASF GitHub Bot logged work on BEAM-10112:
-
Author: ASF GitHub Bot
Created on: 26/Jan/21 04:21
Start Date: 26/Jan/21 04:21
Worklog Time Spent: 10m
Work Description: y1chi commented on a change in pull request #13591:
URL: https://github.com/apache/beam/pull/13591#discussion_r564050935
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4519,6 +4519,8 @@ registered, then Beam will automatically infer the coder
for the state value. Ot
specified when creating the ValueState. For example, the following ParDo
creates a single state variable that
accumulates the number of elements seen.
+Note: ValueState is called ReadModifyWriteState in Python SDK.
Review comment:
Done.
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
Review comment:
Done.
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4544,6 +4546,19 @@ perUser.apply(ParDo.of(new DoFn,
OutputT>() {
}));
{{< /highlight >}}
+{{< highlight python >}}
Review comment:
Done.
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
in a `DoFn` and allowing for the timer tags to be dynamically chosen - e.g.
based on data in the input elements. A
timer with a specific tag can only be set to a single timestamp, so setting
the timer again has the effect of
overwriting the previous expiration time for the timer with that tag. Each
`TimerMap` is identified with a timer family
id, and timers in different timer families are independent.
+In Python SDK, a dynamic timer tag can be specified while calling timer.set()
or timer.clear(), by default the timer
Review comment:
Done.
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
in a `DoFn` and allowing for the timer tags to be dynamically chosen - e.g.
based on data in the input elements. A
timer with a specific tag can only be set to a single timestamp, so setting
the timer again has the effect of
overwriting the previous expiration time for the timer with that tag. Each
`TimerMap` is identified with a timer family
id, and timers in different timer families are independent.
+In Python SDK, a dynamic timer tag can be specified while calling timer.set()
or timer.clear(), by default the timer
Review comment:
Done.
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
in a `DoFn` and allowing for the timer tags to be dynamically chosen - e.g.
based on data in the input elements. A
timer with a specific tag can only be set to a single timestamp, so setting
the timer again has the effect of
overwriting the previous expiration time for the timer with that tag. Each
`TimerMap` is identified with a timer family
id, and timers in different timer families are independent.
+In Python SDK, a dynamic timer tag can be specified while calling timer.set()
or timer.clear(), by default the timer
Review comment:
Done.
This is an automated message from the Apache Git Ser
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541715&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541715 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 26/Jan/21 04:12 Start Date: 26/Jan/21 04:12 Worklog Time Spent: 10m Work Description: boyuanzz commented on pull request #13591: URL: https://github.com/apache/beam/pull/13591#issuecomment-767201493 Thanks! I'm going to merge this PR. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 541715) Time Spent: 3.5h (was: 3h 20m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 3.5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541700&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541700 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 26/Jan/21 04:11 Start Date: 26/Jan/21 04:11 Worklog Time Spent: 10m Work Description: y1chi commented on pull request #13591: URL: https://github.com/apache/beam/pull/13591#issuecomment-767129849 @rosetn thanks for reviewing, I've addressed the comments, PTAL. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 541700) Time Spent: 3h 20m (was: 3h 10m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 3h 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541694&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541694 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 26/Jan/21 04:10 Start Date: 26/Jan/21 04:10 Worklog Time Spent: 10m Work Description: boyuanzz merged pull request #13591: URL: https://github.com/apache/beam/pull/13591 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 541694) Time Spent: 3h 10m (was: 3h) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 3h 10m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541400&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541400 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 26/Jan/21 00:32 Start Date: 26/Jan/21 00:32 Worklog Time Spent: 10m Work Description: boyuanzz commented on pull request #13591: URL: https://github.com/apache/beam/pull/13591#issuecomment-767201493 Thanks! I'm going to merge this PR. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 541400) Time Spent: 2h 50m (was: 2h 40m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 2h 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541401&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541401 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 26/Jan/21 00:32 Start Date: 26/Jan/21 00:32 Worklog Time Spent: 10m Work Description: boyuanzz merged pull request #13591: URL: https://github.com/apache/beam/pull/13591 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 541401) Time Spent: 3h (was: 2h 50m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 3h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541311&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541311 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 25/Jan/21 21:39 Start Date: 25/Jan/21 21:39 Worklog Time Spent: 10m Work Description: y1chi commented on pull request #13591: URL: https://github.com/apache/beam/pull/13591#issuecomment-767129849 @rosetn thanks for reviewing, I've addressed the comments, PTAL. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 541311) Time Spent: 2h 40m (was: 2.5h) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 2h 40m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[
https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541307&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541307
]
ASF GitHub Bot logged work on BEAM-10112:
-
Author: ASF GitHub Bot
Created on: 25/Jan/21 21:26
Start Date: 25/Jan/21 21:26
Worklog Time Spent: 10m
Work Description: y1chi commented on a change in pull request #13591:
URL: https://github.com/apache/beam/pull/13591#discussion_r564054227
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
in a `DoFn` and allowing for the timer tags to be dynamically chosen - e.g.
based on data in the input elements. A
timer with a specific tag can only be set to a single timestamp, so setting
the timer again has the effect of
overwriting the previous expiration time for the timer with that tag. Each
`TimerMap` is identified with a timer family
id, and timers in different timer families are independent.
+In Python SDK, a dynamic timer tag can be specified while calling timer.set()
or timer.clear(), by default the timer
Review comment:
Done.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
---
Worklog Id: (was: 541307)
Time Spent: 2.5h (was: 2h 20m)
> Add python sdk state and timer examples to website
> --
>
> Key: BEAM-10112
> URL: https://issues.apache.org/jira/browse/BEAM-10112
> Project: Beam
> Issue Type: Improvement
> Components: website
>Reporter: Yichi Zhang
>Assignee: Yichi Zhang
>Priority: P3
> Time Spent: 2.5h
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[
https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541306&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541306
]
ASF GitHub Bot logged work on BEAM-10112:
-
Author: ASF GitHub Bot
Created on: 25/Jan/21 21:25
Start Date: 25/Jan/21 21:25
Worklog Time Spent: 10m
Work Description: y1chi commented on a change in pull request #13591:
URL: https://github.com/apache/beam/pull/13591#discussion_r564053596
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
Review comment:
Done.
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4544,6 +4546,19 @@ perUser.apply(ParDo.of(new DoFn,
OutputT>() {
}));
{{< /highlight >}}
+{{< highlight python >}}
Review comment:
Done.
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
in a `DoFn` and allowing for the timer tags to be dynamically chosen - e.g.
based on data in the input elements. A
timer with a specific tag can only be set to a single timestamp, so setting
the timer again has the effect of
overwriting the previous expiration time for the timer with that tag. Each
`TimerMap` is identified with a timer family
id, and timers in different timer families are independent.
+In Python SDK, a dynamic timer tag can be specified while calling timer.set()
or timer.clear(), by default the timer
Review comment:
Done.
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
in a `DoFn` and allowing for the timer tags to be dynamically chosen - e.g.
based on data in the input elements. A
timer with a specific tag can only be set to a single timestamp, so setting
the timer again has the effect of
overwriting the previous expiration time for the timer with that tag. Each
`TimerMap` is identified with a timer family
id, and timers in different timer families are independent.
+In Python SDK, a dynamic timer tag can be specified while calling timer.set()
or timer.clear(), by default the timer
Review comment:
Done.
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
Issue Time Tracking
---
Worklog Id: (was: 541306)
Time Spent: 2h 20m (was: 2h 10m)
> Add python sdk state and timer examples to website
> --
>
> Key: BEAM-10112
> URL: https://issues.apache.org/jira/browse/BEAM-10112
> Project: Beam
> Issue Type: Improvement
> Components: website
>Reporter: Yichi Zhang
>Assignee: Yichi Zhang
>Priority: P3
> Time Spent: 2h 20m
> Remaining Estimate: 0h
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=541302&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-541302 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 25/Jan/21 21:20 Start Date: 25/Jan/21 21:20 Worklog Time Spent: 10m Work Description: y1chi commented on a change in pull request #13591: URL: https://github.com/apache/beam/pull/13591#discussion_r564050935 ## File path: website/www/site/content/en/documentation/programming-guide.md ## @@ -4519,6 +4519,8 @@ registered, then Beam will automatically infer the coder for the state value. Ot specified when creating the ValueState. For example, the following ParDo creates a single state variable that accumulates the number of elements seen. +Note: ValueState is called ReadModifyWriteState in Python SDK. Review comment: Done. This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 541302) Time Spent: 2h 10m (was: 2h) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 2h 10m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[
https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=538191&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-538191
]
ASF GitHub Bot logged work on BEAM-10112:
-
Author: ASF GitHub Bot
Created on: 20/Jan/21 02:56
Start Date: 20/Jan/21 02:56
Worklog Time Spent: 10m
Work Description: rosetn commented on a change in pull request #13591:
URL: https://github.com/apache/beam/pull/13591#discussion_r560639210
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4544,6 +4546,19 @@ perUser.apply(ParDo.of(new DoFn,
OutputT>() {
}));
{{< /highlight >}}
+{{< highlight python >}}
Review comment:
This Python section does not show up when I have Python selected.
http://apache-beam-website-pull-requests.storage.googleapis.com/13591/documentation/programming-guide/index.html#state-and-timers
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
Review comment:
"in the Java SDK."
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
in a `DoFn` and allowing for the timer tags to be dynamically chosen - e.g.
based on data in the input elements. A
timer with a specific tag can only be set to a single timestamp, so setting
the timer again has the effect of
overwriting the previous expiration time for the timer with that tag. Each
`TimerMap` is identified with a timer family
id, and timers in different timer families are independent.
+In Python SDK, a dynamic timer tag can be specified while calling timer.set()
or timer.clear(), by default the timer
Review comment:
I think these are two sentences? "... or `clear()`. By default, the
timer..."
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
in a `DoFn` and allowing for the timer tags to be dynamically chosen - e.g.
based on data in the input elements. A
timer with a specific tag can only be set to a single timestamp, so setting
the timer again has the effect of
overwriting the previous expiration time for the timer with that tag. Each
`TimerMap` is identified with a timer family
id, and timers in different timer families are independent.
+In Python SDK, a dynamic timer tag can be specified while calling timer.set()
or timer.clear(), by default the timer
Review comment:
`set()` and `clear()`
Unless you think it's too ambiguous without the class name. If that's the
case, then add these in code font.
##
File path: website/www/site/content/en/documentation/programming-guide.md
##
@@ -4775,12 +4795,15 @@ _ = (p | 'Read per user' >> ReadPerUser()
11.3.3. Dynamic timer tags {#dynamic-timer-tags}
-Beam also supports dynamically setting a timer tag using `TimerMap`. This
allows for setting multiple different timers
+Beam also supports dynamically setting a timer tag using `TimerMap` in Java
SDK. This allows for setting multiple different timers
in a `DoFn` and allowing for the timer tags to be dynamically chosen - e.g.
based on data in the input elements. A
timer with a specific tag can only be set to a single timestamp, so setting
the timer again has the effect of
overwriting the previous expiration time for the timer with that tag. Each
`TimerMap` is identified with a timer family
id, and timers in different timer families are independent.
+In Python SDK, a dynamic timer tag can be specified while calling timer.set()
or timer.clear(), by default the timer
Review comment:
"In the Python SDK"
This is an automated message from the Apache Git Service.
To respond to
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=538189&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-538189 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 20/Jan/21 02:46 Start Date: 20/Jan/21 02:46 Worklog Time Spent: 10m Work Description: rosetn commented on a change in pull request #13591: URL: https://github.com/apache/beam/pull/13591#discussion_r560637848 ## File path: website/www/site/content/en/documentation/programming-guide.md ## @@ -4519,6 +4519,8 @@ registered, then Beam will automatically infer the coder for the state value. Ot specified when creating the ValueState. For example, the following ParDo creates a single state variable that accumulates the number of elements seen. +Note: ValueState is called ReadModifyWriteState in Python SDK. Review comment: Code font `ValueState` and `ReadModifyWriteState` This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 538189) Time Spent: 1h 50m (was: 1h 40m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 1h 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=538119&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-538119 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 19/Jan/21 22:54 Start Date: 19/Jan/21 22:54 Worklog Time Spent: 10m Work Description: rosetn commented on pull request #13591: URL: https://github.com/apache/beam/pull/13591#issuecomment-763195249 Run Website_Stage_GCS PreCommit This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 538119) Time Spent: 1h 40m (was: 1.5h) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 1h 40m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=531412&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-531412 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 05/Jan/21 18:49 Start Date: 05/Jan/21 18:49 Worklog Time Spent: 10m Work Description: y1chi commented on pull request #13591: URL: https://github.com/apache/beam/pull/13591#issuecomment-754828318 @rosetn friendly ping for review This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 531412) Time Spent: 1.5h (was: 1h 20m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 1.5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=527355&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-527355 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 22/Dec/20 20:39 Start Date: 22/Dec/20 20:39 Worklog Time Spent: 10m Work Description: boyuanzz commented on pull request #13591: URL: https://github.com/apache/beam/pull/13591#issuecomment-749764956 r: @rosetn This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 527355) Time Spent: 1h 20m (was: 1h 10m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 1h 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=527354&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-527354 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 22/Dec/20 20:31 Start Date: 22/Dec/20 20:31 Worklog Time Spent: 10m Work Description: y1chi commented on pull request #13591: URL: https://github.com/apache/beam/pull/13591#issuecomment-749761923 R: @boyuanzz This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 527354) Time Spent: 1h 10m (was: 1h) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 1h 10m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=527001&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-527001 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 21/Dec/20 22:57 Start Date: 21/Dec/20 22:57 Worklog Time Spent: 10m Work Description: y1chi commented on pull request #13591: URL: https://github.com/apache/beam/pull/13591#issuecomment-749242909 R: @angoenka This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 527001) Time Spent: 1h (was: 50m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P3 > Time Spent: 1h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=527000&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-527000 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 21/Dec/20 22:55 Start Date: 21/Dec/20 22:55 Worklog Time Spent: 10m Work Description: y1chi opened a new pull request #13591: URL: https://github.com/apache/beam/pull/13591 **Please** add a meaningful description for your change here Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] [**Choose reviewer(s)**](https://beam.apache.org/contribute/#make-your-change) and mention them in a comment (`R: @username`). - [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue. - [ ] Update `CHANGES.md` with noteworthy changes. - [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf). See the [Contributor Guide](https://beam.apache.org/contribute) for more tips on [how to make review process smoother](https://beam.apache.org/contribute/#make-reviewers-job-easier). Post-Commit Tests Status (on master branch) Lang | SDK | Dataflow | Flink | Samza | Spark | Twister2 --- | --- | --- | --- | --- | --- | --- Go | [](https://ci-beam.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/) | --- | [](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/) | --- | [](https://ci-beam.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/) | --- Java | [](https://ci-beam.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/) | [](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/)[](https://ci-beam.apache.org/job/beam_PostCommit_Java_VR_Dataflow_V2/lastCompletedBuild/)[](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/) | [](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/)[](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Java11/lastCompletedBuild/)[](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/)[](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/) | [](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/) | [](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/)[](https://ci-beam.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/)[](https://ci-beam.apache.org/job/beam_PostCommit_Java_ValidatesRunner_SparkStructuredStreaming/lastCompletedBuild/) | [!
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=441957&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-441957 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 05/Jun/20 18:06 Start Date: 05/Jun/20 18:06 Worklog Time Spent: 10m Work Description: aaltay merged pull request #11882: URL: https://github.com/apache/beam/pull/11882 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 441957) Time Spent: 40m (was: 0.5h) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P2 > Time Spent: 40m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=441654&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-441654 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 05/Jun/20 03:10 Start Date: 05/Jun/20 03:10 Worklog Time Spent: 10m Work Description: aaltay commented on pull request #11882: URL: https://github.com/apache/beam/pull/11882#issuecomment-639231673 retest this please This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 441654) Time Spent: 0.5h (was: 20m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P2 > Time Spent: 0.5h > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=439720&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-439720 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 01/Jun/20 20:36 Start Date: 01/Jun/20 20:36 Worklog Time Spent: 10m Work Description: y1chi commented on pull request #11882: URL: https://github.com/apache/beam/pull/11882#issuecomment-637088326 R: @angoenka This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org Issue Time Tracking --- Worklog Id: (was: 439720) Time Spent: 20m (was: 10m) > Add python sdk state and timer examples to website > -- > > Key: BEAM-10112 > URL: https://issues.apache.org/jira/browse/BEAM-10112 > Project: Beam > Issue Type: Improvement > Components: website >Reporter: Yichi Zhang >Assignee: Yichi Zhang >Priority: P2 > Time Spent: 20m > Remaining Estimate: 0h > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Work logged] (BEAM-10112) Add python sdk state and timer examples to website
[ https://issues.apache.org/jira/browse/BEAM-10112?focusedWorklogId=439719&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-439719 ] ASF GitHub Bot logged work on BEAM-10112: - Author: ASF GitHub Bot Created on: 01/Jun/20 20:35 Start Date: 01/Jun/20 20:35 Worklog Time Spent: 10m Work Description: y1chi opened a new pull request #11882: URL: https://github.com/apache/beam/pull/11882 **Please** add a meaningful description for your change here Thank you for your contribution! Follow this checklist to help us incorporate your contribution quickly and easily: - [ ] [**Choose reviewer(s)**](https://beam.apache.org/contribute/#make-your-change) and mention them in a comment (`R: @username`). - [ ] Format the pull request title like `[BEAM-XXX] Fixes bug in ApproximateQuantiles`, where you replace `BEAM-XXX` with the appropriate JIRA issue, if applicable. This will automatically link the pull request to the issue. - [ ] Update `CHANGES.md` with noteworthy changes. - [ ] If this contribution is large, please file an Apache [Individual Contributor License Agreement](https://www.apache.org/licenses/icla.pdf). See the [Contributor Guide](https://beam.apache.org/contribute) for more tips on [how to make review process smoother](https://beam.apache.org/contribute/#make-reviewers-job-easier). Post-Commit Tests Status (on master branch) Lang | SDK | Apex | Dataflow | Flink | Gearpump | Samza | Spark --- | --- | --- | --- | --- | --- | --- | --- Go | [](https://builds.apache.org/job/beam_PostCommit_Go/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Flink/lastCompletedBuild/) | --- | --- | [](https://builds.apache.org/job/beam_PostCommit_Go_VR_Spark/lastCompletedBuild/) Java | [](https://builds.apache.org/job/beam_PostCommit_Java/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Apex/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Dataflow_Java11/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Flink_Java11/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Batch/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Flink_Streaming/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Gearpump/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Samza/lastCompletedBuild/) | [](https://builds.apache.org/job/beam_PostCommit_Java_ValidatesRunner_Spark/lastCompletedBuild/)[](https://builds.apache.org/job/beam_PostCommit_Java_PVR_Spark_Batch/lastCompletedBuild/)[