Re: Specifying Schema dynamically

2017-02-13 Thread Luqman Ghani
an example code of what the functionality you have > in mind looks like? > That would help clarify if I have misunderstood and there’s actually a way > to do it. > > - Gordon > > On February 12, 2017 at 4:30:56 PM, Luqman Ghani (lgsa...@gmail.com) > wrote: > >

Specifying Schema dynamically

2017-02-12 Thread Luqman Ghani
Hi, I hope everyone is doing well. I have a use case where we infer schema according to file headers and other information. Now, in Flink, we can specify schema of a stream with case classes and tuples. With tuples, we cannot give names to fields, but we will have to generate case classes on the

Re: Submitting an app via API

2017-02-06 Thread Luqman Ghani
Hi, Thanks a lot. On Mon, Feb 6, 2017 at 9:06 PM, Ufuk Celebi wrote: > You can use RemoteStreamEnvironment or the REST APIs > (https://ci.apache.org/projects/flink/flink-docs- > release-1.3/monitoring/rest_api.html#submitting-programs). > > On Sun, Feb 5, 2017 at 4:43 PM, Luqm

Submitting an app via API

2017-02-05 Thread Luqman Ghani
Hi, On quickstart page of Flink docs, it suggests starting a Flink app with "bin/flink" command on command line. Is there any other way of submitting to a cluster of flink, that is, through API call within a program, or through server request? Thanks, Luqman