title: oracle to oracle data pipeline using apache nifi
body: <p>in our project we load data from one database(oracle) to another database(oracle) and run some batch level analytics to it. </p>
  
  <p>as of now it is done via pl/sql jobs where we are pulling 3 years of data into destination db..</p>
  
  <p>i have got a task to automate the flow using APache nifi..</p>
  
  <p>cluster info:
  1. APache hadoop cluster of 5 nodes 
  2. all the softwares are open source being used.</p>
  
  <p>i have tried creating a flow where i am using a processor queryDatabaseTable -> putDatabaseRecord. but as far as i know that queryDatabaseTable outputs avro format..</p>
  
  <p>i request to suggest me how to convert and what should be the processors sequence also i need to handle incremental loads/Change data capture. kindly suggest.
  thanks in advance :)</p>