Hi Vinod, For Pojo, you need to define a class having all of your fields (which will be populated by data retrieved from jdbc table). In this class you also need to define getter/setter for each field. When you use JdbcPOJOInputOperator, provide the fully classified class name as input to this operator (using properties file). You can check example for reading jdbc and loading it to hdfs using JdbcPOJOInputOperator at : https://github.com/DataTorrent/examples/tree/master/tutorials/jdbcIngest
-Priyanka On Wed, Oct 26, 2016 at 10:26 AM, Bhupesh Chawda <[email protected]> wrote: > Hi Vinod, > > Please have a look at the JdbcPOJOInputOperator > <https://github.com/apache/apex-malhar/blob/master/ > library/src/main/java/com/datatorrent/lib/db/jdbc/ > JdbcPOJOInputOperator.java> > which emits POJO records on the output port. > > ~ Bhupesh > > On Wed, Oct 26, 2016 at 6:51 AM, vinod sugur <[email protected]> > wrote: > > > Hi, > > > > I am new to Apache Apex. I have developed a code by looking at > > JDBCInputOperator to move data from relational database to Hadoop. There > is > > no transformation on data, it is just extract and load use case. I need > to > > implement this approach to all tables that are part of relational schema. > > > > Question: > > How do I create Pojo dynamically? or Is there a operator which given an > > input will generate getter and setter based on the field list. > > > > Regards, > > Vinod Sugur > > > > > > > > > > -- > > View this message in context: http://apache-apex-developers- > > list.78491.x6.nabble.com/data-pull-from-JDBC-tp11008.html > > Sent from the Apache Apex Developers list mailing list archive at > > Nabble.com. > > >
