Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
Subject: Re: Join two streams using a count-based window
To: user@flink.apache.org
References: <CAJ2UJ5faDzA-eCBYbPj9_1yNqQLw78EMzmQqTvR648nmECVv5A@mail.gmail.com>
From: "Matthias J. Sax" <mjsax@apache.org>
Message-ID: <575A936F.7060109@apache.org>
Date: Fri, 10 Jun 2016 12:16:15 +0200
MIME-Version: 1.0
In-Reply-To: <CAJ2UJ5faDzA-eCBYbPj9_1yNqQLw78EMzmQqTvR648nmECVv5A@mail.gmail.com>
Content-Type: multipart/signed; micalg=pgp-sha256;
 protocol="application/pgp-signature";
 boundary="E4G6UUuOtomXpb8kNlRnqOsJrtdduAEg2"
archived-at: Fri, 10 Jun 2016 10:19:03 -0000

This is an OpenPGP/MIME signed message (RFC 4880 and 3156)
--E4G6UUuOtomXpb8kNlRnqOsJrtdduAEg2
Content-Type: multipart/mixed; boundary="SKmjn7MmVx1ebXLdEHBSvgtq3PMUFbMvk"
From: "Matthias J. Sax" <mjsax@apache.org>
To: user@flink.apache.org
Message-ID: <575A936F.7060109@apache.org>
Subject: Re: Join two streams using a count-based window
References: <CAJ2UJ5faDzA-eCBYbPj9_1yNqQLw78EMzmQqTvR648nmECVv5A@mail.gmail.com>
In-Reply-To: <CAJ2UJ5faDzA-eCBYbPj9_1yNqQLw78EMzmQqTvR648nmECVv5A@mail.gmail.com>

--SKmjn7MmVx1ebXLdEHBSvgtq3PMUFbMvk
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: quoted-printable

I just put an answer to SO.

About the other questions: Flink processes tuple-by-tuple and does some
internal buffering. You might be interested in
https://cwiki.apache.org/confluence/display/FLINK/Data+exchange+between+t=
asks

-Matthias

On 06/09/2016 08:13 PM, Nikos R. Katsipoulakis wrote:
> Hello all,
>=20
> At first, I have a question posted on
> http://stackoverflow.com/questions/37732978/join-two-streams-using-a-co=
unt-based-window
> . I am re-posting this on the mailing list in case some of you are not
> on SO.
>=20
> In addition, I would like to know what is the difference between Flink
> and other Streaming engines on data-granularity transport and
> processing. To be more precise, I am aware that Storm sends tuples usin=
g
> Netty (by filling up queues) and a Bolt's logic is executed per tuple.
> Spark, employs micro-batches to simulate streaming and (I am not
> entirely certain) each task performs processing on a micro-batch. What
> about Flink? How are tuples transferred and processed. Any explanation
> and or article/blog-post/link is more than welcome.
>=20
> Thanks
>=20
> --=20
> Nikos R. Katsipoulakis,=20
> Department of Computer Science=20
> University of Pittsburgh


--SKmjn7MmVx1ebXLdEHBSvgtq3PMUFbMvk--

--E4G6UUuOtomXpb8kNlRnqOsJrtdduAEg2
Content-Type: application/pgp-signature; name="signature.asc"
Content-Description: OpenPGP digital signature
Content-Disposition: attachment; filename="signature.asc"

-----BEGIN PGP SIGNATURE-----
Version: GnuPG v2

iQIcBAEBCAAGBQJXWpN5AAoJEFCVK48prEZ4VOAQANidutHOMgrFzrBknu889mPI
+Z2wlRXjvESNRw1oTks2QRE/pi0pWcJBy8fcyINT12NPn2P/6DwcEqCxsoBDgM21
p+vN8bVv93hLOKWIEC6Inz01M2R7G/YlnXWXDJnS8ndRnbMJQgLI+/XDqSxGVNYA
HCxosOszSVa0+YWlFLqBjjjH6Gk3t0EIsPFXdQinCLR4+wUkcQVGnkF6t4ulpWt+
bebOGLwyB43dfq/NAAsHkDZYglB9pEl9iYCa8kt0SGC4wRUEOpJU/Ppxev3UE7gB
aiaulVLMX34eg3DU8Sa6jO3GK052xpuyvpyjAItb6NT8GpyKxgqNpcUijfyk/iKJ
ixHPaktq5Ydt4BKCX03gnurnKPxrZVQo2IOh5yw0ntdLsY0OAuHqgozORSbmanwg
mqh6ofXqZ7CQscfmPOcYObiflXY/mON7Y4eXyRKyvdZc+bFBIBDP/jUjlOlhDgB8
VjqZ4T959pFvXTrekB/zr8kORpRt4JIKELX6IzDZOSZAqhXDrnSf5nlOkJR1ak36
pg2Bi9+GbZGKmqsi4+GSOLrZG+WuzZWkIT8pUKvXVM+Ht+GfOjZPZiaYSSBDTg8H
GZBfivnk+vnm2ofXKiAJyB96lZpjfbhVlfec8At0o+RZVEEj3dwhjCcBw7c7dIpt
AreooAipdra9D8neg64X
=mE1l
-----END PGP SIGNATURE-----

--E4G6UUuOtomXpb8kNlRnqOsJrtdduAEg2--