Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id CC2A3200C4E for ; Fri, 21 Apr 2017 09:48:57 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id CAB64160BA2; Fri, 21 Apr 2017 07:48:57 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 1F6A0160B97 for ; Fri, 21 Apr 2017 09:48:56 +0200 (CEST) Received: (qmail 551 invoked by uid 500); 21 Apr 2017 07:48:56 -0000 Mailing-List: contact user-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Delivered-To: mailing list user@flink.apache.org Received: (qmail 540 invoked by uid 99); 21 Apr 2017 07:48:56 -0000 Received: from mail-relay.apache.org (HELO mail-relay.apache.org) (140.211.11.15) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 21 Apr 2017 07:48:56 +0000 Received: from mail-yw0-f173.google.com (mail-yw0-f173.google.com [209.85.161.173]) by mail-relay.apache.org (ASF Mail Server at mail-relay.apache.org) with ESMTPSA id D3F961A00C5 for ; Fri, 21 Apr 2017 07:48:55 +0000 (UTC) Received: by mail-yw0-f173.google.com with SMTP id j9so49352252ywj.3 for ; Fri, 21 Apr 2017 00:48:55 -0700 (PDT) X-Gm-Message-State: AN3rC/58G/R01jjoA3LdH2UbAbwJXls9bBoFrw1lixnndpWfX0pUqYBG w2FoQeLr3GglDLUj82difuG/NVgdJQ== X-Received: by 10.129.115.84 with SMTP id o81mr9791983ywc.205.1492760935176; Fri, 21 Apr 2017 00:48:55 -0700 (PDT) MIME-Version: 1.0 Received: by 10.129.106.66 with HTTP; Fri, 21 Apr 2017 00:48:14 -0700 (PDT) In-Reply-To: <06747662-5F52-4671-9E66-481346836AF5@kloudspot.com> References: <06747662-5F52-4671-9E66-481346836AF5@kloudspot.com> From: Till Rohrmann Date: Fri, 21 Apr 2017 09:48:14 +0200 X-Gmail-Original-Message-ID: Message-ID: Subject: Re: Using FlinkML from Java? To: Steve Jerman Cc: user Content-Type: multipart/alternative; boundary=001a1147e30246a406054da87d9a archived-at: Fri, 21 Apr 2017 07:48:58 -0000 --001a1147e30246a406054da87d9a Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: quoted-printable Hi Steve, unfortunately, FlinkML's pipeline mechanism depends on Scala's implicit value feature. Therefore, FlinkML can only be used with Scala if you don't want to construct the pipelines manually (which I wouldn't recommend). Cheers, Till On Thu, Apr 20, 2017 at 6:56 PM, Steve Jerman wrote: > Hi Folks, > > I=E2=80=99m trying to use FlinkML 1.2 from Java =E2=80=A6 getting this: > > SVM svm =3D new SVM() > .setBlocks(env.getParallelism()) > .setIterations(100) > .setRegularization(0.001) > .setStepsize(0.1) > .setSeed(42); > > > svm.fit(labelledTraining); > > The type org.apache.flink.api.scala.DataSet cannot be resolved. It is > indirectly referenced from required .class files. > > Are there any tricks required to get it running? Or is Java not supported= ? > > Steve > --001a1147e30246a406054da87d9a Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
Hi Steve,

unfortunately, FlinkML's = pipeline mechanism depends on Scala's implicit value feature. Therefore= , FlinkML can only be used with Scala if you don't want to construct th= e pipelines manually (which I wouldn't recommend).

=
Cheers,
Till

On Thu, Apr 20, 2017 at 6:56 PM, Steve Jerman <ste= ve@kloudspot.com> wrote:
Hi Folks,

I=E2=80=99m trying to use FlinkML 1.2 from Java =E2=80=A6 getting this= :

SVM svm =3D new SVM()
=C2=A0 .setBlocks(env.g= etParallelism())
=C2=A0 .setIterations(100)
=C2=A0 .setRegularization(0.001)
=C2=A0 .setStepsize(0.1)
=C2=A0 .setSeed(42);


svm.fit(labelledTra= ining);

The type org.apache.flink.api.scala.DataSet cannot be resolved. I= t is indirectly referenced from required .class files.

Are there any tricks required to get it running? Or is Java not suppor= ted?

Steve

--001a1147e30246a406054da87d9a--