Documentation

Data Type
Operators
Mathematical Functions
String Functions
Date/Time Functions
Sequence Functions
Table Sequence Functions
Loop Functions
Functions for Associative Operations
File-handling Functions
Database Functions
Cursor Functions
Statements
System- & interface-related Functions
Cluster Computing Functions
Chart-plotting Functions
Financial Functions
External Library Functions
Composite-Table-Related Functions
Functions

#c

$(db)sql;…

$()sql;…

${macroExp}

=expression

>statement

[a:b]

@

A()

A.( x )

[a 1 ,…a n ]

abs()

acos()

acosh()

age()

align()

ali_client()

ali_close()

ali_query()

and()

append()

array()

asc()

asin()

asinh()

atan()

atanh()

attach()

avg()

base64 ()

between()

bits()

bool()

break {a}

C

Cr()

calc()

call()

call path/dfx( … )

callx()

cand()

canvas()

case()

ceil()

ch.()

channel()

char()

clear

clipboard()

close()

cmp()

cor()

combin()

commit()

concat()

conj()

conjx()

connect()

contain()

cos()

cosh()

count()

create()

cs.()

cum()

cursor()

date()

datetime()

day()

days()

decimal()

delete()

deq()

derive()

dfx ( … )

diff()

directory()

dup()

elapse()

end s

enum()

env()

eq()

error()

eval()

es_close ()

es_delete()

es_head()

es_open()

es_get()

es_post()

es_put()

execute()

exists()

exp()

export()

f@o(…)

Faccrint()

Faccrintm()

fact()

false

Fcoupcd()

Fcoups()

Fdb()

Fddb()

Fdisc()

Fduration()

fetch()

field()

file()

filename()

find()

Fintrate()

Firr()

float()

floor()

Fmirr()

fname()

fno()

Fnper()

Fnpv()

for

fork

fork A i ,…

Fpmt()

Fprice()

Frate()

Freceived()

Fsln()

Fsyd()

ftp_cd()

ftp_client()

ftp_close()

ftp_dir()

ftp_get()

ftp_mget()

ftp_mput()

ftp_put()

func()

Fv()

Fvdb()

Fyield()

gcd()

goto C

group()

groupi()

groupn()

groups()

groupx()

hash()

hbase_close()

hbase_cmp()

hbase_filter()

hbase_filterlist()

hbase_get()

hbase_open()

hbase_scan()

hdfs_client()

hdfs_close()

hdfs_dir()

hdfs_file()

hive_client()

hive_close()

hive_cursor()

hive_execute ()

hive_query()

hosts()

hour()

httpfile()

icursor()

icount()

id()

if

if()

ifa()

ifdate()

ifn()

ifnumber()

ifr()

ifstring()

ift()

iftime()

ifv()

ifx_close()

ifx_conn()

ifx_cursor()

ifx_listfrag()

ifx_savefrag()

ifx_setfrag()

ifx_takefrag()

import()

index()

inf()

insert()

int()

interval()

inv()

invoke()

isalpha()

isdigit()

isect()

iselect()

islower()

isolate()

isupper()

iterate()

join()

joinx()

json()

k()

k{}

kafka_close()

kafka_commit()

kafka_poll()

kafka_subscribe()

key()

keys()

lcm()

left()

len()

lg()

like()

ln()

lock()

long()

lower()

m()

max()

maxp()

mcursor()

md5()

median()

memory()

merge()

Mergex()

mid()

millisecond()

min()

minp()

minute()

modify()

mongo_close ()

mongo_insert()

mongo_open()

mongo_shell()

month()

movefile()

n.f( x )

name()

new()

news()

next{a}

nodes()

not()

now()

null

number()

nvl()

olap_close()

olap_open()

olap_query()

or()

output()

p()

pad()

parse()

paste()

pdate()

penum()

periods()

permut()

pfind()

pi()

pivot()

pmax()

pmin()

pos()

power()

prior()

proc()

product()

property()

pseg()

pselect()

psort()

ptop()

push()

query()

r.( x )

r.F

r.F=x

rand()

rands()

range()

rank()

ranks()

read()

record()

redis()

redis_close()

redis_cluster()

redis_get()

redis_getrange()

redis_hkeys()

redis_hlen()

redis_hmget()

redis_hvals()

redis_keys()

redis_lindex()

redis_llen()

redis_lrange()

redis_pool()

redis_scard()

redis_sdiff()

redis_select()

redis_sentinel()

redis_shared()

redis_sharedpool()

redis_sinter()

redis_sismember()

redis_smembers()

redis_srandmember()

redis_strlen()

redis_sunion()

redis_type()

redis_zcard()

redis_zcount()

redis_zrange()

redis_zrangebyscore()

redis_zrank()

redis_zscore()

regex()

register()

rename()

replace()

report_config()

report_exportHtml()

report_exportPdf()

report_exportXls()

report_open()

report_run()

reset()

result

return xi

rgb()

right()

rollback()

round()

run()

rvs()

sap_client ()

sap_close()

sap_cursor ()

sap_execute ()

sap_getparam ()

sap_table ()

savepoint()

second()

segp()

select()

seq()

shift()

sign()

sin()

sinh()

size()

sizeof()

skip()

sleep()

sort()

sortx()

spark_client()

spark_close()

spark_cursor()

spark_query()

split()

sqlparse()

sqltranslate()

SQL +

substr()

stax_close ()

stax_connect ()

stax_query ()

sqrt()

step()

string()

sum()

swap()

switch()

sync()

system()

tan()

tanh()

time()

to()

top()

total()

trim()

true

union()

update()

upper()

urlencode ()

v()

words()

workday()

workdays()

write()

ws_call()

ws_client()

xjoin()

xjoinx()

xlscell()

xlsclose()

xlsexport()

xlsimport()

xlsopen()

xlswrite()

xml()

xor()

year()

ym_build_model()

ym_close()

ym_env()

ym_importance()

ym_list()

ym_model()

ym_performance()

ym_predict()

ym_present()

ym_result()

ym_setparam()

ym_statistics()

ym_target()

z()

zip()

zip_add()

zip_close ()

zip_compress()

zip_del()

zip_encrypt()

zip_extract()

zone()

Intersection of sequences

Comparison operation

Hexadecimal long integer

Modulus

Concatenation of sequences

Arithmetic operations

Compound assignment

String

String concatenation

Concatenation of serial bytes

Alignment arithmetic operations

Difference between sequences

Union of sequences

Multiplication of sequences

Loop functions

The writing rules for expression x in loop functions

Batch Computation

Identifier

Opposite Number

Empty Sequence

Assignment

Value Computation and Assignment

Escape Character

Logical Operations

Long Integer

Cell type

Code block type
Chart Elements

G .draw()

G.hlink

G .plot()

Chart Element Parameters

sync()

Read（217） Like（0） Label: nodes, synchronize,

Description:

Synchronize the nodes.

Syntax:

sync(hd:hs,p;zs)

Note:

The function synchronzies file directories p in partition list zs on the nodes holding the processes specified by parameter hs onto the same directories in zs on the nodes holding the processes specified by parameter hd. The synchronization is performed according to the last time the files are updated, thus extra file will be deleted and time will be checked. If there are namesake files in the same partitions, synchronize hd by those with the latest update time. Perform the synchronization on the local machine if parameter hs and hd are absent; synchronize all files if parameter p is absent; and find the files under the nodes’ main directories if parameter zs is absent.

Parameters:

hd	A sequence of processes
hs	A sequence of processes
p	The file directories in the partition list on the nodes holding processes parameter hs specifies
zs	A data partition named after an integer. The parameter is a sequence when there are multiple partitions.

Example:

	A
1	=sync(["192.168.1.100:8081","192.168.1.101:8283"]:"192.168.0.99:9281";1)	Synchronize data partition 1 on the node "192.168.0.99:9281" to the data partition 1 on both the nodes "192.168.0.100:8081" and "192.168.1.101:8283"
2	=sync(["192.168.1.100:8081","192.168.1.101:8283"]:"192.168.0.99:9281")	Synchronzie all data partitions on the node "192.168.0.99:9281" to the data partitions on both the nodes "192.168.0.100:8081" and "192.168.1.101:8283"
3	=sync(["192.168.1.100:8081","192.168.1.101:8283"]:"192.168.0.99:9281","f1")	Synchronize folder “f1” under the main directory on the node "192.168.0.99:9281" to the main directory on both the nodes "192.168.0.100:8081" and "192.168.1.101:8283"
4	=sync(["192.168.1.100:8081","192.168.1.101:8283"]:;1)	Synchronize data partition 1 on the local machine to data partition 1 on both the nodes "192.168.0.100:8081" and "192.168.1.101:8283"
5	=sync(:"192.168.0.99:9281";[1,2])	Syncronize data partitions 1 and 2 on the node "192.168.0.99:9281" to the same data partitions on the local machine
6	=sync(["192.168.1.100:8081","192.168.1.101:8283"]:"192.168.0.99:9281",”t1”;1)	Synchronize the folder “t1” in partition 1 on the node "192.168.0.99:9281" onto the corresponding folder in partition 1 on node “192.168.0.100:8081” and node “192.168.1.101:8283”