Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
MIME-Version: 1.0
In-Reply-To: 
 <CAELUF_CroSpmhk+UirSibxi=WF8ri=A6jeTsLR4TeiMHZXa6nw@mail.gmail.com>
References: 
 <CAELUF_CroSpmhk+UirSibxi=WF8ri=A6jeTsLR4TeiMHZXa6nw@mail.gmail.com>
Date: Fri, 8 May 2015 12:42:15 +0200
Message-ID: 
 <CAAdrtT0K5L_X7og=yqFfsYgtb9x9EWjb6uFq-5sOYdaJn4ZRWg@mail.gmail.com>
Subject: Re: Package multiple jobs in a single jar
From: Fabian Hueske <fhueske@gmail.com>
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=089e014939fc7c362105158faefa

--089e014939fc7c362105158faefa
Content-Type: text/plain; charset=UTF-8

You easily have multiple Flink programs in a single JAR file.
A program is defined using an ExecutionEnvironment and executed when you
call ExecutionEnvironment.exeucte().
Where and how you do that does not matter.

You can for example implement a main function such as:

public static void main(String... args) {

  if (today == Monday) {
    ExecutionEnvironment env = ...
    // define Monday prog
    env.execute()
  }
  else {
    ExecutionEnvironment env = ...
    // define other prog
    env.execute()
  }
}

2015-05-08 11:41 GMT+02:00 Flavio Pompermaier <pompermaier@okkam.it>:

> Hi to all,
> is there any way to keep multiple jobs in a jar and then choose at runtime
> the one to execute (like what ProgramDriver does in Hadoop)?
>
> Best,
> Flavio
>
>

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

<div dir=3D"ltr"><div><div><div><div><div><div><div><div><div><div>You easi=
ly have multiple Flink programs in a single JAR file.<br></div>A program is=
 defined using an ExecutionEnvironment and executed when you call Execution=
Environment.exeucte(). <br></div>Where and how you do that does not matter.=
<br><br></div>You can for example implement a main function such as:<br><br=
></div>public static void main(String... args) {<br><br></div>=C2=A0 if (to=
day =3D=3D Monday) {<br></div>=C2=A0=C2=A0=C2=A0 ExecutionEnvironment env =
=3D ...<br></div>=C2=A0=C2=A0=C2=A0 // define Monday prog<br></div>=C2=A0=
=C2=A0=C2=A0 env.execute()<br>=C2=A0 }<br></div>=C2=A0 else {<br></div>=C2=
=A0=C2=A0=C2=A0 ExecutionEnvironment env =3D ...<br>=C2=A0=C2=A0=C2=A0 // d=
efine other prog<br>=C2=A0=C2=A0=C2=A0 env.execute()<div>=C2=A0 }<br><div><=
div><div><div><div><div>}<br></div></div></div></div></div></div></div></di=
v><div class=3D"gmail_extra"><br><div class=3D"gmail_quote">2015-05-08 11:4=
1 GMT+02:00 Flavio Pompermaier <span dir=3D"ltr">&lt;<a href=3D"mailto:pomp=
ermaier@okkam.it" target=3D"_blank">pompermaier@okkam.it</a>&gt;</span>:<br=
><blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;border-left:1=
px #ccc solid;padding-left:1ex"><div dir=3D"ltr"><div><div><div>Hi to all,<=
br></div>is there any way to keep multiple jobs in a jar and then choose at=
 runtime the one to execute (like what ProgramDriver does in Hadoop)?<br><b=
r></div>Best,<br></div>Flavio<br><div><div><div><div><div dir=3D"ltr"><p></=
p><p></p><p></p><p></p></div>
</div></div></div></div></div>
</blockquote></div><br></div>

--089e014939fc7c362105158faefa--