Return-Path: 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 C30C917AA3 for ; Tue, 14 Apr 2015 06:10:49 +0000 (UTC) Received: (qmail 72867 invoked by uid 500); 14 Apr 2015 06:10:49 -0000 Delivered-To: apmail-flink-user-archive@flink.apache.org Received: (qmail 72801 invoked by uid 500); 14 Apr 2015 06:10:49 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@flink.apache.org Delivered-To: mailing list user@flink.apache.org Received: (qmail 72791 invoked by uid 99); 14 Apr 2015 06:10:49 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Apr 2015 06:10:49 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=RCVD_IN_DNSWL_LOW X-Spam-Check-By: apache.org Received-SPF: error (athena.apache.org: local policy) Received: from [212.27.42.1] (HELO smtp1-g21.free.fr) (212.27.42.1) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 14 Apr 2015 06:10:44 +0000 Received: from vaio-sb (unknown [85.179.174.139]) (Authenticated sender: benoit.hanotte) by smtp1-g21.free.fr (Postfix) with ESMTPSA id AE040940041 for ; Tue, 14 Apr 2015 08:07:59 +0200 (CEST) Content-Type: text/plain; charset=iso-8859-15; format=flowed; delsp=yes To: "user@flink.apache.org" Date: Tue, 14 Apr 2015 08:11:39 +0200 Subject: Nested Iterations supported in Flink? MIME-Version: 1.0 Content-Transfer-Encoding: Quoted-Printable From: =?iso-8859-15?Q?Beno=EEt_Hanotte?= Message-ID: User-Agent: Opera Mail/1.0 (Win32) X-Virus-Checked: Checked by ClamAV on apache.org Hello, I'm implementing an algorithm which requires nested iterations, and, fro= m = what I understood, this feature was not yet available in Flink [1], and = my = experiments with 2 nested bulk iterations seem to confirm that. However = I = came across a Flink unit test [2] using nested iterations, so I'm now a = = bit confused. Could you please give me some insight on what is supported= = or not in the current state of the project? Thanks! Beno=EEt. [1] = http://mail-archives.apache.org/mod_mbox/flink-user/201411.mbox/%3CCANC1= h_tpNFWwrnm14+Et1yBvkQPQ1-pfk=3DiUPP5Un90ZgUGeyg@mail.gmail.com%3E [2] = https://github.com/apache/flink/blob/master/flink-optimizer/src/test/jav= a/org/apache/flink/optimizer/NestedIterationsTest.java