Re: EventTimeSourceFunction class

[Stephan Ewen <se...@apache.org>]

Hi!

In Flink 1.0.0, all functions can act as EventTimeSourceFunctions - all
functions can call "emitWithTimestamp(value, timestamp)" on the source
context.

You can also get timestamps onto values via a Timestamp Assigner.

Have a look here:
https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming/event_timestamps_watermarks.html

Greetings,
Stephan


On Mon, Mar 7, 2016 at 7:09 PM, Madhire, Naveen <
Naveen.Madhire@capitalone.com> wrote:

> Hi,
>
> The EventTimeSourceFunction class is not present in 1.0.0 version, it was
> in 0.10.2
>
>
> https://github.com/apache/flink/blob/release-0.10.2-rc2/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/EventTimeSourceFunction.java
>
> I am trying to generate a stream from input file based on the event
> timestamp. Can you please tell me which class should I use in 1.0.0 version?
>
>
> Thanks,
> Naveen
>
> ------------------------------
>
> The information contained in this e-mail is confidential and/or
> proprietary to Capital One and/or its affiliates and may only be used
> solely in performance of work or services for Capital One. The information
> transmitted herewith is intended only for use by the individual or entity
> to which it is addressed. If the reader of this message is not the intended
> recipient, you are hereby notified that any review, retransmission,
> dissemination, distribution, copying or other use of, or taking of any
> action in reliance upon this information is strictly prohibited. If you
> have received this communication in error, please contact the sender and
> delete the material from your computer.
>