Re: Extracting Timestamp in MapFunction

Posted by Aljoscha Krettek on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Extracting-Timestamp-in-MapFunction-tp7240p7249.html

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 <[hidden email]> 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.