Sha256: 7044267327c51668918b2590174d7796db85fad927e94358a3e4dce8abe4fc0f
Contents?: true
Size: 792 Bytes
Versions: 10
Compression:
Stored size: 792 Bytes
Contents
# -*- coding: utf-8 -*-
require 'tengine_job'
# [jobnet0013]
# start --- job1 --- [hadoop_job_run1] --- job2 --- end
#
# [hadoop_job_run1]
# start --- [hadoop_job1] --- [hadoop_job2] --- end
#
# [hadoop_job1]
# |--- map ------|
# start ---F J--- end
# |--- reduce ---|
#
# [hadoop_job2]
# |--- map ------|
# start ---F J--- end
# |--- reduce ---|
#
jobnet("jobnet0013", "ジョブネット0013", :vm_instance_name => "i-11111111", :credential_name => "goku-ssh-pk1") do
auto_sequence
job("job1", "ジョブ1", "import_hdfs.sh")
hadoop_job_run("hadoop_job_run1", "Hadoopジョブ1", "hadoop_job_run.sh") do
hadoop_job("hadoop_job1")
hadoop_job("hadoop_job2")
end
job("job2", "ジョブ2", "export_hdfs.sh")
end
Version data entries
10 entries across 5 versions & 1 rubygems