class OdpsDatahub::XmlTemplate
Public Class Methods
getJobXml(name, comment, priority, taskStr, runMode)
click to toggle source
# File lib/fluent/plugin/odps/xml_template.rb, line 39 def self.getJobXml(name, comment, priority, taskStr, runMode) job_template=%{<?xml version="1.0" encoding="utf-8"?> <Instance> <Job> <Name>#{name}</Name> <Comment>#{comment}</Comment> <Priority>#{priority}</Priority> <Tasks> #{taskStr} </Tasks> <DAG> <RunMode>#{runMode}</RunMode> </DAG> </Job> </Instance>} return job_template end
getTaskXml(taskName, sqlString)
click to toggle source
# File lib/fluent/plugin/odps/xml_template.rb, line 23 def self.getTaskXml(taskName, sqlString) task_template=%{<SQL> <Name>#{taskName}</Name> <Comment/> <Config> <Property> <Name>settings</Name> <Value>{"odps.sql.udf.strict.mode": "true"}</Value> </Property> </Config> <Query><![CDATA[#{sqlString}]]></Query> </SQL> } return task_template end