On Fri, May 10, 2013 at 04:46:46PM +0800, liyuesen 00108910 wrote:

By the way, I am using the newest Monetdb source package,version 11.5.3. And the platfrom is Redhat linux on intel CPU.

The error message: mal>function test(i:int):str; mal>io.print(i); mal>i:= i*2; mal> b:= bat.new(:int,:int); mal>bat.insert(b,1,i); mal>io.print(b); mal>return test:= "ok"; mal>end test; MAPI = (monetdb) /tmp/.s.monetdb.50000 QUERY = end test; ERROR = !TypeException:BAT.test[3]:'bat.new' undefined in: b:any := bat.new(_5:int, _6:int) !TypeException:BAT.test[4]:'bat.insert' undefined in: _7:any := bat.insert(b:any, _8:int, i:int)

Can you help me to fix the error and give me some advice about how to create a MAL function.

As the error message says, there is no function bat.new() that takes two integers as argument; as of Feb2013, BATs must have a dense OID head; see also $ mclient -lmal Welcome to mclient, the MonetDB interactive terminal (Feb2013-SP2) Type \q to quit, \? for a list of available commands mal>?bat.new() command bat.new(nme:str):bat[:oid,:any_1] address CMDBATderivedByName; comment Localize a bat by name and produce a clone. pattern bat.new(b:bat[:oid,:any_1],size:lng):bat[:oid,:any_1] address CMDBATnewDerived; pattern bat.new(b:bat[:oid,:any_1]):bat[:oid,:any_1] address CMDBATnewDerived; pattern bat.new(ht:oid,tt:any_1,size:lng):bat[:oid,:any_1] address CMDBATnew; comment Creates a new BAT and allocate space. pattern bat.new(ht:oid,tt:any_1,size:int):bat[:oid,:any_1] address CMDBATnewint; comment Creates a new BAT with sufficient space. pattern bat.new(ht:oid,tt:any_1):bat[:oid,:any_1] address CMDBATnew; comment Creates a new empty transient BAT, with head- and tail-types as indicated. mal>

The other issue, about the binary copy command. Use explain we can get a MAL function like this. Can the append operations be executed parallel by using language.dataflow().

No. Appends (to one BAT) cannot be executed in parallel. Best, Stefan

If that is the case, can you show me how to do this?

explain copy binary into sys.DETAIL_UFDR_OTHER from ('/srv/monetdb/o/SID.dat','/srv/monetdb/o/PROBEID.dat','/srv/monetdb/o/GROUPID.dat','/srv/monetdb/o/GGSN_ID.dat','/srv/monetdb/o/SGSN_ID.dat','/srv/monetdb/o/SESSION_INDICATOR.dat','/srv/monetdb/o/BEGIN_TIME.dat','/srv/monetdb/o/BEGIN_TIME_MSEL.dat','/srv/monetdb/o/END_TIME.dat','/srv/monetdb/o/END_TIME_MSEL.dat','/srv/monetdb/o/PROT_CATEGORY.dat','/srv/monetdb/o/PROT_TYPE.dat','/srv/mone tdb/o/L7_CARRIER_PROT.dat','/srv/monetdb/o/MSISDN.dat','/srv/monetdb/o/IMSI.dat','/srv/monetdb/o/IMEI.dat','/srv/monetdb/o/ENCRYPT_VERSION.dat','/srv/monetdb/o/ROAMING_TYPE.dat','/srv/monetdb/o/ROAM_DIRECTION.dat','/srv/monetdb/o/MS_IP.dat','/srv/monetdb/o/SERVER_IP.dat','/srv/monetdb/o/MS_PORT.dat','/srv/monetdb/o/SERVER_PORT.dat','/srv/monetdb/o/APN.dat','/srv/monetdb/o/SGSN_SIG_IP.dat','/srv/monetdb/o/GGSN_SIG_IP.dat','/srv/monetdb/o/SGSN _USER_IP.dat','/srv/monetdb/o/GGSN_USER_IP.dat','/srv/monetdb/o/MCC.dat','/srv/monetdb/o/MNC.dat','/srv/monetdb/o/RAT.dat','/srv/monetdb/o/LAC.dat','/srv/monetdb/o/RAC.dat','/srv/monetdb/o/SAC.dat','/srv/monetdb/o/CI.dat','/srv/monetdb/o/L4_TYPE.dat','/srv/monetdb/o/L4_UL_THROUGHPUT.dat','/srv/monetdb/o/L4_DW_THROUGHPUT.dat','/srv/monetdb/o/L4_UL_GOODPUT.dat','/srv/monetdb/o/L4_DW_GOODPUT.dat','/srv/monetdb/o/NETWORK_UL_TRAFFIC.dat','/srv/mo netdb/o/NETWORK_DL_TRAFFIC.dat','/srv/monetdb/o/L4_UL_PACKETS.dat','/srv/monetdb/o/L4_DW_PACKETS.dat','/srv/monetdb/o/TCP_CONN_STATES.dat','/srv/monetdb/o/TCP_CONN_TIMES.dat','/srv/monetdb/o/TCP_CONN_2_FAILED_TIMES.dat','/srv/monetdb/o/TCP_CONN_3_FAILED_TIMES.dat','/srv/monetdb/o/FLAG.dat','/srv/monetdb/o/FLOW_SAMPLE_RATIO.dat','/srv/monetdb/o/TAC.dat','/srv/monetdb/o/ECI.dat','/srv/monetdb/o/TCP_SYN_TIME.dat','/srv/monetdb/o/TCP_SYN_TIME_MS EL.dat','/srv/monetdb/o/TCP_RTT_STEP1.dat','/srv/monetdb/o/TCP_UL_RETRANS_WITHPL.dat','/srv/monetdb/o/TCP_DW_RETRANS_WITHPL.dat','/srv/monetdb/o/TCP_UL_RETRANS_WITHOUTPL.dat','/srv/monetdb/o/TCP_DW_RETRANS_WITHOUTPL.dat','/srv/monetdb/o/TCP_UL_PACKAGES_WITHPL.dat','/srv/monetdb/o/TCP_DW_PACKAGES_WITHPL.dat','/srv/monetdb/o/TCP_UL_PACKAGES_WITHOUTPL.dat','/srv/monetdb/o/TCP_DW_PACKAGES_WITHOUTPL.dat','/srv/monetdb/o/UPPERLAYER_IP_UL_PACKETS.d at','/srv/monetdb/o/UPPERLAYER_IP_DL_PACKETS.dat','/srv/monetdb/o/DOWNLAYER_IP_UL_PACKETS.dat','/srv/monetdb/o/DOWNLAYER_IP_DL_PACKETS.dat','/srv/monetdb/o/UPPERLAYER_IP_UL_FRAGMENTS.dat','/srv/monetdb/o/UPPERLAYER_IP_DL_FRAGMENTS.dat','/srv/monetdb/o/DOWNLAYER_IP_UL_FRAGMENTS.dat','/srv/monetdb/o/DOWNLAYER_IP_DL_FRAGMENTS.dat','/srv/monetdb/o/SERVICE_DALAY_MSEC.dat','/srv/monetdb/o/VALID_TRANS_DURATION.dat','/srv/monetdb/o/AIR_PORT_DURATION .dat','/srv/monetdb/o/RADIO_CONN_TIMES.dat','/srv/monetdb/o/TCP_FST_SYN_DIRECTION.dat','/srv/monetdb/o/RAN_NE_ID.dat','/srv/monetdb/o/RAN_NE_USER_IP.dat','/srv/monetdb/o/TCP_STATES.dat','/srv/monetdb/o/TCP_RTT.dat','/srv/monetdb/o/TCP_UL_OUTOFSEQU.dat','/srv/monetdb/o/TCP_DW_OUTOFSEQU.dat','/srv/monetdb/o/TCP_WIN_SIZE.dat','/srv/monetdb/o/TCP_MSS.dat','/srv/monetdb/o/TRANS_TYPE.dat','/srv/monetdb/o/GET_NUM.dat','/srv/monetdb/o/GET_SUCCEED_NU M.dat','/srv/monetdb/o/GET_RETRANS_NUM.dat','/srv/monetdb/o/GET_TIMEOUT_NUM.dat','/srv/monetdb/o/POST_NUM.dat','/srv/monetdb/o/POST_SUCCEED_NUM.dat','/srv/monetdb/o/POST_RETRANS_NUM.dat','/srv/monetdb/o/POST_TO_NUM.dat','/srv/monetdb/o/SERVICE_SUCCEED_FLAG.dat','/srv/monetdb/o/INTERFACEID.dat','/srv/monetdb/o/HOMEMCC.dat','/srv/monetdb/o/HOMEMNC.dat','/srv/monetdb/o/HOMEPROVINCE.dat','/srv/monetdb/o/HOMECITY.dat','/srv/monetdb/o/HOST.dat','/ srv/monetdb/o/SERVICE_ID.dat','/srv/monetdb/o/CHARGING_CLASS.dat','/srv/monetdb/o/CHARGE_FLAG.dat','/srv/monetdb/o/Prepaid_Flag.dat'); +-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+ | mal | +=============================================================================================================================================================================================================+ | function user.s1_1{autoCommit=true}():void; | | X_2 := sql.mvc(); | | (X_3:bat[:oid,:lng] ,X_4:bat[:oid,:lng] ,X_5:bat[:oid,:int] ,X_6:bat[:oid,:lng] ,X_7:bat[:oid,:lng] ,X_8:bat[:oid,:bte] ,X_9:bat[:oid,:lng] ,X_10:bat[:oid,:sht] ,X_11:bat[:oid,:lng] ,X_12:bat[:oid,:s | : ht] ,X_13:bat[:oid,:int] ,X_14:bat[:oid,:int] ,X_15:bat[:oid,:sht] ,X_16:bat[:oid,:str] ,X_17:bat[:oid,:str] ,X_18:bat[:oid,:str] ,X_19:bat[:oid,:int] ,X_20:bat[:oid,:bte] ,X_21:bat[:oid,:bte] ,X_22:bat[ : : :oid,:str] ,X_23:bat[:oid,:str] ,X_24:bat[:oid,:int] ,X_25:bat[:oid,:int] ,X_26:bat[:oid,:str] ,X_27:bat[:oid,:str] ,X_28:bat[:oid,:str] ,X_29:bat[:oid,:str] ,X_30:bat[:oid,:str] ,X_31:bat[:oid,:str] ,X_ : : 32:bat[:oid,:str] ,X_33:bat[:oid,:bte] ,X_34:bat[:oid,:str] ,X_35:bat[:oid,:str] ,X_36:bat[:oid,:str] ,X_37:bat[:oid,:str] ,X_38:bat[:oid,:bte] ,X_39:bat[:oid,:lng] ,X_40:bat[:oid,:lng] ,X_41:bat[:oid,:l : : ng] ,X_42:bat[:oid,:lng] ,X_43:bat[:oid,:lng] ,X_44:bat[:oid,:lng] ,X_45:bat[:oid,:lng] ,X_46:bat[:oid,:lng] ,X_47:bat[:oid,:bte] ,X_48:bat[:oid,:int] ,X_49:bat[:oid,:int] ,X_50:bat[:oid,:int] ,X_51:bat[ : : :oid,:sht] ,X_52:bat[:oid,:int] ,X_53:bat[:oid,:str] ,X_54:bat[:oid,:str] ,X_55:bat[:oid,:int] ,X_56:bat[:oid,:sht] ,X_57:bat[:oid,:lng] ,X_58:bat[:oid,:lng] ,X_59:bat[:oid,:lng] ,X_60:bat[:oid,:lng] ,X_ : : 61:bat[:oid,:lng] ,X_62:bat[:oid,:lng] ,X_63:bat[:oid,:lng] ,X_64:bat[:oid,:lng] ,X_65:bat[:oid,:lng] ,X_66:bat[:oid,:lng] ,X_67:bat[:oid,:lng] ,X_68:bat[:oid,:lng] ,X_69:bat[:oid,:lng] ,X_70:bat[:oid,:l : : ng] ,X_71:bat[:oid,:lng] ,X_72:bat[:oid,:lng] ,X_73:bat[:oid,:lng] ,X_74:bat[:oid,:lng] ,X_75:bat[:oid,:lng] ,X_76:bat[:oid,:lng] ,X_77:bat[:oid,:lng] ,X_78:bat[:oid,:bte] ,X_79:bat[:oid,:lng] ,X_80:bat[ : : :oid,:str] ,X_81:bat[:oid,:bte] ,X_82:bat[:oid,:lng] ,X_83:bat[:oid,:lng] ,X_84:bat[:oid,:lng] ,X_85:bat[:oid,:int] ,X_86:bat[:oid,:int] ,X_87:bat[:oid,:int] ,X_88:bat[:oid,:int] ,X_89:bat[:oid,:int] ,X_ : : 90:bat[:oid,:int] ,X_91:bat[:oid,:int] ,X_92:bat[:oid,:int] ,X_93:bat[:oid,:int] ,X_94:bat[:oid,:int] ,X_95:bat[:oid,:int] ,X_96:bat[:oid,:bte] ,X_97:bat[:oid,:bte] ,X_98:bat[:oid,:str] ,X_99:bat[:oid,:s : : tr] ,X_100:bat[:oid,:lng] ,X_101:bat[:oid,:lng] ,X_102:bat[:oid,:str] ,X_103:bat[:oid,:lng] ,X_104:bat[:oid,:lng] ,X_105:bat[:oid,:bte] ,X_106:bat[:oid,:bte] ) := sql.importTable("sys":str,"detail_ufdr_o : : ther":str,"/srv/monetdb/o/SID.dat":str,"/srv/monetdb/o/PROBEID.dat":str,"/srv/monetdb/o/GROUPID.dat":str,"/srv/monetdb/o/GGSN_ID.dat":str,"/srv/monetdb/o/SGSN_ID.dat":str,"/srv/monetdb/o/SESSION_INDICATO : : R.dat":str,"/srv/monetdb/o/BEGIN_TIME.dat":str,"/srv/monetdb/o/BEGIN_TIME_MSEL.dat":str,"/srv/monetdb/o/END_TIME.dat":str,"/srv/monetdb/o/END_TIME_MSEL.dat":str,"/srv/monetdb/o/PROT_CATEGORY.dat":str,"/s : : rv/monetdb/o/PROT_TYPE.dat":str,"/srv/monetdb/o/L7_CARRIER_PROT.dat":str,"/srv/monetdb/o/MSISDN.dat":str,"/srv/monetdb/o/IMSI.dat":str,"/srv/monetdb/o/IMEI.dat":str,"/srv/monetdb/o/ENCRYPT_VERSION.dat":s : : tr,"/srv/monetdb/o/ROAMING_TYPE.dat":str,"/srv/monetdb/o/ROAM_DIRECTION.dat":str,"/srv/monetdb/o/MS_IP.dat":str,"/srv/monetdb/o/SERVER_IP.dat":str,"/srv/monetdb/o/MS_PORT.dat":str,"/srv/monetdb/o/SERVER_ : : PORT.dat":str,"/srv/monetdb/o/APN.dat":str,"/srv/monetdb/o/SGSN_SIG_IP.dat":str,"/srv/monetdb/o/GGSN_SIG_IP.dat":str,"/srv/monetdb/o/SGSN_USER_IP.dat":str,"/srv/monetdb/o/GGSN_USER_IP.dat":str,"/srv/mone : : tdb/o/MCC.dat":str,"/srv/monetdb/o/MNC.dat":str,"/srv/monetdb/o/RAT.dat":str,"/srv/monetdb/o/LAC.dat":str,"/srv/monetdb/o/RAC.dat":str,"/srv/monetdb/o/SAC.dat":str,"/srv/monetdb/o/CI.dat":str,"/srv/monet : : db/o/L4_TYPE.dat":str,"/srv/monetdb/o/L4_UL_THROUGHPUT.dat":str,"/srv/monetdb/o/L4_DW_THROUGHPUT.dat":str,"/srv/monetdb/o/L4_UL_GOODPUT.dat":str,"/srv/monetdb/o/L4_DW_GOODPUT.dat":str,"/srv/monetdb/o/NET : : WORK_UL_TRAFFIC.dat":str,"/srv/monetdb/o/NETWORK_DL_TRAFFIC.dat":str,"/srv/monetdb/o/L4_UL_PACKETS.dat":str,"/srv/monetdb/o/L4_DW_PACKETS.dat":str,"/srv/monetdb/o/TCP_CONN_STATES.dat":str,"/srv/monetdb/o : : /TCP_CONN_TIMES.dat":str,"/srv/monetdb/o/TCP_CONN_2_FAILED_TIMES.dat":str,"/srv/monetdb/o/TCP_CONN_3_FAILED_TIMES.dat":str,"/srv/monetdb/o/FLAG.dat":str,"/srv/monetdb/o/FLOW_SAMPLE_RATIO.dat":str,"/srv/m : : onetdb/o/TAC.dat":str,"/srv/monetdb/o/ECI.dat":str,"/srv/monetdb/o/TCP_SYN_TIME.dat":str,"/srv/monetdb/o/TCP_SYN_TIME_MSEL.dat":str,"/srv/monetdb/o/TCP_RTT_STEP1.dat":str,"/srv/monetdb/o/TCP_UL_RETRANS_W : : ITHPL.dat":str,"/srv/monetdb/o/TCP_DW_RETRANS_WITHPL.dat":str,"/srv/monetdb/o/TCP_UL_RETRANS_WITHOUTPL.dat":str,"/srv/monetdb/o/TCP_DW_RETRANS_WITHOUTPL.dat":str,"/srv/monetdb/o/TCP_UL_PACKAGES_WITHPL.da : : t":str,"/srv/monetdb/o/TCP_DW_PACKAGES_WITHPL.dat":str,"/srv/monetdb/o/TCP_UL_PACKAGES_WITHOUTPL.dat":str,"/srv/monetdb/o/TCP_DW_PACKAGES_WITHOUTPL.dat":str,"/srv/monetdb/o/UPPERLAYER_IP_UL_PACKETS.dat": : : str,"/srv/monetdb/o/UPPERLAYER_IP_DL_PACKETS.dat":str,"/srv/monetdb/o/DOWNLAYER_IP_UL_PACKETS.dat":str,"/srv/monetdb/o/DOWNLAYER_IP_DL_PACKETS.dat":str,"/srv/monetdb/o/UPPERLAYER_IP_UL_FRAGMENTS.dat":str : : ,"/srv/monetdb/o/UPPERLAYER_IP_DL_FRAGMENTS.dat":str,"/srv/monetdb/o/DOWNLAYER_IP_UL_FRAGMENTS.dat":str,"/srv/monetdb/o/DOWNLAYER_IP_DL_FRAGMENTS.dat":str,"/srv/monetdb/o/SERVICE_DALAY_MSEC.dat":str,"/sr : : v/monetdb/o/VALID_TRANS_DURATION.dat":str,"/srv/monetdb/o/AIR_PORT_DURATION.dat":str,"/srv/monetdb/o/RADIO_CONN_TIMES.dat":str,"/srv/monetdb/o/TCP_FST_SYN_DIRECTION.dat":str,"/srv/monetdb/o/RAN_NE_ID.dat : : ":str,"/srv/monetdb/o/RAN_NE_USER_IP.dat":str,"/srv/monetdb/o/TCP_STATES.dat":str,"/srv/monetdb/o/TCP_RTT.dat":str,"/srv/monetdb/o/TCP_UL_OUTOFSEQU.dat":str,"/srv/monetdb/o/TCP_DW_OUTOFSEQU.dat":str,"/sr : : v/monetdb/o/TCP_WIN_SIZE.dat":str,"/srv/monetdb/o/TCP_MSS.dat":str,"/srv/monetdb/o/TRANS_TYPE.dat":str,"/srv/monetdb/o/GET_NUM.dat":str,"/srv/monetdb/o/GET_SUCCEED_NUM.dat":str,"/srv/monetdb/o/GET_RETRAN : : S_NUM.dat":str,"/srv/monetdb/o/GET_TIMEOUT_NUM.dat":str,"/srv/monetdb/o/POST_NUM.dat":str,"/srv/monetdb/o/POST_SUCCEED_NUM.dat":str,"/srv/monetdb/o/POST_RETRANS_NUM.dat":str,"/srv/monetdb/o/POST_TO_NUM.d : : at":str,"/srv/monetdb/o/SERVICE_SUCCEED_FLAG.dat":str,"/srv/monetdb/o/INTERFACEID.dat":str,"/srv/monetdb/o/HOMEMCC.dat":str,"/srv/monetdb/o/HOMEMNC.dat":str,"/srv/monetdb/o/HOMEPROVINCE.dat":str,"/srv/mo : : netdb/o/HOMECITY.dat":str,"/srv/monetdb/o/HOST.dat":str,"/srv/monetdb/o/SERVICE_ID.dat":str,"/srv/monetdb/o/CHARGING_CLASS.dat":str,"/srv/monetdb/o/CHARGE_FLAG.dat":str,"/srv/monetdb/o/Prepaid_Flag.dat": : : str); : | X_109 := sql.append(X_2,"sys","detail_ufdr_other","sid",X_3); | | X_112 := sql.append(X_109,"sys","detail_ufdr_other","probeid",X_4); | | X_114 := sql.append(X_112,"sys","detail_ufdr_other","groupid",X_5); | | X_116 := sql.append(X_114,"sys","detail_ufdr_other","ggsn_id",X_6); | | X_118 := sql.append(X_116,"sys","detail_ufdr_other","sgsn_id",X_7); | | X_120 := sql.append(X_118,"sys","detail_ufdr_other","session_indicator",X_8); | | X_123 := sql.append(X_120,"sys","detail_ufdr_other","begin_time",X_9); | | X_126 := sql.append(X_123,"sys","detail_ufdr_other","begin_time_msel",X_10); | | X_128 := sql.append(X_126,"sys","detail_ufdr_other","end_time",X_11); | | X_130 := sql.append(X_128,"sys","detail_ufdr_other","end_time_msel",X_12); | | X_132 := sql.append(X_130,"sys","detail_ufdr_other","prot_category",X_13); | | X_135 := sql.append(X_132,"sys","detail_ufdr_other","prot_type",X_14); | | X_137 := sql.append(X_135,"sys","detail_ufdr_other","l7_carrier_prot",X_15); | | X_140 := sql.append(X_137,"sys","detail_ufdr_other","msisdn",X_16); | | X_142 := sql.append(X_140,"sys","detail_ufdr_other","imsi",X_17); | | X_144 := sql.append(X_142,"sys","detail_ufdr_other","imei",X_18); | | X_146 := sql.append(X_144,"sys","detail_ufdr_other","encrypt_version",X_19); | | X_149 := sql.append(X_146,"sys","detail_ufdr_other","roaming_type",X_20); | | X_151 := sql.append(X_149,"sys","detail_ufdr_other","roam_direction",X_21); | | X_154 := sql.append(X_151,"sys","detail_ufdr_other","ms_ip",X_22); | | X_156 := sql.append(X_154,"sys","detail_ufdr_other","server_ip",X_23); | | X_158 := sql.append(X_156,"sys","detail_ufdr_other","ms_port",X_24); | | X_161 := sql.append(X_158,"sys","detail_ufdr_other","server_port",X_25); | | X_163 := sql.append(X_161,"sys","detail_ufdr_other","apn",X_26); | | X_165 := sql.append(X_163,"sys","detail_ufdr_other","sgsn_sig_ip",X_27); | | X_168 := sql.append(X_165,"sys","detail_ufdr_other","ggsn_sig_ip",X_28); | | X_170 := sql.append(X_168,"sys","detail_ufdr_other","sgsn_user_ip",X_29); | | X_172 := sql.append(X_170,"sys","detail_ufdr_other","ggsn_user_ip",X_30); | | X_175 := sql.append(X_172,"sys","detail_ufdr_other","mcc",X_31); | | X_177 := sql.append(X_175,"sys","detail_ufdr_other","mnc",X_32); | | X_179 := sql.append(X_177,"sys","detail_ufdr_other","rat",X_33); | | X_182 := sql.append(X_179,"sys","detail_ufdr_other","lac",X_34); | | X_184 := sql.append(X_182,"sys","detail_ufdr_other","rac",X_35); | | X_187 := sql.append(X_184,"sys","detail_ufdr_other","sac",X_36); | | X_189 := sql.append(X_187,"sys","detail_ufdr_other","ci",X_37); | | X_191 := sql.append(X_189,"sys","detail_ufdr_other","l4_type",X_38); | | X_193 := sql.append(X_191,"sys","detail_ufdr_other","l4_ul_throughput",X_39); | | X_196 := sql.append(X_193,"sys","detail_ufdr_other","l4_dw_throughput",X_40); | | X_198 := sql.append(X_196,"sys","detail_ufdr_other","l4_ul_goodput",X_41); | | X_201 := sql.append(X_198,"sys","detail_ufdr_other","l4_dw_goodput",X_42); | | X_203 := sql.append(X_201,"sys","detail_ufdr_other","network_ul_traffic",X_43); | | X_205 := sql.append(X_203,"sys","detail_ufdr_other","network_dl_traffic",X_44); | | X_207 := sql.append(X_205,"sys","detail_ufdr_other","l4_ul_packets",X_45); | | X_210 := sql.append(X_207,"sys","detail_ufdr_other","l4_dw_packets",X_46); | | X_213 := sql.append(X_210,"sys","detail_ufdr_other","tcp_conn_states",X_47); | | X_215 := sql.append(X_213,"sys","detail_ufdr_other","tcp_conn_times",X_48); | | X_217 := sql.append(X_215,"sys","detail_ufdr_other","tcp_conn_2_failed_times",X_49); | | X_219 := sql.append(X_217,"sys","detail_ufdr_other","tcp_conn_3_failed_times",X_50); | | X_221 := sql.append(X_219,"sys","detail_ufdr_other","flag",X_51); | | X_224 := sql.append(X_221,"sys","detail_ufdr_other","flow_sample_ratio",X_52); | | X_227 := sql.append(X_224,"sys","detail_ufdr_other","tac",X_53); | | X_229 := sql.append(X_227,"sys","detail_ufdr_other","eci",X_54); | | X_231 := sql.append(X_229,"sys","detail_ufdr_other","tcp_syn_time",X_55); | | X_233 := sql.append(X_231,"sys","detail_ufdr_other","tcp_syn_time_msel",X_56); | | X_235 := sql.append(X_233,"sys","detail_ufdr_other","tcp_rtt_step1",X_57); | | X_239 := sql.append(X_235,"sys","detail_ufdr_other","tcp_ul_retrans_withpl",X_58); | | X_241 := sql.append(X_239,"sys","detail_ufdr_other","tcp_dw_retrans_withpl",X_59); | | X_243 := sql.append(X_241,"sys","detail_ufdr_other","tcp_ul_retrans_withoutpl",X_60); | | X_245 := sql.append(X_243,"sys","detail_ufdr_other","tcp_dw_retrans_withoutpl",X_61); | | X_247 := sql.append(X_245,"sys","detail_ufdr_other","tcp_ul_packages_withpl",X_62); | | X_249 := sql.append(X_247,"sys","detail_ufdr_other","tcp_dw_packages_withpl",X_63); | | X_253 := sql.append(X_249,"sys","detail_ufdr_other","tcp_ul_packages_withoutpl",X_64); | | X_255 := sql.append(X_253,"sys","detail_ufdr_other","tcp_dw_packages_withoutpl",X_65); | | X_257 := sql.append(X_255,"sys","detail_ufdr_other","upperlayer_ip_ul_packets",X_66); | | X_259 := sql.append(X_257,"sys","detail_ufdr_other","upperlayer_ip_dl_packets",X_67); | | X_261 := sql.append(X_259,"sys","detail_ufdr_other","downlayer_ip_ul_packets",X_68); | | X_264 := sql.append(X_261,"sys","detail_ufdr_other","downlayer_ip_dl_packets",X_69); | | X_267 := sql.append(X_264,"sys","detail_ufdr_other","upperlayer_ip_ul_fragments",X_70); | | X_269 := sql.append(X_267,"sys","detail_ufdr_other","upperlayer_ip_dl_fragments",X_71); | | X_271 := sql.append(X_269,"sys","detail_ufdr_other","downlayer_ip_ul_fragments",X_72); | | X_273 := sql.append(X_271,"sys","detail_ufdr_other","downlayer_ip_dl_fragments",X_73); | | X_275 := sql.append(X_273,"sys","detail_ufdr_other","service_dalay_msec",X_74); | | X_278 := sql.append(X_275,"sys","detail_ufdr_other","valid_trans_duration",X_75); | | X_281 := sql.append(X_278,"sys","detail_ufdr_other","air_port_duration",X_76); | | X_283 := sql.append(X_281,"sys","detail_ufdr_other","radio_conn_times",X_77); | | X_285 := sql.append(X_283,"sys","detail_ufdr_other","tcp_fst_syn_direction",X_78); | | X_287 := sql.append(X_285,"sys","detail_ufdr_other","ran_ne_id",X_79); | | X_290 := sql.append(X_287,"sys","detail_ufdr_other","ran_ne_user_ip",X_80); | | X_292 := sql.append(X_290,"sys","detail_ufdr_other","tcp_states",X_81); | | X_295 := sql.append(X_292,"sys","detail_ufdr_other","tcp_rtt",X_82); | | X_297 := sql.append(X_295,"sys","detail_ufdr_other","tcp_ul_outofsequ",X_83); | | X_299 := sql.append(X_297,"sys","detail_ufdr_other","tcp_dw_outofsequ",X_84); | | X_301 := sql.append(X_299,"sys","detail_ufdr_other","tcp_win_size",X_85); | | X_304 := sql.append(X_301,"sys","detail_ufdr_other","tcp_mss",X_86); | | X_306 := sql.append(X_304,"sys","detail_ufdr_other","trans_type",X_87); | | X_309 := sql.append(X_306,"sys","detail_ufdr_other","get_num",X_88); | | X_311 := sql.append(X_309,"sys","detail_ufdr_other","get_succeed_num",X_89); | | X_313 := sql.append(X_311,"sys","detail_ufdr_other","get_retrans_num",X_90); | | X_316 := sql.append(X_313,"sys","detail_ufdr_other","get_timeout_num",X_91); | | X_318 := sql.append(X_316,"sys","detail_ufdr_other","post_num",X_92); | | X_320 := sql.append(X_318,"sys","detail_ufdr_other","post_succeed_num",X_93); | | X_323 := sql.append(X_320,"sys","detail_ufdr_other","post_retrans_num",X_94); | | X_325 := sql.append(X_323,"sys","detail_ufdr_other","post_to_num",X_95); | | X_327 := sql.append(X_325,"sys","detail_ufdr_other","service_succeed_flag",X_96); | | X_330 := sql.append(X_327,"sys","detail_ufdr_other","interfaceid",X_97); | | X_332 := sql.append(X_330,"sys","detail_ufdr_other","homemcc",X_98); | | X_334 := sql.append(X_332,"sys","detail_ufdr_other","homemnc",X_99); | | X_337 := sql.append(X_334,"sys","detail_ufdr_other","homeprovince",X_100); | | X_339 := sql.append(X_337,"sys","detail_ufdr_other","homecity",X_101); | | X_342 := sql.append(X_339,"sys","detail_ufdr_other","host",X_102); | | X_344 := sql.append(X_342,"sys","detail_ufdr_other","service_id",X_103); | | X_346 := sql.append(X_344,"sys","detail_ufdr_other","charging_class",X_104); | | X_348 := sql.append(X_346,"sys":str,"detail_ufdr_other","charge_flag",X_105); | | X_351 := sql.append(X_348,"sys":str,"detail_ufdr_other","prepaid_flag",X_106); | | X_352 := aggr.count(X_106); | | sql.affectedRows(X_351,X_352,""); | | end s1_1; | +-------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------+

****************************************************************************************** This email and its attachments contain confidential information from HUAWEI, which is intended only for the person or entity whose address is listed above. Any use of the information contained here in any way (including, but not limited to, total or partial disclosure, reproduction, or dissemination) by persons other than the intended recipient(s) is prohibited. If you receive this email in error, please notify the sender by phone or email immediately and delete it! ***************************************************************************************** _______________________________________________ developers-list mailing list developers-list@monetdb.org http://mail.monetdb.org/mailman/listinfo/developers-list

-- | Stefan.Manegold@CWI.nl | DB Architectures (DA) | | www.CWI.nl/~manegold | Science Park 123 (L321) | | +31 (0)20 592-4212 | 1098 XG Amsterdam (NL) |