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