Skip to main content

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;