|
|
@@ -5,7 +5,6 @@ from configparser import ConfigParser
|
|
|
from typing import Dict, List
|
|
|
|
|
|
from dw_base.common.template_constants import MYSQL_HIVE_CREATE_TABLE_TEMPLATE, MYSQL_HIVE_HBASE_CREATE_TABLE_TEMPLATE
|
|
|
-from dw_base.database.mysql_utils import MySQLColumn
|
|
|
from dw_base.datax.datax_constants import *
|
|
|
from dw_base.datax.plugins.reader.reader import Reader
|
|
|
from dw_base.utils.datetime_utils import local_2_utc, parse_datetime
|
|
|
@@ -196,7 +195,7 @@ class MySQLReader(Reader):
|
|
|
hive_table_name: str,
|
|
|
table_comment: str,
|
|
|
partitioned: bool,
|
|
|
- columns: List[MySQLColumn],
|
|
|
+ columns: List,
|
|
|
column_types: Dict[str, str]) -> str:
|
|
|
columns_definition = []
|
|
|
partition_def = ''
|
|
|
@@ -224,7 +223,7 @@ class MySQLReader(Reader):
|
|
|
table_comment: str,
|
|
|
hbase_namespace: str,
|
|
|
hbase_table_name: str,
|
|
|
- columns: List[MySQLColumn],
|
|
|
+ columns: List,
|
|
|
column_types: Dict[str, str]) -> str:
|
|
|
columns_definition = []
|
|
|
hbase_column_mapping_definition = []
|