businessdoc Normal / ID_BATCH Y ID_BATCH CHANNEL_ID Y CHANNEL_ID TRANSNAME Y TRANSNAME STATUS Y STATUS LINES_READ Y LINES_READ LINES_WRITTEN Y LINES_WRITTEN LINES_UPDATED Y LINES_UPDATED LINES_INPUT Y LINES_INPUT LINES_OUTPUT Y LINES_OUTPUT LINES_REJECTED Y LINES_REJECTED ERRORS Y ERRORS STARTDATE Y STARTDATE ENDDATE Y ENDDATE LOGDATE Y LOGDATE DEPDATE Y DEPDATE REPLAYDATE Y REPLAYDATE LOG_FIELD Y LOG_FIELD EXECUTING_SERVER N EXECUTING_SERVER EXECUTING_USER N EXECUTING_USER CLIENT N CLIENT ID_BATCH Y ID_BATCH SEQ_NR Y SEQ_NR LOGDATE Y LOGDATE TRANSNAME Y TRANSNAME STEPNAME Y STEPNAME STEP_COPY Y STEP_COPY LINES_READ Y LINES_READ LINES_WRITTEN Y LINES_WRITTEN LINES_UPDATED Y LINES_UPDATED LINES_INPUT Y LINES_INPUT LINES_OUTPUT Y LINES_OUTPUT LINES_REJECTED Y LINES_REJECTED ERRORS Y ERRORS INPUT_BUFFER_ROWS Y INPUT_BUFFER_ROWS OUTPUT_BUFFER_ROWS Y OUTPUT_BUFFER_ROWS ID_BATCH Y ID_BATCH CHANNEL_ID Y CHANNEL_ID LOG_DATE Y LOG_DATE LOGGING_OBJECT_TYPE Y LOGGING_OBJECT_TYPE OBJECT_NAME Y OBJECT_NAME OBJECT_COPY Y OBJECT_COPY REPOSITORY_DIRECTORY Y REPOSITORY_DIRECTORY FILENAME Y FILENAME OBJECT_ID Y OBJECT_ID OBJECT_REVISION Y OBJECT_REVISION PARENT_CHANNEL_ID Y PARENT_CHANNEL_ID ROOT_CHANNEL_ID Y ROOT_CHANNEL_ID ID_BATCH Y ID_BATCH CHANNEL_ID Y CHANNEL_ID LOG_DATE Y LOG_DATE TRANSNAME Y TRANSNAME STEPNAME Y STEPNAME STEP_COPY Y STEP_COPY LINES_READ Y LINES_READ LINES_WRITTEN Y LINES_WRITTEN LINES_UPDATED Y LINES_UPDATED LINES_INPUT Y LINES_INPUT LINES_OUTPUT Y LINES_OUTPUT LINES_REJECTED Y LINES_REJECTED ERRORS Y ERRORS LOG_FIELD N LOG_FIELD ID_BATCH Y ID_BATCH CHANNEL_ID Y CHANNEL_ID LOG_DATE Y LOG_DATE METRICS_DATE Y METRICS_DATE METRICS_CODE Y METRICS_CODE METRICS_DESCRIPTION Y METRICS_DESCRIPTION METRICS_SUBJECT Y METRICS_SUBJECT METRICS_TYPE Y METRICS_TYPE METRICS_VALUE Y METRICS_VALUE 0.0 0.0 10000 50 50 N Y 50000 Y N 1000 100 - 2019/05/13 20:10:40.442 - 2019/05/13 20:10:40.442 H4sIAAAAAAAAAAMAAAAAAAAAAAA= N esSqlserver 192.168.50.30 MSSQLNATIVE Native LJHYBZK 1433 es Encrypted 2be98afc86ac281d5f94afa2588d38f99 FORCE_IDENTIFIERS_TO_LOWERCASE N FORCE_IDENTIFIERS_TO_UPPERCASE N IS_CLUSTERED N MSSQLUseIntegratedSecurity false MSSQL_DOUBLE_DECIMAL_SEPARATOR N PORT_NUMBER 1433 PRESERVE_RESERVED_WORD_CASE Y QUOTE_ALL_FIELDS N SUPPORTS_BOOLEAN_DATA_TYPE Y SUPPORTS_TIMESTAMP_DATA_TYPE Y USE_POOLING N 表输入 Elasticsearch bulk insert Y Elasticsearch bulk insert ElasticSearchBulk Y 1 none businessdoc _doc 500 100 SECONDS N BusinessId N N Y AcctName AcctName ActBalance ActBalance Address Address BankAccount BankAccount Beactive Beactive BillCode BillCode BillNo BillNo BusinessCode BusinessCode BusinessCont BusinessCont BusinessId BusinessId BusinessName BusinessName CEntId CEntId CZoneId CZoneId Capacity Capacity ChanceId ChanceId Contact Contact Content Content CreateDate CreateDate CreateTime CreateTime CreaterId CreaterId CreaterInfo CreaterInfo CusNatId CusNatId CusSubId CusSubId DelTime DelTime DelUserID DelUserID DeptId DeptId DirectorId DirectorId DocLevId DocLevId Email Email EntId EntId ExpAutOrg ExpAutOrg Fax Fax GPSAdd GPSAdd GroupId GroupId IdCard IdCard InfoState InfoState IsAbandon IsAbandon IsBusiness IsBusiness IsClients IsClients IsFreeze IsFreeze IsLogistics IsLogistics IsMfc IsMfc IsPartner IsPartner IsPass IsPass Is_Supp Is_Supp K_yfzffs K_yfzffs LastCareTime LastCareTime LastDate LastDate LastModifyTime LastModifyTime LastRtnTime LastRtnTime LastServTime LastServTime LastStfId LastStfId LastVisitTime LastVisitTime LegalRep LegalRep LevelId LevelId Logogram Logogram OldCode OldCode OperMode OperMode OrgCert OrgCert OrgCertDate OrgCertDate OrgCertVal OrgCertVal OrgId OrgId PBusinessId PBusinessId PostCode PostCode PowerBalance PowerBalance QADirName QADirName Reason Reason RegAuthority RegAuthority RegCapital RegCapital RegDates RegDates RegNo RegNo RegValDate RegValDate RegYearDate RegYearDate ResAutOrg ResAutOrg RfEntId RfEntId RouteId RouteId RouteOrder RouteOrder RptYear RptYear SelAttachId SelAttachId ShortName ShortName Subbranch Subbranch SyncId SyncId TaxNo TaxNo Telephone Telephone Url Url ZoneId ZoneId businessKey businessKey ing ing jkfsid jkfsid k_b2bAccountName k_b2bAccountName k_b2bIDCard k_b2bIDCard k_b2bNickName k_b2bNickName k_b2bUserName k_b2bUserName k_deliverid k_deliverid k_ismr k_ismr k_kdlx k_kdlx k_qu k_qu k_sheng k_sheng k_shi k_shi k_xiangxi k_xiangxi koul koul lat lat source source yingyzz yingyzz

192.168.50.32

9300 cluster.name es

560 368 Y 表输入 TableInput Y 1 none esSqlserver SELECT *,'erp' as source,ROW_NUMBER() OVER (ORDER BY businessId DESC) as businessKey FROM businessdoc 0 N N Y

496 192 Y N