github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-04 06:10:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

ref: modify package name

Browse Source
This commit is contained in:
lispQin 2023-01-17 09:10:15 +08:00
parent a2c4be1d1f
commit c4910206f1
66 changed files with 72 additions and 80 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tdengine20reader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReader.java → tdengine20reader/src/main/java/com/alibaba/datax/plugin/tdengine20reader/TDengineReader.java
View File

@ -1,11 +1,11 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.common.element.*; import com.alibaba.datax.common.element.*;
import com.alibaba.datax.common.exception.DataXException; import com.alibaba.datax.common.exception.DataXException;
import com.alibaba.datax.common.plugin.RecordSender; import com.alibaba.datax.common.plugin.RecordSender;
import com.alibaba.datax.common.spi.Reader; import com.alibaba.datax.common.spi.Reader;
import com.alibaba.datax.common.util.Configuration; import com.alibaba.datax.common.util.Configuration;
import com.alibaba.datax.plugin.writer.tdenginewriter.Key; import com.alibaba.datax.plugin.writer.tdengine20writer.Key;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
@ -15,8 +15,6 @@ import java.sql.*;
import java.text.ParseException; import java.text.ParseException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List; import java.util.List;
public class TDengineReader extends Reader { public class TDengineReader extends Reader {

2
tdengine30reader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReaderErrorCode.java → tdengine20reader/src/main/java/com/alibaba/datax/plugin/tdengine20reader/TDengineReaderErrorCode.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.common.spi.ErrorCode; import com.alibaba.datax.common.spi.ErrorCode;

4
tdengine20reader/src/main/resources/plugin.json
View File

@ -1,6 +1,6 @@
{ {
"name": "tdengin20ereader", "name": "tdengine20reader",
"class": "com.alibaba.datax.plugin.reader.TDengineReader", "class": "com.alibaba.datax.plugin.tdengine20reader.TDengineReader",
"description": { "description": {
"useScene": "data migration from tdengine", "useScene": "data migration from tdengine",
"mechanism": "use JDBC to read data from tdengine." "mechanism": "use JDBC to read data from tdengine."

4
tdengine20reader/src/test/java/com/alibaba/datax/plugin/reader/TDengine2DMTest.java → tdengine20reader/src/test/java/com/alibaba/datax/plugin/tdengine20reader/TDengine2DMTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Ignore; import org.junit.Ignore;
@ -31,7 +31,7 @@ public class TDengine2DMTest {
@Test @Test
public void t2dm_case02() throws Throwable { public void t2dm_case02() throws Throwable {
// given // given
createSupTable("us"); // createSupTable("us");
// when // when
String[] params = {"-mode", "standalone", "-jobid", "-1", "-job", "src/test/resources/t2dm.json"}; String[] params = {"-mode", "standalone", "-jobid", "-1", "-job", "src/test/resources/t2dm.json"};

2
tdengine30reader/src/test/java/com/alibaba/datax/plugin/reader/TDengine2StreamTest.java → tdengine20reader/src/test/java/com/alibaba/datax/plugin/tdengine20reader/TDengine2StreamTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Ignore; import org.junit.Ignore;

4
tdengine20reader/src/test/java/com/alibaba/datax/plugin/reader/TDengineReaderTest.java → tdengine20reader/src/test/java/com/alibaba/datax/plugin/tdengine20reader/TDengineReaderTest.java
View File

@ -1,7 +1,7 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.common.util.Configuration; import com.alibaba.datax.common.util.Configuration;
import com.alibaba.datax.plugin.writer.tdenginewriter.Key; import com.alibaba.datax.plugin.writer.tdengine20writer.Key;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;

2
tdengine20reader/src/test/resources/t2dm.json
View File

@ -3,7 +3,7 @@
"content": [ "content": [
{ {
"reader": { "reader": {
"name": "tdenginereader", "name": "tdengine20reader",
"parameter": { "parameter": {
"username": "root", "username": "root",
"password": "taosdata", "password": "taosdata",

2
tdengine20reader/src/test/resources/t2stream-1.json
View File

@ -3,7 +3,7 @@
"content": [ "content": [
{ {
"reader": { "reader": {
"name": "tdenginereader", "name": "tdengine20reader",
"parameter": { "parameter": {
"username": "root", "username": "root",
"password": "taosdata", "password": "taosdata",

2
tdengine20reader/src/test/resources/t2stream-2.json
View File

@ -3,7 +3,7 @@
"content": [ "content": [
{ {
"reader": { "reader": {
"name": "tdenginereader", "name": "tdengine20reader",
"parameter": { "parameter": {
"username": "root", "username": "root",
"password": "taosdata", "password": "taosdata",

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/ColumnMeta.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/ColumnMeta.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public class ColumnMeta { public class ColumnMeta {
String field; String field;

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/Constants.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/Constants.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public class Constants { public class Constants {
public static final String DEFAULT_USERNAME = "root"; public static final String DEFAULT_USERNAME = "root";

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DataHandler.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/DataHandler.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.plugin.RecordReceiver; import com.alibaba.datax.common.plugin.RecordReceiver;
import com.alibaba.datax.common.plugin.TaskPluginCollector; import com.alibaba.datax.common.plugin.TaskPluginCollector;

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/DefaultDataHandler.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.element.Column; import com.alibaba.datax.common.element.Column;
import com.alibaba.datax.common.element.Record; import com.alibaba.datax.common.element.Record;

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/Key.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/Key.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public class Key { public class Key {
public static final String USERNAME = "username"; public static final String USERNAME = "username";

3
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/OpentsdbDataHandler.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/OpentsdbDataHandler.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.element.Column; import com.alibaba.datax.common.element.Column;
import com.alibaba.datax.common.element.Record; import com.alibaba.datax.common.element.Record;
@ -14,7 +14,6 @@ import org.slf4j.LoggerFactory;
import java.sql.Connection; import java.sql.Connection;
import java.sql.DriverManager; import java.sql.DriverManager;
import java.sql.SQLException;
public class OpentsdbDataHandler implements DataHandler { public class OpentsdbDataHandler implements DataHandler {
private static final Logger LOG = LoggerFactory.getLogger(OpentsdbDataHandler.class); private static final Logger LOG = LoggerFactory.getLogger(OpentsdbDataHandler.class);

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/SchemaManager.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/SchemaManager.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.exception.DataXException; import com.alibaba.datax.common.exception.DataXException;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TDengineWriter.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TDengineWriter.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.exception.DataXException; import com.alibaba.datax.common.exception.DataXException;
import com.alibaba.datax.common.plugin.RecordReceiver; import com.alibaba.datax.common.plugin.RecordReceiver;

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TDengineWriterErrorCode.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TDengineWriterErrorCode.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.spi.ErrorCode; import com.alibaba.datax.common.spi.ErrorCode;

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TableMeta.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TableMeta.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public class TableMeta { public class TableMeta {
TableType tableType; TableType tableType;

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TableType.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TableType.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public enum TableType { public enum TableType {
SUP_TABLE, SUB_TABLE, NML_TABLE SUP_TABLE, SUB_TABLE, NML_TABLE

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TimestampPrecision.java → tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TimestampPrecision.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public enum TimestampPrecision { public enum TimestampPrecision {
MILLISEC, MICROSEC, NANOSEC MILLISEC, MICROSEC, NANOSEC

2
tdengine20writer/src/main/resources/plugin.json
View File

@ -1,6 +1,6 @@
{ {
"name": "tdengine20writer", "name": "tdengine20writer",
"class": "com.alibaba.datax.plugin.writer.tdenginewriter.TDengineWriter", "class": "com.alibaba.datax.plugin.writer.tdengine20writer.TDengineWriter",
"description": { "description": {
"useScene": "data migration to tdengine", "useScene": "data migration to tdengine",
"mechanism": "use taos-jdbcdriver to write data." "mechanism": "use taos-jdbcdriver to write data."

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Csv2TDengineTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Csv2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Ignore; import org.junit.Ignore;

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/DM2TDengineTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/DM2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Before; import org.junit.Before;

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandlerTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/DefaultDataHandlerTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.element.DateColumn; import com.alibaba.datax.common.element.DateColumn;
import com.alibaba.datax.common.element.LongColumn; import com.alibaba.datax.common.element.LongColumn;

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Mongo2TDengineTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Mongo2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Test; import org.junit.Test;

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Mysql2TDengineTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Mysql2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Before; import org.junit.Before;

3
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Mysql2TDengineTest2.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Mysql2TDengineTest2.java
View File

@ -1,8 +1,7 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.apache.commons.lang3.RandomStringUtils; import org.apache.commons.lang3.RandomStringUtils;
import org.apache.commons.lang3.StringUtils;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Mysql2TDengineTest3.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Mysql2TDengineTest3.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.apache.commons.lang3.RandomStringUtils; import org.apache.commons.lang3.RandomStringUtils;

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Opentsdb2TDengineTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Opentsdb2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Assert; import org.junit.Assert;

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/SchemaManagerTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/SchemaManagerTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.Assert; import org.junit.Assert;

3
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Stream2TDengineTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Stream2TDengineTest.java
View File

@ -1,7 +1,6 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import java.sql.Connection; import java.sql.Connection;

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/TDengine2TDengineTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/TDengine2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Before; import org.junit.Before;

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/TDengineWriterTest.java → tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/TDengineWriterTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.util.Configuration; import com.alibaba.datax.common.util.Configuration;
import org.junit.Assert; import org.junit.Assert;

4
tdengine30reader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReader.java → tdengine30reader/src/main/java/com/alibaba/datax/plugin/tdengine20reader/TDengineReader.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.common.element.*; import com.alibaba.datax.common.element.*;
import com.alibaba.datax.common.element.Record; import com.alibaba.datax.common.element.Record;
@ -6,7 +6,7 @@ import com.alibaba.datax.common.exception.DataXException;
import com.alibaba.datax.common.plugin.RecordSender; import com.alibaba.datax.common.plugin.RecordSender;
import com.alibaba.datax.common.spi.Reader; import com.alibaba.datax.common.spi.Reader;
import com.alibaba.datax.common.util.Configuration; import com.alibaba.datax.common.util.Configuration;
import com.alibaba.datax.plugin.writer.tdenginewriter.Key; import com.alibaba.datax.plugin.writer.tdengine20writer.Key;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;

2
tdengine20reader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReaderErrorCode.java → tdengine30reader/src/main/java/com/alibaba/datax/plugin/tdengine20reader/TDengineReaderErrorCode.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.common.spi.ErrorCode; import com.alibaba.datax.common.spi.ErrorCode;

2
tdengine30reader/src/main/resources/plugin.json
View File

@ -1,6 +1,6 @@
{ {
"name": "tdengine30reader", "name": "tdengine30reader",
"class": "com.alibaba.datax.plugin.reader.TDengineReader", "class": "com.alibaba.datax.plugin.tdengine30reader.TDengineReader",
"description": { "description": {
"useScene": "data migration from tdengine", "useScene": "data migration from tdengine",
"mechanism": "use JDBC to read data from tdengine." "mechanism": "use JDBC to read data from tdengine."

2
tdengine30reader/src/test/java/com/alibaba/datax/plugin/reader/TDengine2DMTest.java → tdengine30reader/src/test/java/com/alibaba/datax/plugin/tdengine20reader/TDengine2DMTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Ignore; import org.junit.Ignore;

2
tdengine20reader/src/test/java/com/alibaba/datax/plugin/reader/TDengine2StreamTest.java → tdengine30reader/src/test/java/com/alibaba/datax/plugin/tdengine20reader/TDengine2StreamTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Ignore; import org.junit.Ignore;

4
tdengine30reader/src/test/java/com/alibaba/datax/plugin/reader/TDengineReaderTest.java → tdengine30reader/src/test/java/com/alibaba/datax/plugin/tdengine20reader/TDengineReaderTest.java
View File

@ -1,7 +1,7 @@
package com.alibaba.datax.plugin.reader; package com.alibaba.datax.plugin.tdengine20reader;
import com.alibaba.datax.common.util.Configuration; import com.alibaba.datax.common.util.Configuration;
import com.alibaba.datax.plugin.writer.tdenginewriter.Key; import com.alibaba.datax.plugin.writer.tdengine20writer.Key;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Test; import org.junit.Test;

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/ColumnMeta.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/ColumnMeta.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public class ColumnMeta { public class ColumnMeta {
String field; String field;

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/Constants.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/Constants.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public class Constants { public class Constants {
public static final String DEFAULT_USERNAME = "root"; public static final String DEFAULT_USERNAME = "root";

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DataHandler.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/DataHandler.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.plugin.RecordReceiver; import com.alibaba.datax.common.plugin.RecordReceiver;
import com.alibaba.datax.common.plugin.TaskPluginCollector; import com.alibaba.datax.common.plugin.TaskPluginCollector;

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/DefaultDataHandler.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.element.Column; import com.alibaba.datax.common.element.Column;
import com.alibaba.datax.common.element.Record; import com.alibaba.datax.common.element.Record;

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/Key.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/Key.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public class Key { public class Key {
public static final String USERNAME = "username"; public static final String USERNAME = "username";

3
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/OpentsdbDataHandler.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/OpentsdbDataHandler.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.element.Column; import com.alibaba.datax.common.element.Column;
import com.alibaba.datax.common.element.Record; import com.alibaba.datax.common.element.Record;
@ -14,7 +14,6 @@ import org.slf4j.LoggerFactory;
import java.sql.Connection; import java.sql.Connection;
import java.sql.DriverManager; import java.sql.DriverManager;
import java.sql.SQLException;
public class OpentsdbDataHandler implements DataHandler { public class OpentsdbDataHandler implements DataHandler {
private static final Logger LOG = LoggerFactory.getLogger(OpentsdbDataHandler.class); private static final Logger LOG = LoggerFactory.getLogger(OpentsdbDataHandler.class);

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/Schema3_0Manager.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/Schema3_0Manager.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.exception.DataXException; import com.alibaba.datax.common.exception.DataXException;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/SchemaManager.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/SchemaManager.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.exception.DataXException; import com.alibaba.datax.common.exception.DataXException;
import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.StringUtils;

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TDengineWriter.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TDengineWriter.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.exception.DataXException; import com.alibaba.datax.common.exception.DataXException;
import com.alibaba.datax.common.plugin.RecordReceiver; import com.alibaba.datax.common.plugin.RecordReceiver;

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TDengineWriterErrorCode.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TDengineWriterErrorCode.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.spi.ErrorCode; import com.alibaba.datax.common.spi.ErrorCode;

2
tdengine20writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TableMeta.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TableMeta.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public class TableMeta { public class TableMeta {
TableType tableType; TableType tableType;

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TableType.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TableType.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public enum TableType { public enum TableType {
SUP_TABLE, SUB_TABLE, NML_TABLE SUP_TABLE, SUB_TABLE, NML_TABLE

2
tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/TimestampPrecision.java → tdengine30writer/src/main/java/com/alibaba/datax/plugin/writer/tdengine20writer/TimestampPrecision.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
public enum TimestampPrecision { public enum TimestampPrecision {
MILLISEC, MICROSEC, NANOSEC MILLISEC, MICROSEC, NANOSEC

2
tdengine30writer/src/main/resources/plugin.json
View File

@ -1,6 +1,6 @@
{ {
"name": "tdengine30writer", "name": "tdengine30writer",
"class": "com.alibaba.datax.plugin.writer.tdenginewriter.TDengineWriter", "class": "com.alibaba.datax.plugin.writer.tdengine30writer.TDengineWriter",
"description": { "description": {
"useScene": "data migration to tdengine", "useScene": "data migration to tdengine",
"mechanism": "use taos-jdbcdriver to write data." "mechanism": "use taos-jdbcdriver to write data."

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Csv2TDengineTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Csv2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Ignore; import org.junit.Ignore;

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/DM2TDengineTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/DM2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Before; import org.junit.Before;

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandlerTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/DefaultDataHandlerTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.element.DateColumn; import com.alibaba.datax.common.element.DateColumn;
import com.alibaba.datax.common.element.LongColumn; import com.alibaba.datax.common.element.LongColumn;

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Mongo2TDengineTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Mongo2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Test; import org.junit.Test;

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Mysql2TDengineTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Mysql2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Before; import org.junit.Before;

3
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Mysql2TDengineTest2.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Mysql2TDengineTest2.java
View File

@ -1,8 +1,7 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.apache.commons.lang3.RandomStringUtils; import org.apache.commons.lang3.RandomStringUtils;
import org.apache.commons.lang3.StringUtils;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Mysql2TDengineTest3.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Mysql2TDengineTest3.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.apache.commons.lang3.RandomStringUtils; import org.apache.commons.lang3.RandomStringUtils;

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Opentsdb2TDengineTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Opentsdb2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Assert; import org.junit.Assert;

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/SchemaManagerTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/SchemaManagerTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import org.junit.AfterClass; import org.junit.AfterClass;
import org.junit.Assert; import org.junit.Assert;

3
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Stream2TDengineTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/Stream2TDengineTest.java
View File

@ -1,7 +1,6 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import java.sql.Connection; import java.sql.Connection;

2
tdengine20writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/TDengine2TDengineTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/TDengine2TDengineTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.core.Engine; import com.alibaba.datax.core.Engine;
import org.junit.Before; import org.junit.Before;

2
tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/TDengineWriterTest.java → tdengine30writer/src/test/java/com/alibaba/datax/plugin/writer/tdengine20writer/TDengineWriterTest.java
View File

@ -1,4 +1,4 @@
package com.alibaba.datax.plugin.writer.tdenginewriter; package com.alibaba.datax.plugin.writer.tdengine20writer;
import com.alibaba.datax.common.util.Configuration; import com.alibaba.datax.common.util.Configuration;
import org.junit.Assert; import org.junit.Assert;