Erman Arslan's Oracle Forum

Oracle to Kudu

Posted by Roshan on Oct 06, 2020; 5:06pm
URL: http://erman-arslan-s-oracle-forum.124.s1.nabble.com/Oracle-to-Kudu-tp8834.html

Hi Erman,

Do you know any tool to convert Oracle SQL to Kudu SQL?

I am facing some mapping issues during the initial load.

Error while writing batch on table impala::common.gsm_service_mast Reason Mapping of SourceType {org.joda.time.DateTime} to TargetType {INT64(-5)} is not supported for target filed {data_speed_n}. Source Table {CBSOGG.GSM_SERVICE_MAST} Target Table {impala::common.gsm_service_mast}, Source Index {58}, Target index {58}. Cause: Mapping of SourceType {org.joda.time.DateTime} to TargetType {INT64(-5)} is not supported for target filed {data_speed_n}. Source Table {CBSOGG.GSM_SERVICE_MAST} Target Table {impala::common.gsm_service_mast}, Source Index {58}, Target index {58}

Source DDL:

ACCOUNT_LINK_CODE_N NUMBER(10,0)
ACCOUNT_CODE_N NUMBER(10,0)
STATUS_CODE_V VARCHAR2(2 BYTE)
STATUS_REASON_CODE_N VARCHAR2(10 BYTE)
INTERIM_STATUS_CODE_V VARCHAR2(2 BYTE)
SIM_NUM_V VARCHAR2(20 BYTE)
IMSI_NUM_N NUMBER(15,0)
IMSI_ACTIVE_DATE_D TIMESTAMP(6) WITH TIME ZONE
MOBL_NUM_VOICE_V VARCHAR2(16 BYTE)
MOBL_NUM_DATA_V VARCHAR2(16 BYTE)
MOBL_NUM_FAX_V VARCHAR2(16 BYTE)
PACKAGE_CODE_V VARCHAR2(7 BYTE)
SUB_PACKAGE_CODE_V VARCHAR2(3 BYTE)
PACKAGE_START_DATE_D TIMESTAMP(6) WITH TIME ZONE
TARIFF_CODE_V VARCHAR2(6 BYTE)
TARIFF_START_DATE_D TIMESTAMP(6) WITH TIME ZONE
CONTRACT_TYPE_V VARCHAR2(1 BYTE)
VALIDITY_DATE_D TIMESTAMP(6) WITH TIME ZONE
VALIDITY_GRACE_DAYS_N NUMBER(2,0)
SERVICE_INDICATOR_V VARCHAR2(15 BYTE)
ROAMING_TYPE_N NUMBER(1,0)
AIRTM_RATE_START_DATE_D TIMESTAMP(6) WITH TIME ZONE
SCHEDUL_SERVICE_EXEC_DATE_D TIMESTAMP(6) WITH TIME ZONE
MID_CYCL_DISC_DATE_D TIMESTAMP(6) WITH TIME ZONE
ONLINE_BATCH_RATE_OPTN_V VARCHAR2(1 BYTE)
OUTGOING_BARRD_DATE_D TIMESTAMP(6) WITH TIME ZONE
SPECIAL_CATEGORY_INDICATORS_V VARCHAR2(10 BYTE)
SPECIAL_CATEGORY_CHANGE_DATE_D TIMESTAMP(6) WITH TIME ZONE
SPECIAL_TARF_CODE_V VARCHAR2(6 BYTE)
SPECIAL_TARF_DATE_D TIMESTAMP(6) WITH TIME ZONE
CHRG_EXPTN_PH_FLG_V VARCHAR2(1 BYTE)
CEL_ID_ZONE_CODE_V VARCHAR2(6 BYTE)
CEL_ID_START_DATE_D TIMESTAMP(6) WITH TIME ZONE
CEL_ID_END_DATE_D TIMESTAMP(6) WITH TIME ZONE
CUG_GRP_CODE_V VARCHAR2(10 BYTE)
SUBS_CUG_START_DATE_D TIMESTAMP(6) WITH TIME ZONE
SUBS_CUG_END_DATE_D TIMESTAMP(6) WITH TIME ZONE
GRP_PHONE_START_DATE_D TIMESTAMP(6) WITH TIME ZONE
GRP_PHONE_END_DATE_D TIMESTAMP(6) WITH TIME ZONE
FRNDS_START_DATE_D TIMESTAMP(6) WITH TIME ZONE
FRNDS_END_DATE_D TIMESTAMP(6) WITH TIME ZONE
EXEC_MEDI_FLG_V VARCHAR2(1 BYTE)
PROV_PRIORITY_N NUMBER(1,0)
X_DIRECTORY_LEVEL_N NUMBER(2,0)
BAR_ON_THRESHOLD_FLG_V VARCHAR2(1 BYTE)
ACTIVATED_BY_USER_CODE_N NUMBER(10,0)
REGISTRATION_DATE_D TIMESTAMP(6) WITH TIME ZONE
ACTIVATION_DATE_D TIMESTAMP(6) WITH TIME ZONE
REACTIVATION_DATE_D TIMESTAMP(6) WITH TIME ZONE
SUSPENDED_DATE_D TIMESTAMP(6) WITH TIME ZONE
ERASED_DATE_D TIMESTAMP(6) WITH TIME ZONE
MODIFIED_DATE_D TIMESTAMP(6) WITH TIME ZONE
MOBILE_ACTIVATED_DATE_DT TIMESTAMP(6) WITH TIME ZONE
PROFILE_CODE_V VARCHAR2(64 BYTE)
SUBS_TITLE_V VARCHAR2(40 BYTE)
SUBS_NAME_V VARCHAR2(120 BYTE)
IC_NUMBER_V VARCHAR2(32 BYTE)
CONTRACT_START_D TIMESTAMP(6) WITH TIME ZONE
CONTRACT_END_D TIMESTAMP(6) WITH TIME ZONE
PRE_TERMINATE_DATE_D TIMESTAMP(6) WITH TIME ZONE
AMPS_FLG_V VARCHAR2(1 BYTE)
TRANSFER_IN_SERVICE_TYPES_N NUMBER(1,0)
TRANSFER_FROM_ACC_LINK_CODE_N NUMBER(10,0)
RESTRICT_SMS_FLAG_V VARCHAR2(1 BYTE)
ACCESS_PASSWORD_V VARCHAR2(30 BYTE)
VIP_FLAG_V VARCHAR2(1 BYTE)
ID_TYPE_V VARCHAR2(10 BYTE)
PREFERRED_LANGUAGE_V VARCHAR2(10 BYTE)
GENDER_V VARCHAR2(1 BYTE)
FAMILY_NAME_V VARCHAR2(80 BYTE)
EMAIL_ID_V VARCHAR2(50 BYTE)
CONTACT_MOBL_NUM_V VARCHAR2(20 BYTE)
CONTACT_HOME_NUM_V VARCHAR2(20 BYTE)
CONTACT_OFFICE_NUM_V VARCHAR2(20 BYTE)
FAX_NUM_V VARCHAR2(20 BYTE)
ACCOUNT_MANAGER_N NUMBER(10,0)
SALES_REP_V VARCHAR2(10 BYTE)
DEALER_CODE_V VARCHAR2(10 BYTE)
DMS_RECIVED_FLAG_V VARCHAR2(1 BYTE)
DMS_RECIVED_DATE_D TIMESTAMP(6) WITH TIME ZONE
DMS_VERIFIED_FLAG_V VARCHAR2(1 BYTE)
BUSINESS_INDIVIDUAL_V VARCHAR2(1 BYTE)
COMPANY_NAME_V VARCHAR2(60 BYTE)
COMPANY_REGISTRATION_NO_V VARCHAR2(30 BYTE)
COMPANY_CONTACT_NUM_V VARCHAR2(20 BYTE)
REGISTERED_LOCATION_V VARCHAR2(20 BYTE)
PROFILE_TYPE_V VARCHAR2(1 BYTE)
SUBSCRIBER_CATEGORY_V VARCHAR2(8 BYTE)
SUBSCRIBER_SUB_CATEGORY_V VARCHAR2(8 BYTE)
SUBSCRIBER_SEGMENT_V VARCHAR2(10 BYTE)
HOME_FAX_NUM_V VARCHAR2(20 BYTE)
ID_EXPIRY_DATE_D TIMESTAMP(6) WITH TIME ZONE
OCCUPATION_CODE_V VARCHAR2(10 BYTE)
EMPLOYED_FROM_DATE_D TIMESTAMP(6) WITH TIME ZONE
READY_TO_GO_DATE_D TIMESTAMP(6) WITH TIME ZONE
ADDRESS_RECIVED_FLAG_V VARCHAR2(1 BYTE)
LAST_EARNED_REV_CALC_DATE_D TIMESTAMP(6) WITH TIME ZONE
GHOST_PROFILE_FLAG_V VARCHAR2(1 BYTE)
BOGOF_FLG_V VARCHAR2(1 BYTE)
MIGRATE_TIME_N NUMBER(15,0)
DMS_SEEN_FLG_V VARCHAR2(1 BYTE)
GRACE_DAYS_N NUMBER(15,0)
DMS_VERIFIED_DATE_D TIMESTAMP(6) WITH TIME ZONE
MMS_DOC_RECIVED_FLAG_V VARCHAR2(1 BYTE)
MMS_DOC_VERIFIED_FLAG_V VARCHAR2(1 BYTE)
MMS_DOC_VERIFIED_DATE_D TIMESTAMP(6) WITH TIME ZONE
GHOST_PROFILE_TYPE_V VARCHAR2(1 BYTE)
FIRST_CALL_V VARCHAR2(2 BYTE)
MMS_DOC_RECEIVED_DATE_D TIMESTAMP(6) WITH TIME ZONE
DEALER_ID_CODE_V VARCHAR2(20 BYTE)
DATE_OF_BIRTH_D TIMESTAMP(6) WITH TIME ZONE
SUBSCRIPTION_FEE_N NUMBER(10,0)
DEGREE_V VARCHAR2(10 BYTE)
HANDSET_SUBSIDY_FLAG_V VARCHAR2(1 BYTE)
HANDSET_CONTRACT_FLAG_V VARCHAR2(1 BYTE)
HANDSET_SECURITY_FLAG_V VARCHAR2(1 BYTE)
CPD_FLAG_V VARCHAR2(1 BYTE)
CONTRACT_DOC_RECE_DATE_D TIMESTAMP(6) WITH TIME ZONE
SECURITY_DOC_RECE_DATE_D TIMESTAMP(6) WITH TIME ZONE
CPD_DOC_RECE_DATE_D TIMESTAMP(6) WITH TIME ZONE
POAD_DOC_FLAG_V VARCHAR2(1 BYTE)
POAD_DOC_RECEIVED_DATE_D TIMESTAMP(6) WITH TIME ZONE
SIM_CHANGE_FLAG_N NUMBER
LBS_DOC_RECEIVED_FLAG_V VARCHAR2(1 BYTE)
FATHER_NAME_V VARCHAR2(120 BYTE)
CHURN_CATEGORY_V VARCHAR2(1 BYTE)
GEN_TYPE_V VARCHAR2(6 BYTE)
ADDITIONAL_IMSI_NUM_N NUMBER(15,0)
ADDITIONAL_SIM_FLAG_V VARCHAR2(1 BYTE)
ADDITIONAL_SIM_NUM_V VARCHAR2(20 BYTE)
ALLOW_MARKETING_CALLS_V VARCHAR2(1 BYTE)
BC_TARIFF_CHANGE_TYPE_V VARCHAR2(1 BYTE)
BILL_CYCL_CODE_N NUMBER(9,0)
BIRTH_DATE_D TIMESTAMP(6) WITH TIME ZONE
BUNDLE_FLAG_V VARCHAR2(1 BYTE)
BUNDLE_SERIAL_NUMBER_V VARCHAR2(15 BYTE)
CALL_FWD_BUSY_V VARCHAR2(16 BYTE)
CALL_FWD_IMMD_V VARCHAR2(16 BYTE)
CALL_FWD_NOREPLY_V VARCHAR2(16 BYTE)
COMMITMENT_AMOUNT_N NUMBER(14,0)
CONTACT_NUMBER1_V VARCHAR2(20 BYTE)
CONTACT_NUMBER2_V VARCHAR2(20 BYTE)
DATA_SPEED_N NUMBER(4,0)
DOC_RECVD_BY_N NUMBER(6,0)
DOC_RECVD_ON_D TIMESTAMP(6) WITH TIME ZONE
DUAL_IMSI_NUM_N NUMBER(15,0)
EPBAX_SERV_FLAG_V VARCHAR2(1 BYTE)
HANDSET_TYPE_V VARCHAR2(1 BYTE)
HYBRID_SERVICE_STATUS_V VARCHAR2(1 BYTE)
IMEI_NUMBER_V VARCHAR2(20 BYTE)
IP_ADDRESS_V VARCHAR2(15 BYTE)
LANGUAGE_CODE_V VARCHAR2(10 BYTE)
LAST_NAME_V VARCHAR2(210 BYTE)
LAST_POSTED_DATE_D TIMESTAMP(6) WITH TIME ZONE
LAST_STATE_CHNG_DATE_D TIMESTAMP(6) WITH TIME ZONE
LAST_STATE_CHNG_DONE_BY_N NUMBER(10,0)
LAST_STATE_CHNG_MODE_V VARCHAR2(1 BYTE)
MODEL_CODE_V VARCHAR2(10 BYTE)
NOTIFICATION_LANG_CODE_V VARCHAR2(10 BYTE)
PID_NUMBER_V VARCHAR2(16 BYTE)
POSTED_DATE_D TIMESTAMP(6) WITH TIME ZONE
POSTED_FLAG_N NUMBER(1,0)
PREFERRED_CURR_CODE_V VARCHAR2(5 BYTE)
PREF_DAY_CODE_N NUMBER(4,0)
PREF_DAY_DATE_V VARCHAR2(4 BYTE)
ROAM_IMSI_ACT_DT_D TIMESTAMP(6) WITH TIME ZONE
ROAM_IMSI_N NUMBER(15,0)
SALES_PERSON_CODE_V VARCHAR2(10 BYTE)
SDP_CODE_V VARCHAR2(12 BYTE)
SERV_ADDNL_FLD_1_D TIMESTAMP(6) WITH TIME ZONE
SERV_ADDNL_FLD_1_N NUMBER(14,0)
SERV_ADDNL_FLD_1_V VARCHAR2(50 BYTE)
SERV_ADDNL_FLD_2_D TIMESTAMP(6) WITH TIME ZONE
SERV_ADDNL_FLD_2_N NUMBER(14,0)
SERV_ADDNL_FLD_2_V VARCHAR2(50 BYTE)
SERV_ADDNL_FLD_3_D TIMESTAMP(6) WITH TIME ZONE
SERV_ADDNL_FLD_3_N NUMBER(14,0)
SERV_ADDNL_FLD_3_V VARCHAR2(50 BYTE)
SERV_ADDNL_FLD_4_N NUMBER(14,0)
SERV_ADDNL_FLD_4_V VARCHAR2(50 BYTE)
SERV_ADDNL_FLD_5_N NUMBER(14,0)
SERV_ADDNL_FLD_5_V VARCHAR2(50 BYTE)
SHORT_CODE_V VARCHAR2(16 BYTE)
SIM_ITEM_CODE_N NUMBER(10,0)
SUBSCRIBER_CLASS VARCHAR2(50 BYTE)
SUB_SERVICE_CODE_V VARCHAR2(10 BYTE)
TIME_ZONE_CODE_N NUMBER(4,0)
TWIN_SIM_LINKED_ACC_N NUMBER(10,0)
ACTIVATED_VIA_V VARCHAR2(1 BYTE)
BALANCE_AMOUNT_N NUMBER(14,0)
BLACKLISTED_DATE_D TIMESTAMP(6) WITH TIME ZONE
BLACKLISTED_FLG_V VARCHAR2(1 BYTE)
CR_CTRL_SCHDL_CODE_V VARCHAR2(6 BYTE)
FAX_SPEED_N NUMBER(4,0)
HYBRID_TYPE_V VARCHAR2(1 BYTE)
IN_LANGUAGE_CODE_N NUMBER(3,0)
SEVICE_IDENTIFIER_V VARCHAR2(3 BYTE)
DOC_FLAG_V VARCHAR2(1 BYTE)
DEFAULT_CR_CNTL_FLAG VARCHAR2(1 BYTE)
EMAIL_NOTIF_FLAG VARCHAR2(1 BYTE)
EMAIL_NOTIFICATION_ID VARCHAR2(300 BYTE)
SMS_NOTIF_FLAG VARCHAR2(1 BYTE)
SMS_NUMBER VARCHAR2(20 BYTE)
MELLI_NUM_N NUMBER(20,0)
STATUS_CHANGE_DATE_D TIMESTAMP(6) WITH TIME ZONE
CS_STATUS_V VARCHAR2(2 BYTE)
MIDDLE_NAME_V VARCHAR2(40 BYTE)
PAYMENT_AMOUNT_N NUMBER(16,2)
BC_COMMITMENT_POST_FLAG_V VARCHAR2(1 BYTE)
MTN_SUBSCRIBER_V VARCHAR2(1 BYTE)
BLACKBERRY_SERVICE_V VARCHAR2(1 BYTE)
HIGHEST_QUALIFICATION VARCHAR2(10 BYTE)
ECARE_V VARCHAR2(1 BYTE)
ACCOUNT_TYPE_V VARCHAR2(1 BYTE)
CHILDREN_FLAG_V VARCHAR2(5 BYTE)
ADDITIONAL_LINE#SITE_FLG_V VARCHAR2(1 BYTE)
ADDITIONAL_LINE#SITE_QTY_N NUMBER(4,0)
REG_FROM_V VARCHAR2(100 BYTE)
COW_HOLDER_FLAG_V VARCHAR2(1 BYTE)
REG_FORM_RECEIVED_FLAG_V VARCHAR2(1 BYTE)
REG_FORM_RECEIVED_DATE_D DATE

Target Kudu DDL:

create table `gsm_service_mast` (
ACCOUNT_LINK_CODE_N INT ,
ACCESS_PASSWORD_V STRING ,
ACCOUNT_CODE_N INT ,
ACCOUNT_MANAGER_N INT ,
ACCOUNT_TYPE_V STRING ,
ACTIVATED_BY_USER_CODE_N INT ,
ACTIVATED_VIA_V STRING ,
ACTIVATION_DATE_D TIMESTAMP ,
ADDITIONAL_IMSI_NUM_N INT ,
ADDITIONAL_LINE_SITE_FLG_V STRING ,
ADDITIONAL_LINE_SITE_QTY_N INT ,
ADDITIONAL_SIM_FLAG_V STRING ,
ADDITIONAL_SIM_NUM_V STRING ,
ADDRESS_RECIVED_FLAG_V STRING ,
AIRTM_RATE_START_DATE_D TIMESTAMP ,
ALLOW_MARKETING_CALLS_V STRING ,
AMPS_FLG_V STRING ,
BALANCE_AMOUNT_N INT ,
BAR_ON_THRESHOLD_FLG_V STRING ,
BC_COMMITMENT_POST_FLAG_V STRING ,
BC_TARIFF_CHANGE_TYPE_V STRING ,
BILL_CYCL_CODE_N INT ,
BIRTH_DATE_D TIMESTAMP ,
BLACKBERRY_SERVICE_V STRING ,
BLACKLISTED_DATE_D TIMESTAMP ,
BLACKLISTED_FLG_V STRING ,
BOGOF_FLG_V STRING ,
BUNDLE_FLAG_V STRING ,
BUNDLE_SERIAL_NUMBER_V STRING ,
BUSINESS_INDIVIDUAL_V STRING ,
CALL_FWD_BUSY_V STRING ,
CALL_FWD_IMMD_V STRING ,
CALL_FWD_NOREPLY_V STRING ,
CEL_ID_END_DATE_D TIMESTAMP ,
CEL_ID_START_DATE_D TIMESTAMP ,
CEL_ID_ZONE_CODE_V STRING ,
CHILDREN_FLAG_V STRING ,
CHRG_EXPTN_PH_FLG_V STRING ,
CHURN_CATEGORY_V STRING ,
COMMITMENT_AMOUNT_N INT ,
COMPANY_CONTACT_NUM_V STRING ,
COMPANY_NAME_V STRING ,
COMPANY_REGISTRATION_NO_V STRING ,
CONTACT_HOME_NUM_V STRING ,
CONTACT_MOBL_NUM_V STRING ,
CONTACT_NUMBER1_V STRING ,
CONTACT_NUMBER2_V STRING ,
CONTACT_OFFICE_NUM_V STRING ,
CONTRACT_DOC_RECE_DATE_D TIMESTAMP ,
CONTRACT_END_D TIMESTAMP ,
CONTRACT_START_D TIMESTAMP ,
CONTRACT_TYPE_V STRING ,
COW_HOLDER_FLAG_V STRING ,
CPD_DOC_RECE_DATE_D TIMESTAMP ,
CPD_FLAG_V STRING ,
CR_CTRL_SCHDL_CODE_V STRING ,
CS_STATUS_V STRING ,
CUG_GRP_CODE_V STRING ,
DATA_SPEED_N INT ,
DATE_OF_BIRTH_D TIMESTAMP ,
DEALER_CODE_V STRING ,
DEALER_ID_CODE_V STRING ,
DEFAULT_CR_CNTL_FLAG STRING ,
DEGREE_V STRING ,
DMS_RECIVED_DATE_D TIMESTAMP ,
DMS_RECIVED_FLAG_V STRING ,
DMS_SEEN_FLG_V STRING ,
DMS_VERIFIED_DATE_D TIMESTAMP ,
DMS_VERIFIED_FLAG_V STRING ,
DOC_FLAG_V STRING ,
DOC_RECVD_BY_N INT ,
DOC_RECVD_ON_D TIMESTAMP ,
DUAL_IMSI_NUM_N INT ,
ECARE_V STRING ,
EMAIL_ID_V STRING ,
EMAIL_NOTIFICATION_ID STRING ,
EMAIL_NOTIF_FLAG STRING ,
EMPLOYED_FROM_DATE_D TIMESTAMP ,
EPBAX_SERV_FLAG_V STRING ,
ERASED_DATE_D TIMESTAMP ,
EXEC_MEDI_FLG_V STRING ,
FAMILY_NAME_V STRING ,
FATHER_NAME_V STRING ,
FAX_NUM_V STRING ,
FAX_SPEED_N INT ,
FIRST_CALL_V STRING ,
FRNDS_END_DATE_D TIMESTAMP ,
FRNDS_START_DATE_D TIMESTAMP ,
GENDER_V STRING ,
GEN_TYPE_V STRING ,
GHOST_PROFILE_FLAG_V STRING ,
GHOST_PROFILE_TYPE_V STRING ,
GRACE_DAYS_N INT ,
GRP_PHONE_END_DATE_D TIMESTAMP ,
GRP_PHONE_START_DATE_D TIMESTAMP ,
HANDSET_CONTRACT_FLAG_V STRING ,
HANDSET_SECURITY_FLAG_V STRING ,
HANDSET_SUBSIDY_FLAG_V STRING ,
HANDSET_TYPE_V STRING ,
HIGHEST_QUALIFICATION STRING ,
HOME_FAX_NUM_V STRING ,
HYBRID_SERVICE_STATUS_V STRING ,
HYBRID_TYPE_V STRING ,
IC_NUMBER_V STRING ,
ID_EXPIRY_DATE_D TIMESTAMP ,
ID_TYPE_V STRING ,
IMEI_NUMBER_V STRING ,
IMSI_ACTIVE_DATE_D TIMESTAMP ,
IMSI_NUM_N INT ,
INTERIM_STATUS_CODE_V STRING ,
IN_LANGUAGE_CODE_N INT ,
IP_ADDRESS_V STRING ,
LANGUAGE_CODE_V STRING ,
LAST_EARNED_REV_CALC_DATE_D TIMESTAMP ,
LAST_NAME_V STRING ,
LAST_POSTED_DATE_D TIMESTAMP ,
LAST_STATE_CHNG_DATE_D TIMESTAMP ,
LAST_STATE_CHNG_DONE_BY_N INT ,
LAST_STATE_CHNG_MODE_V STRING ,
LBS_DOC_RECEIVED_FLAG_V STRING ,
MELLI_NUM_N INT ,
MIDDLE_NAME_V STRING ,
MID_CYCL_DISC_DATE_D TIMESTAMP ,
MIGRATE_TIME_N INT ,
MMS_DOC_RECEIVED_DATE_D TIMESTAMP ,
MMS_DOC_RECIVED_FLAG_V STRING ,
MMS_DOC_VERIFIED_DATE_D TIMESTAMP ,
MMS_DOC_VERIFIED_FLAG_V STRING ,
MOBILE_ACTIVATED_DATE_DT TIMESTAMP ,
MOBL_NUM_DATA_V STRING ,
MOBL_NUM_FAX_V STRING ,
MOBL_NUM_VOICE_V STRING ,
MODEL_CODE_V STRING ,
MODIFIED_DATE_D TIMESTAMP ,
MTN_SUBSCRIBER_V STRING ,
NOTIFICATION_LANG_CODE_V STRING ,
OCCUPATION_CODE_V STRING ,
ONLINE_BATCH_RATE_OPTN_V STRING ,
OUTGOING_BARRD_DATE_D TIMESTAMP ,
PACKAGE_CODE_V STRING ,
PACKAGE_START_DATE_D TIMESTAMP ,
PAYMENT_AMOUNT_N INT ,
PID_NUMBER_V STRING ,
POAD_DOC_FLAG_V STRING ,
POAD_DOC_RECEIVED_DATE_D TIMESTAMP ,
POSTED_DATE_D TIMESTAMP ,
POSTED_FLAG_N INT ,
PREFERRED_CURR_CODE_V STRING ,
PREFERRED_LANGUAGE_V STRING ,
PREF_DAY_CODE_N INT ,
PREF_DAY_DATE_V STRING ,
PRE_TERMINATE_DATE_D TIMESTAMP ,
PROFILE_CODE_V STRING ,
PROFILE_TYPE_V STRING ,
PROV_PRIORITY_N INT ,
REACTIVATION_DATE_D TIMESTAMP ,
READY_TO_GO_DATE_D TIMESTAMP ,
REGISTERED_LOCATION_V STRING ,
REGISTRATION_DATE_D TIMESTAMP ,
REG_FORM_RECEIVED_DATE_D TIMESTAMP ,
REG_FORM_RECEIVED_FLAG_V STRING ,
REG_FROM_V STRING ,
RESTRICT_SMS_FLAG_V STRING ,
ROAMING_TYPE_N INT ,
ROAM_IMSI_ACT_DT_D TIMESTAMP ,
ROAM_IMSI_N INT ,
SALES_PERSON_CODE_V STRING ,
SALES_REP_V STRING ,
SCHEDUL_SERVICE_EXEC_DATE_D TIMESTAMP ,
SDP_CODE_V STRING ,
SECURITY_DOC_RECE_DATE_D TIMESTAMP ,
SERVICE_INDICATOR_V STRING ,
SERV_ADDNL_FLD_1_D TIMESTAMP ,
SERV_ADDNL_FLD_1_N INT ,
SERV_ADDNL_FLD_1_V STRING ,
SERV_ADDNL_FLD_2_D TIMESTAMP ,
SERV_ADDNL_FLD_2_N INT ,
SERV_ADDNL_FLD_2_V STRING ,
SERV_ADDNL_FLD_3_D TIMESTAMP ,
SERV_ADDNL_FLD_3_N INT ,
SERV_ADDNL_FLD_3_V STRING ,
SERV_ADDNL_FLD_4_N INT ,
SERV_ADDNL_FLD_4_V STRING ,
SERV_ADDNL_FLD_5_N INT ,
SERV_ADDNL_FLD_5_V STRING ,
SEVICE_IDENTIFIER_V STRING ,
SHORT_CODE_V STRING ,
SIM_CHANGE_FLAG_N INT ,
SIM_ITEM_CODE_N INT ,
SIM_NUM_V STRING ,
SMS_NOTIF_FLAG STRING ,
SMS_NUMBER STRING ,
SPECIAL_CATEGORY_CHANGE_DATE_D TIMESTAMP ,
SPECIAL_CATEGORY_INDICATORS_V STRING ,
SPECIAL_TARF_CODE_V STRING ,
SPECIAL_TARF_DATE_D TIMESTAMP ,
STATUS_CHANGE_DATE_D TIMESTAMP ,
STATUS_CODE_V STRING ,
STATUS_REASON_CODE_N STRING ,
SUBSCRIBER_CATEGORY_V STRING ,
SUBSCRIBER_CLASS STRING ,
SUBSCRIBER_SEGMENT_V STRING ,
SUBSCRIBER_SUB_CATEGORY_V STRING ,
SUBSCRIPTION_FEE_N INT ,
SUBS_CUG_END_DATE_D TIMESTAMP ,
SUBS_CUG_START_DATE_D TIMESTAMP ,
SUBS_NAME_V STRING ,
SUBS_TITLE_V STRING ,
SUB_PACKAGE_CODE_V STRING ,
SUB_SERVICE_CODE_V STRING ,
SUSPENDED_DATE_D TIMESTAMP ,
TARIFF_CODE_V STRING ,
TARIFF_START_DATE_D TIMESTAMP ,
TIME_ZONE_CODE_N INT ,
TRANSFER_FROM_ACC_LINK_CODE_N INT ,
TRANSFER_IN_SERVICE_TYPES_N INT ,
TWIN_SIM_LINKED_ACC_N INT ,
VALIDITY_DATE_D TIMESTAMP ,
VALIDITY_GRACE_DAYS_N INT ,
VIP_FLAG_V STRING ,
X_DIRECTORY_LEVEL_N INT ,
PRIMARY KEY (ACCOUNT_LINK_CODE_N)
) PARTITION BY HASH(ACCOUNT_LINK_CODE_N) PARTITIONS 16 STORED AS KUDU;

Kindly advise.

Thanks,

Roshan