flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Extracting Timestamp in MapFunction
Date Mon, 30 May 2016 08:47:08 GMT
Hi,
right now the only way of getting at the timestamps is writing a custom
operator and using that with DataStream.transform(). Take a look at
StreamMap, which is the operator implementation that executes MapFunctions.

I think the links in the doc should point to
https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/event_time.html
 and
https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/event_timestamps_watermarks.html.
I'll fix the documentation link.

Cheers,
Aljoscha

On Mon, 30 May 2016 at 00:47 Biplob Biswas <revolutionisme@gmail.com> wrote:

> Hi,
>
> I have a source where I am using the collectWithTimestamp method and
> streaming the timestamp along with the actual data.
>
> Now I want to get the values of the timestamp in the map function, I tried
> looking for that in the documentation in the following link and the
> ExtractTimestamp method interested me, although I didnt understand the
> working as to how can i use that for my purpose.
>
>
> https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/streaming/index.html
>
> Also the hyperlink "Working with time" is broken, so couldn't read anything
> about timestamps from there as well.
>
> Any help is much appreciated.
>
> Thanks a lot.
> Biplob Biswas
>
>
>
>
>
> --
> View this message in context:
> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Extracting-Timestamp-in-MapFunction-tp7240.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>

Mime
View raw message