Mailing-List: contact dev-help@flink.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@flink.incubator.apache.org
Received-SPF: pass (athena.apache.org: domain of reckoner42@gmail.com
 designates 209.85.128.173 as permitted sender)
MIME-Version: 1.0
Date: Wed, 9 Jul 2014 10:08:50 +0200
Message-ID: 
 <CAF6bXwU_KkPKh++ybE17ToAyOA3Yk-_JGF6uxvvvs5Nj5kX0Cg@mail.gmail.com>
Subject: Support user code as anonymous inner classes in streaming API
From: =?UTF-8?Q?Hermann_G=C3=A1bor?= <reckoner42@gmail.com>
To: dev@flink.incubator.apache.org
Content-Type: multipart/alternative; boundary=089e0160baf4f0ff1704fdbe37d2

--089e0160baf4f0ff1704fdbe37d2
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Hey,

We saw that the Flink API supports user code as anonymous classes, and we
would like to support it too. So far we've been using the default Java
serialization for serializing user codes and by default that cannot
serialize (non-static) inner classes. It seems to me that UserCodeWrapper
is the workaround for this, but I could not figure it how to wrap simply
the user code (e.g. a MapFunction) and use it for serialization. Can you
show us an example or give us some hints? Thanks for the help!

Regards,
G=C3=A1bor Hermann

--089e0160baf4f0ff1704fdbe37d2--