Return-Path: 
 <user-return-4062-apmail-flink-user-archive=flink.apache.org@flink.apache.org>
X-Original-To: apmail-flink-user-archive@minotaur.apache.org
Delivered-To: apmail-flink-user-archive@minotaur.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 0C31D1823C
	for <apmail-flink-user-archive@minotaur.apache.org>;
 Tue, 22 Dec 2015 14:16:50 +0000 (UTC)
Received: (qmail 23028 invoked by uid 500); 22 Dec 2015 14:16:34 -0000
Delivered-To: apmail-flink-user-archive@flink.apache.org
Received: (qmail 22940 invoked by uid 500); 22 Dec 2015 14:16:33 -0000
Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:user-help@flink.apache.org>
List-Unsubscribe: <mailto:user-unsubscribe@flink.apache.org>
List-Post: <mailto:user@flink.apache.org>
List-Id: <user.flink.apache.org>
Reply-To: user@flink.apache.org
Delivered-To: mailing list user@flink.apache.org
Received: (qmail 22930 invoked by uid 99); 22 Dec 2015 14:16:33 -0000
Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 22 Dec 2015 14:16:33 +0000
Received: from localhost (localhost [127.0.0.1])
	by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org)
 with ESMTP id 84A30C06B9
	for <user@flink.apache.org>; Tue, 22 Dec 2015 14:16:33 +0000 (UTC)
X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org
X-Spam-Flag: NO
X-Spam-Score: 2.879
X-Spam-Level: **
X-Spam-Status: No, score=2.879 tagged_above=-999 required=6.31
	tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, DKIM_VALID_AU=-0.1,
	HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01,
	SPF_PASS=-0.001] autolearn=disabled
Authentication-Results: spamd4-us-west.apache.org (amavisd-new);
	dkim=pass (2048-bit key) header.d=gmail.com
Received: from mx1-us-east.apache.org ([10.40.0.8])
	by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new,
 port 10024)
	with ESMTP id pV3zz8e21wqI for <user@flink.apache.org>;
	Tue, 22 Dec 2015 14:16:33 +0000 (UTC)
Received: from mail-wm0-f43.google.com (mail-wm0-f43.google.com
 [74.125.82.43])
	by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with
 ESMTPS id 97B2D439AD
	for <user@flink.apache.org>; Tue, 22 Dec 2015 14:16:32 +0000 (UTC)
Received: by mail-wm0-f43.google.com with SMTP id p187so110785611wmp.1
        for <user@flink.apache.org>; Tue, 22 Dec 2015 06:16:32 -0800 (PST)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=20120113;
        h=mime-version:from:date:message-id:subject:to:content-type;
        bh=qX/ii0zLbzt0K2PznZyVKt+Xpvjl54kgPMIX9BV3V5Q=;
        b=pYPAC2d3rf7yG1w0r2HX8AF3QdojrvcFa1cHXAeCXEgwb0JkxSK8JWe3OUA27wnNf/
         U7IFZYNPXSWTv+zMlzsYrSj8DQ7xNO/g+7Co4Uf9z3xPf3aI7ZCBcmubLjYbhW3NT3+V
         CjQX4QBHCCEi/PrOIajac6TxiE4VsYtU01QoradRYzatniCJC7uy022ta52HX1yHcNhh
         pHLSpxm5VA8YRxGUwUeRKCAogs+/CMQIGmb/Ifj3BBEwyoeGaCrmy3SeGuP3wJ5d880Y
         QetCYMhzzDHUcVT0M6uTJ9wkWXClewy/jJVZ/muYQjKVnojq2uyFz0B1jIfS4fd01cFj
         pKzw==
X-Received: by 10.28.140.201 with SMTP id o192mr29349626wmd.88.1450793791773;
 Tue, 22 Dec 2015 06:16:31 -0800 (PST)
MIME-Version: 1.0
From: Don Frascuchon <frascuchon@gmail.com>
Date: Tue, 22 Dec 2015 14:16:21 +0000
Message-ID: 
 <CAOJWaGXbQd_L0U7r0rDmbTvjGgkWvX+3Cryx8BZEqbDZJHJGnQ@mail.gmail.com>
Subject: Scala API and sources with timestamp
To: "user@flink.apache.org" <user@flink.apache.org>
Content-Type: multipart/alternative; boundary=001a11497bd899e1fa05277d4019

--001a11497bd899e1fa05277d4019
Content-Type: text/plain; charset=UTF-8

Hello,

There is a way for define  a EventTimeSourceFunction with anonymous
functions from the scala api?  Like that:

 env.addSource[Int] {
  ctx => {

  ...

ctx.collectWithTimestamp(i, System.currentTimeMillis())
...

  }

}

Thanks in advance!

--001a11497bd899e1fa05277d4019
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Hello,<div><br></div><div>There is a way for define =C2=A0=
a EventTimeSourceFunction with anonymous functions from the scala api?=C2=
=A0 Like that:</div><div><br></div><div><pre style=3D"font-family:Menlo;col=
or:rgb(169,183,198);background-color:rgb(43,43,43)"> env.addSource[<span st=
yle=3D"color:#cc7832">Int</span>] {<br>  ctx =3D&gt; { <br><pre style=3D"fo=
nt-family:Menlo">  ...  </pre> ctx.collectWithTimestamp(i<span style=3D"col=
or:rgb(204,120,50)">, </span>System.<span style=3D"font-style:italic">curre=
ntTimeMillis</span>())<br>  ...  <br><pre style=3D"font-family:Menlo">  }  =
</pre>}</pre></div><div>Thanks in advance!=C2=A0<br></div></div>

--001a11497bd899e1fa05277d4019--