Mailing-List: contact dev-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.apache.org
MIME-Version: 1.0
From: =?UTF-8?Q?Gyula_F=C3=B3ra?= <gyfora@apache.org>
Date: Mon, 20 Feb 2017 13:53:57 +0000
Message-ID: <CA+faj9ytivbLtnC_tChi9_fGK4+q0aULLwv--ViX1YbMc7J5xQ@mail.gmail.com>
Subject: Question about Async IO
To: "dev@flink.apache.org" <dev@flink.apache.org>
Content-Type: multipart/alternative; boundary=001a11c17404ee17ef0548f6985f
archived-at: Mon, 20 Feb 2017 13:54:16 -0000

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

Hi,

I was looking at the AsyncFunction interface and try to wrap my head around
the implementation and the assumptions and I have some questions, maybe
somebody could help me out :)

What happens if the user does not collect any data or set a future to do so
in the invoke method?
Also what happens if I create more than one Future?

It seems that the "streamRecordBufferEntry"  logic assumes that there will
be a Future that eventually collects 1 thing or the user does this
directly.
Do I understand correctly? If not I am probably missing the part where the
buffer entry is removed immediately if no async request was made.

Thank you!
Gyula

--001a11c17404ee17ef0548f6985f--