[
https://issues.apache.org/jira/browse/BEAM-6695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16794340#comment-16794340
]
Tanay Tummalapalli edited comment on BEAM-6695 at 3/16/19 8:54 PM:
-------------------------------------------------------------------
How do I get the event time of an element in a CombineFn's add_input method?
Eg:
I've got:
{code:python}
class Latest(core.CombineFn):
def add_input(self, accumulator, element)
# I need to access the event time of element
# element.timestamp?
{code}
Also, what is the type of `element`?
was (Author: ttanay):
How do I get the event time of an element in a CombineFn's add_input method?
Eg:
I've got:
```
class Latest(core.CombineFn):
def add_input(self, accumulator, element)
# I need to access the event time of element
# element.timestamp?
```
Also, what is the type of `element`?
> Latest transform for Python SDK
> -------------------------------
>
> Key: BEAM-6695
> URL: https://issues.apache.org/jira/browse/BEAM-6695
> Project: Beam
> Issue Type: New Feature
> Components: sdk-py-core
> Reporter: Ahmet Altay
> Assignee: Tanay Tummalapalli
> Priority: Minor
>
> Add a PTransform} and Combine.CombineFn for computing the latest element in a
> PCollection.
> It should offer the same API as its Java counterpart:
> https://github.com/apache/beam/blob/11a977b8b26eff2274d706541127c19dc93131a2/sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/Latest.java
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
