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