Hi Pawan,
@Fabian was right and I thought it was stream environment. Sorry for that.
What do you mean by `read the available records of my datasource`? How do
you implement the nextRecord() method in DASInputFormat?
Best,
Xingcan
On Wed, Mar 1, 2017 at 4:45 PM, Fabian Hueske <fhue...@gmail.com> wrote:
> Hi Pawan,
>
> in the DataSet API DataSet.print() will trigger the execution (you do not
> need to call ExecutionEnvironment.execute()).
> The DataSet will be printed on the standard out of the process that submits
> the program. This does only work for small DataSets.
> In general print() should only be used when developing jobs.
>
> You can also use DataSet.printOnTaskManager() which writes to the standard
> out of the TaskManager processes, usually to .out files in the ./log
> folder.
>
> Best, Fabian
>
> 2017-03-01 7:16 GMT+01:00 Pawan Manishka Gunarathna <
> pawan.manis...@gmail.com>:
>
> > Hi,
> >
> > So how can I read the available records of my datasource. I saw in some
> > examples that print() method will print the available data of that
> > datasource. ( like files )
> >
> > Thanks,
> > Pawan
> >
> >
> > On Wed, Mar 1, 2017 at 11:30 AM, Xingcan Cui <xingc...@gmail.com> wrote:
> >
> > > Hi Pawan,
> > >
> > > in Flink, most of the methods for DataSet (including print()) will just
> > add
> > > operators to the plan but not really run it. If the DASInputFormat has
> no
> > > error, you can run the plan by calling environment.execute().
> > >
> > > Best,
> > > Xingcan
> > >
> > > On Wed, Mar 1, 2017 at 12:17 PM, Pawan Manishka Gunarathna <
> > > pawan.manis...@gmail.com> wrote:
> > >
> > > > Hi,
> > > >
> > > > I have implemented a Flink InputFormat interface related to my
> > > datasource.
> > > > It have our own data type as *Record*. So my class seems as follows,
> > > >
> > > > public class DASInputFormat implements InputFormat<Record,
> > DASInputSplit>
> > > {
> > > > }
> > > >
> > > > So when I executed the print() method, my console shows the Flink
> > > > execution,
> > > > but nothing will print. So how can I read/print available records in
> > > > my datasource
> > > > table.
> > > >
> > > > ------------------------------------------------------------
> > > > -----------------------
> > > >
> > > > ExecutionEnvironment environment =
> > > > ExecutionEnvironment.getExecutionEnvironment();
> > > > DASInputFormat dasInputFormat = new DASInputFormat(1,
> "SAMPLETABLE1",2,
> > > > null,
> > > > Long.MIN_VALUE, Long.MAX_VALUE,0, -1);
> > > > DataSet<Record> dasRecords = environment.createInput(
> dasInputFormat);
> > > > dasRecords.print();
> > > >
> > > > Thanks,
> > > > Pawan
> > > > --
> > > >
> > > > *Pawan Gunaratne*
> > > > *Mob: +94 770373556*
> > > >
> > >
> >
> >
> >
> > --
> >
> > *Pawan Gunaratne*
> > *Mob: +94 770373556*
> >
>
