TQL application
Create the following TQL application, substituting the appropriate connection URL and table name:
CREATE SOURCE OracleCDCSource USING OracleReader ( StartTimestamp:'07-OCT-2015 18:37:55', Username:'qatest', Password:'qatest', ConnectionURL:'192.0.2.0:1521:orcl', Tables:'QATEST.POSAUTHORIZATIONS', OnlineCatalog:true, FetchSize:1, Compression:true ) OUTPUT TO DataStream; CREATE TARGET HiveTarget USING HDFSWriter( filename:'ora_hive_pos.bin', hadoopurl:'hdfs://localhost:9000/output/’, ) FORMAT USING AvroFormatter ( schemaFileName: ’ora_hive_pos.avsc' ) INPUT FROM DataStream;