Skip to content

Commit

Permalink
修改源码本地权限为777
Browse files Browse the repository at this point in the history
  • Loading branch information
chinan.hjc committed Feb 4, 2015
1 parent cfa0aa3 commit 2bdc595
Show file tree
Hide file tree
Showing 674 changed files with 174 additions and 2 deletions.
Empty file modified README
100644 → 100755
Empty file.
Empty file modified common/pom.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified common/src/main/java/com/alibaba/datax/common/spi/Hook.java
100644 → 100755
Empty file.
Empty file modified common/src/main/java/com/alibaba/datax/common/spi/Reader.java
100644 → 100755
Empty file.
Empty file modified common/src/main/java/com/alibaba/datax/common/spi/Writer.java
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified common/src/main/java/com/alibaba/datax/common/util/StrUtil.java
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified common/src/test/resources/all.json
100644 → 100755
Empty file.
Empty file modified core/pom.xml
100644 → 100755
Empty file.
Empty file modified core/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file modified core/src/main/bin/datax.py
100644 → 100755
Empty file.
Empty file modified core/src/main/conf/.secret.properties
100644 → 100755
Empty file.
Empty file modified core/src/main/conf/core.json
100644 → 100755
Empty file.
Empty file modified core/src/main/conf/logback.xml
100644 → 100755
Empty file.
Empty file.
Empty file modified core/src/main/java/com/alibaba/datax/core/Engine.java
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file modified core/src/main/java/com/alibaba/datax/core/job/JobContainer.java
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified core/src/main/java/com/alibaba/datax/core/util/ClassUtil.java
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified core/src/main/java/com/alibaba/datax/core/util/SecretUtil.java
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified core/src/main/job/job.json
100644 → 100755
Empty file.
Empty file modified core/src/main/log/datax.log
100644 → 100755
Empty file.
Empty file modified core/src/main/script/Readme.md
100644 → 100755
Empty file.
Empty file modified core/src/main/tmp/readme.txt
100644 → 100755
Empty file.
Empty file modified core/src/test/bin/case/column_case.txt
100644 → 100755
Empty file.
Empty file modified core/src/test/bin/case/empty.xml
100644 → 100755
Empty file.
Empty file modified core/src/test/bin/case/no_reader.xml
100644 → 100755
Empty file.
Empty file modified core/src/test/bin/case/no_writer.xml
100644 → 100755
Empty file.
Empty file modified core/src/test/bin/case/ok.xml
100644 → 100755
Empty file.
Empty file modified core/src/test/bin/xml_converter_test.py
100644 → 100755
Empty file.
Empty file modified core/src/test/java/com/alibaba/datax/core/EngineTest.java
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified core/src/test/java/com/alibaba/datax/core/faker/FakeReader.java
100644 → 100755
Empty file.
Empty file modified core/src/test/java/com/alibaba/datax/core/faker/FakeWriter.java
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified core/src/test/java/com/alibaba/datax/core/util/ReflectUtil.java
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file modified core/src/test/resources/all.json
100644 → 100755
Empty file.
Empty file modified core/src/test/resources/conf/.secret.properties
100644 → 100755
Empty file.
Empty file modified core/src/test/resources/conf/core.json
100644 → 100755
Empty file.
Empty file modified core/src/test/resources/conf/logback.xml
100644 → 100755
Empty file.
Empty file modified core/src/test/resources/job/job.json
100644 → 100755
Empty file.
Empty file.
Empty file modified core/src/test/resources/plugin/reader/fakereader/plugin.json
100644 → 100755
Empty file.
Empty file.
Empty file modified core/src/test/resources/plugin/writer/fakewriter/plugin.json
100644 → 100755
Empty file.
Empty file modified db2reader/pom.xml
100644 → 100755
Empty file.
Empty file modified db2reader/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified db2reader/src/main/libs/db2jcc4.jar
100644 → 100755
Empty file.
Empty file modified db2reader/src/main/resources/plugin.json
100644 → 100755
Empty file.
Empty file modified db2reader/src/test/sources/basic0.json
100644 → 100755
Empty file.
Empty file modified dqchook/pom.xml
100644 → 100755
Empty file.
Empty file modified dqchook/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file modified dqchook/src/main/java/com/alibaba/datax/hook/dqc/DQCHook.java
100644 → 100755
Empty file.
Empty file modified dqchook/src/main/java/com/alibaba/datax/hook/dqc/DTSummary.java
100644 → 100755
Empty file.
Empty file.
Empty file modified dqchook/src/main/resources/dqc.properties
100644 → 100755
Empty file.
Empty file.
Empty file modified dqchook/src/test/resources/dqc.properties
100644 → 100755
Empty file.
Empty file modified drdsreader/pom.xml
100644 → 100755
Empty file.
Empty file modified drdsreader/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified drdsreader/src/main/resources/plugin.json
100644 → 100755
Empty file.
Empty file modified drdsreader/src/test/resources/basic0.json
100644 → 100755
Empty file.
Empty file modified drdswriter/pom.xml
100644 → 100755
Empty file.
Empty file modified drdswriter/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file modified drdswriter/src/main/resources/plugin.json
100644 → 100755
Empty file.
Empty file modified drdswriter/src/test/resources/basic0.json
100644 → 100755
Empty file.
Empty file modified hbasereader/pom.xml
100644 → 100755
Empty file.
Empty file modified hbasereader/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@
import com.alibaba.datax.plugin.reader.hbasereader.ColumnType;
import com.alibaba.datax.plugin.reader.hbasereader.HbaseColumnCell;
import com.alibaba.datax.plugin.reader.hbasereader.HbaseReaderErrorCode;
import org.apache.commons.lang3.time.DateUtils;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.util.Bytes;
import org.apache.http.impl.cookie.DateUtils;

import java.io.IOException;

Expand Down
Empty file modified hbasereader/src/main/resources/plugin.json
100644 → 100755
Empty file.
Empty file modified hbasereader/src/test/resources/mutiVersion_template.json
100644 → 100755
Empty file.
Empty file modified hbasereader/src/test/resources/normal_template.json
100644 → 100755
Empty file.
174 changes: 173 additions & 1 deletion job.json
100644 → 100755
Original file line number Diff line number Diff line change
@@ -1 +1,173 @@
{"common":{"column":{"dateFormat":"yyyy-MM-dd","datetimeFormat":"yyyy-MM-dd HH:mm:ss","encoding":"utf-8","timeFormat":"HH:mm:ss","timeZone":"GMT+8"}},"core":{"channel":{"capacity":128,"class":"com.alibaba.datax.core.MemoryChannel","queue":{"class":"com.alibaba.datax.core.transport.channel.memory.DoubleQueue","timeOut":30},"speed":1000000},"container":{"id":1,"job":{"class":"com.alibaba.datax.core.container.JobContainer","reportInterval":1000},"model":"master","taskGroup":{"channel":3,"class":"com.alibaba.datax.core.container.TaskGroupContainer"}},"plugin":{"exchanger":{"bufferSize":32,"class":"com.alibaba.datax.core.plugin.BufferedRecordExchanger"}},"scheduler":{"class":"com.alibaba.datax.core.scheduler.standalone.StandAloneScheduler"},"statistics":{"collector":{"container":{"jobClass":"com.alibaba.datax.core.statistics.collector.container.standalone.JobContainerCollector","taskGroupClass":"com.alibaba.datax.core.statistics.collector.container.standalone.TaskGroupContainerCollector"},"framework":{"jobClass":"com.alibaba.datax.core.statistics.collector.container.standalone.JobContainerCollector","taskGroupClass":"com.alibaba.datax.core.statistics.collector.container.standalone.TaskGroupContainerCollector"},"plugin":{"maxDirtyNumber":1000,"taskClass":"com.alibaba.datax.core.statistics.plugin.task.StdoutPluginCollector"}}},"transport":{"channel":{"capacity":32,"class":"com.alibaba.datax.core.transport.channel.memory.MemoryChannel","speed":{"byte":1048576,"record":10000}},"exchanger":{"bufferSize":32,"class":"com.alibaba.datax.core.plugin.BufferedRecordExchanger"}}},"entry":{"environment":{"DATAX_HOME":"/home/admin","PATH":"/home/admin"},"jvm":"-Xms1G -Xmx1G"},"job":{"content":[{"reader":{"name":"fakereader","parameter":{"jdbcUrl":[["jdbc:mysql://localhost:3305/db1","jdbc:mysql://localhost:3306/db1"],["jdbc:mysql://localhost:3305/db2","jdbc:mysql://localhost:3306/db2"]],"table":["bazhen_[0-15]","bazhen_[15-31]"]}},"writer":{"name":"fakewriter","parameter":{"column":[{"name":"id","type":"string"},{"name":"age","type":"int"}],"encode":"utf-8","hbase-conf":"/home/hbase/hbase-conf.xml"}}}],"setting":{"errorLimit":{},"speed":{"byte":104857600}}},"plugin":{"reader":{"fakereader":{"class":"com.alibaba.datax.core.faker.FakeReader","description":{"mechanism":"Produce Record from memory.","useScene":"only for performance test.","warn":"Never use it in your real job."},"developer":"someBody,bug reported to : someBody@someSite","name":"fakereader","path":"/Users/hjc/work/git_project/datax/core/target/test-classes//plugin/reader/fakereader"},"mysqlreader":{"class":"com.alibaba.datax.plugins.reader.fakereader.FakeReader","description":{"mechanism":"Produce Record from memory.","useScene":"only for performance test.","warn":"Never use it in your real job."},"developer":"someBody,bug reported to : someBody@someSite","name":"fakereader"},"oraclereader":{"class":"com.alibaba.datax.plugins.reader.oraclereader.OracleReader","description":{"mechanism":"Produce Record from memory.","useScene":"only for performance test.","warn":"Never use it in your real job."},"developer":"someBody,bug reported to : someBody@someSite","name":"oraclereader"}},"transformer":{"groovyTranformer":{}},"writer":{"fakewriter":{"class":"com.alibaba.datax.core.faker.FakeWriter","description":{"mechanism":"Produce Record from memory.","useScene":"only for performance test.","warn":"Never use it in your real job."},"developer":"someBody,bug reported to : someBody@someSite","name":"fakewriter","path":"/Users/hjc/work/git_project/datax/core/target/test-classes//plugin/writer/fakewriter"}}}}
{
"common": {
"column": {
"dateFormat": "yyyy-MM-dd",
"datetimeFormat": "yyyy-MM-dd HH:mm:ss",
"encoding": "utf-8",
"timeFormat": "HH:mm:ss",
"timeZone": "GMT+8"
}
},
"core": {
"channel": {
"capacity": 128,
"class": "com.alibaba.datax.core.MemoryChannel",
"queue": {
"class": "com.alibaba.datax.core.transport.channel.memory.DoubleQueue",
"timeOut": 30
},
"speed": 1000000
},
"container": {
"id": 1,
"job": {
"class": "com.alibaba.datax.core.container.JobContainer",
"reportInterval": 1000
},
"model": "master",
"taskGroup": {
"channel": 3,
"class": "com.alibaba.datax.core.container.TaskGroupContainer"
}
},
"plugin": {
"exchanger": {
"bufferSize": 32,
"class": "com.alibaba.datax.core.plugin.BufferedRecordExchanger"
}
},
"scheduler": {"class": "com.alibaba.datax.core.scheduler.standalone.StandAloneScheduler"},
"statistics": {
"collector": {
"container": {
"jobClass": "com.alibaba.datax.core.statistics.collector.container.standalone.JobContainerCollector",
"taskGroupClass": "com.alibaba.datax.core.statistics.collector.container.standalone.TaskGroupContainerCollector"
},
"framework": {
"jobClass": "com.alibaba.datax.core.statistics.collector.container.standalone.JobContainerCollector",
"taskGroupClass": "com.alibaba.datax.core.statistics.collector.container.standalone.TaskGroupContainerCollector"
},
"plugin": {
"maxDirtyNumber": 1000,
"taskClass": "com.alibaba.datax.core.statistics.plugin.task.StdoutPluginCollector"
}
}
},
"transport": {
"channel": {
"capacity": 32,
"class": "com.alibaba.datax.core.transport.channel.memory.MemoryChannel",
"speed": {
"byte": 1048576,
"record": 10000
}
},
"exchanger": {
"bufferSize": 32,
"class": "com.alibaba.datax.core.plugin.BufferedRecordExchanger"
}
}
},
"entry": {
"environment": {
"DATAX_HOME": "/home/admin",
"PATH": "/home/admin"
},
"jvm": "-Xms1G -Xmx1G"
},
"job": {
"content": [
{
"reader": {
"name": "fakereader",
"parameter": {
"jdbcUrl": [
[
"jdbc:mysql://localhost:3305/db1",
"jdbc:mysql://localhost:3306/db1"
],
[
"jdbc:mysql://localhost:3305/db2",
"jdbc:mysql://localhost:3306/db2"
]
],
"table": [
"bazhen_[0-15]",
"bazhen_[15-31]"
]
}
},
"writer": {
"name": "fakewriter",
"parameter": {
"column": [
{
"name": "id",
"type": "string"
},
{
"name": "age",
"type": "int"
}
],
"encode": "utf-8",
"hbase-conf": "/home/hbase/hbase-conf.xml"
}
}
}
],
"setting": {
"errorLimit": {},
"speed": {"byte": 104857600}
}
},
"plugin": {
"reader": {
"fakereader": {
"class": "com.alibaba.datax.core.faker.FakeReader",
"description": {
"mechanism": "Produce Record from memory.",
"useScene": "only for performance test.",
"warn": "Never use it in your real job."
},
"developer": "someBody,bug reported to : someBody@someSite",
"name": "fakereader",
"path": "/Users/hjc/work/git_project/datax/core/target/test-classes//plugin/reader/fakereader"
},
"mysqlreader": {
"class": "com.alibaba.datax.plugins.reader.fakereader.FakeReader",
"description": {
"mechanism": "Produce Record from memory.",
"useScene": "only for performance test.",
"warn": "Never use it in your real job."
},
"developer": "someBody,bug reported to : someBody@someSite",
"name": "fakereader"
},
"oraclereader": {
"class": "com.alibaba.datax.plugins.reader.oraclereader.OracleReader",
"description": {
"mechanism": "Produce Record from memory.",
"useScene": "only for performance test.",
"warn": "Never use it in your real job."
},
"developer": "someBody,bug reported to : someBody@someSite",
"name": "oraclereader"
}
},
"transformer": {"groovyTranformer": {}},
"writer": {
"fakewriter": {
"class": "com.alibaba.datax.core.faker.FakeWriter",
"description": {
"mechanism": "Produce Record from memory.",
"useScene": "only for performance test.",
"warn": "Never use it in your real job."
},
"developer": "someBody,bug reported to : someBody@someSite",
"name": "fakewriter",
"path": "/Users/hjc/work/git_project/datax/core/target/test-classes//plugin/writer/fakewriter"
}
}
}
}
Empty file modified mysqlreader/pom.xml
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file modified mysqlreader/src/main/resources/TODO.txt
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/main/resources/plugin.json
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file modified mysqlreader/src/test/resources/basic0.json
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/basic1.json
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/basic7.json
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/case1.json
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/case2.json
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/case3.json
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/case4.json
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/case5.json
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/case6_null.json
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/data/create_db_table.sql
100644 → 100755
Empty file.
Empty file modified mysqlreader/src/test/resources/data/db.conn
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified mysqlwriter/pom.xml
100644 → 100755
Empty file.
Empty file modified mysqlwriter/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file modified mysqlwriter/src/main/resources/plugin.json
100644 → 100755
Empty file.
Empty file.
Empty file modified mysqlwriter/src/test/resources/basic0.json
100644 → 100755
Empty file.
Empty file modified mysqlwriter/src/test/resources/basic1.json
100644 → 100755
Empty file.
Empty file modified mysqlwriter/src/test/resources/basic2.json
100644 → 100755
Empty file.
Empty file modified mysqlwriter/src/test/resources/data/create_db_table.sql
100644 → 100755
Empty file.
Empty file modified mysqlwriter/src/test/resources/data/db.conn
100644 → 100755
Empty file.
Empty file modified odpsreader/pom.xml
100644 → 100755
Empty file.
Empty file modified odpsreader/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified odpsreader/src/main/resources/TODO.txt
100644 → 100755
Empty file.
Empty file modified odpsreader/src/main/resources/plugin.json
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file modified odpsreader/src/test/resources/basic0.json
100644 → 100755
Empty file.
Empty file modified odpsreader/src/test/resources/basic1.json
100644 → 100755
Empty file.
Empty file modified odpsreader/src/test/resources/basic2.json
100644 → 100755
Empty file.
Empty file modified odpswriter/pom.xml
100644 → 100755
Empty file.
Empty file modified odpswriter/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified odpswriter/src/main/libs/gson-1.6.jar.jar
100644 → 100755
Empty file.
Empty file modified odpswriter/src/main/libs/odps-tunnel-sdk-1.0.jar
100644 → 100755
Empty file.
Empty file modified odpswriter/src/main/resources/TODO.txt
100644 → 100755
Empty file.
Empty file modified odpswriter/src/main/resources/plugin.json
100644 → 100755
Empty file.
Empty file.
Empty file.
Empty file.
Empty file modified odpswriter/src/test/resources/basic0.json
100644 → 100755
Empty file.
Empty file modified odpswriter/src/test/resources/basic1.json
100644 → 100755
Empty file.
Empty file modified odpswriter/src/test/resources/basic2.json
100644 → 100755
Empty file.
Empty file modified odpswriter/src/test/resources/basic3.json
100644 → 100755
Empty file.
Empty file modified odpswriter/src/test/resources/data/create_odps_table.sql
100644 → 100755
Empty file.
Empty file modified oraclereader/pom.xml
100644 → 100755
Empty file.
Empty file modified oraclereader/src/main/assembly/package.xml
100644 → 100755
Empty file.
Empty file.
Empty file.
Loading

0 comments on commit 2bdc595

Please sign in to comment.