External Library Functions

Read(460) Label: external library, database,

  esProc has external library functions that access and handle data stored in various places.

 

Ø  ali_client()

Connect to Alibaba Cloud and return result as a cursor

 

Ø  ali_close()

Close the connection to Alibaba Cloud

 

Ø  ali_query()

Query a certain part of the data, and return result as a cursor

 

Ø  es_close()

Close REST Client connection

 

Ø  es_delete()

Execute a delete command over an ES server

 

Ø  es_head()

Execute a head command over an ES server

 

Ø  es_get()

Execute a get command over an ES server

 

Ø  es_open()

Connect to Elasticsearch (ES) server

 

Ø  es_post()

Execute a post command over an ES server

 

Ø  es_put()

Execute a put command over an ES server

 

Ø  ftp_cd()

Set the remote working directory/directories on the FTP server

 

Ø  ftp_client()

Create an FTP client

 

Ø  ftp_close()

Exit an FTP client program

 

Ø  ftp_dir()

List all directories and files under the current directory on an FTP server

 

Ø  ftp_get()

Download a file from the FTP server

 

Ø  ftp_mget()

Download multiple files from a FTP server

 

Ø  ftp_mput()

Upload multiple files onto a FTP server

 

Ø  ftp_put()

Upload a file to the FTP server

 

Ø  hbase_close()

Close a HBase connection

 

 

Ø  hbase_cmp()

Compare data with the HBase-supplied comparator

 

 

Ø  hbase_filter()

Filter data with the HBase-supplied filter

 

 

Ø  hbase_filterlist()

Filter data with multiple filters

 

 

Ø  hbase_get()

Query data in HBase database and return a single row

 

 

Ø  hbase_open()

Create a HBase connection

 

 

Ø  hbase_scan()

Query a HBase database and return result as a cursor or a table sequence

 

 

Ø  hdfs_client()

Connect to the HDFS file system and return an HDFS client object

 

Ø  hdfs_close()

Close the HDFS connection

 

Ø  hdfs_dir()

List the file names in a specified path in an HDFS file system

 

Ø  hdfs_file()

Open a specified directory and return an HDFS file flow

 

Ø  hive_client()

Create a Hive database connection

 

Ø  hive_close()

Close a Hive database connection

 

Ø  hive_cursor()

Query a Hive database, and return the result as a cursor

 

Ø  hive_execute()

Execute Hive’s SQL-like queries

 

Ø  hive_query()

Query a Hive database, and return the result as a sequence

 

Ø  ifx_close()

Close Informix database connection

 

Ø  ifx_conn()

Create Informix database connection

 

Ø  ifx_cursor()

List the fragmentation information of a specified table with cursors

 

Ø  ifx_listfrag()

List the fragmentation information of a specified table with table sequences

 

Ø  ifx_savefrag()

Save the fragmentation information file stored in the memory as a new file

 

Ø  ifx_setfrag()

Set the fragmentation information of a specified table

 

Ø  ifx_takefrag()

Extract fragmentation information from the database

 

Ø  kafka_close()

Close a Consumer connection

 

Ø  kafka_commit()

Commit the current consumer offset position

 

Ø  kafka_poll()

Return records in a Consumer topic as a table sequence

 

Ø  kafka_subscribe()

Connect to Kafka server

 

Ø  mongo_close()

Close the connection to MongoDB

 

Ø  mongo_insert()

Insert data to a MongoDB database

 

Ø  mongo_open()

Connect to MongoDB server

 

Ø  mongo_shell()

Query MongoDB and return the query result

 

Ø  olap_close()

Close connection to a multidimensional database

 

Ø  olap_open()

Establish connection to multidimensional database

 

Ø  olap_query()

Query data in a multidimensional database and return the result

 

Ø  redis()

Connect to a Redis database under the single machine model

 

Ø  redis_close()

Close a Redis database connection

 

Ø  redis_cluster()

Connect to Redis cluster

 

Ø  redis_get()

Get the values of all the given keys

 

Ø  redis_getrange()

Get a substring of the string stored at a key

 

Ø  redis_hkeys()

Get all the fields in a hash

 

Ø  redis_hlen()

Get the number of fields in a hash

 

Ø  redis_hmget()

Get the values of all the given hash fields

 

Ø  redis_hvals()

Get the values of all hash fields

 

Ø  redis_keys()

Find all keys matching the specified pattern

 

Ø  redis_lindex()

Get a member from a list by its index

 

Ø  redis_llen()

Get the length of a list

 

Ø  redis_lrange()

Get a range of members in a list with indexes within the given values

 

Ø  redis_pool()

Connect to Redis database in buffer pool mode

 

 

Ø  redis_scard()

Get the number of members in a set

 

Ø  redis_sdiff()

Get members of the difference set of all the given sets

 

Ø  redis_select()

Change the selected database for the current connection

 

Ø  redis_sentinel()

Connect to distributed Redis cluster

 

 

Ø  redis_shared()

Connect to a Redis database in shared pool mode

 

 

Ø  redis_sharedpool()

Connect to a Redis database in a mode of both buffer pool and shared pool

 

 

Ø  redis_sinter()

Get members of the intersection of all the given sets

 

Ø  redis_sismember()

Determine if a given value is a member of a set

 

Ø  redis_smembers()

Get all members of a set

 

Ø  redis_srandmember()

Get one or multiple random members from a set

 

Ø  redis_strlen()

Get the length of the string value stored in the key

 

Ø  redis_sunion()

Get the members of the union of all the given sets

 

Ø  redis_type()

Get the data type of the value stored in the key

 

Ø  redis_zcard()

Get the number of members in a sorted set

 

Ø  redis_zcount()

Count the number of members in a sorted set with scores between a given interval

 

Ø  redis_zrange()

Return a range of members in a sorted set, by index

 

Ø  redis_zrangebyscore()

Return a range of members in sorted set, by score

 

Ø  redis_zrank()

Determine the ranking of a member in a sorted set

 

Ø  redis_zscore()

Get the score associated with the given member in a sorted set

 

Ø  report_config()

Read information from the configuration file

 

Ø  report_exportHtml()

Export a report as a HTML file or an MHT file

 

Ø  report_exportPdf()

Export a report as a PDF file

 

Ø  report_exportXls()

Export a report as an xls file or an xlsx file

 

Ø  report_open()

Read a report file

 

Ø  report_run()

Compute a report file

 

Ø  sap_client()

Connect to an SAP server

 

Ø  sap_close()

Close an SAP server connection

 

Ø  sap_cursor()

Return the list of table-valued result set as a cursor

 

Ø  sap_excute()

Get a function object according to the import parameter(s)

 

Ø  sap_getparam()

Get data records according to the import parameter(s)

 

Ø  sap_table()

Return a list according to the import table-valued parameter

 

Ø  spark_client()

Create a Spark database connection

 

Ø  spark_close()

Close a Spark database connection

 

Ø  spark_cursor()

Query a Spark database, and return the result as a cursor

 

Ø  spark_query()

Query a Spark database, and return the result as a sequence

 

Ø  stax_close()

Close connection to the Cassandra database

 

Ø  stax_connect()

Create connection to the Cassandra database

 

Ø  stax_query()

Query a Cassandra database and return query result as a table sequence

 

Ø  web_crawl()

Extract data from websites

 

Ø  ws_call()

Create a web service client

 

Ø  ws_client()

Send a query request to the web service server to get the returned data

 

Ø  ym_build_model()

Perform model building operation

 

Ø  ym_close()

Close Python service to reduce source usage

 

Ø  ym_env()

Initialize the environment by setting an environment variable

 

Ø  ym_exec()

Execute a Python file to define a data file and the target variable for data scoring

 

Ø  ym_importance()

List the degrees of importance for model building variables

 

Ø  ym_json()

Return model information as a JSON string

 

Ø  ym_load_pcf()

Generate a model object based on the model building file

 

Ø  ym_model()

Load data for model building

 

Ø  ym_performance()

Get information about the performance of a model

Ø  ym_pre_performance()

Get model performance information according to scoring result

 

 

Ø  ym_predict()

perform data scoring

 

Ø  ym_present()

Get model description data

 

Ø  ym_result()

Get data from the scoring result object

 

Ø  ym_save_pcf()

Generate a model file according to a model object

 

Ø  ym_setparam()

Set model building parameters

 

Ø  ym_statistics()

Get a series of information about a specified  variable

 

Ø  ym_target()

Set a target variable for model building

 

Ø  zip()

Perform file compression operations

 

Ø  zip_add()

Add one or more files to a zip file

 

Ø  zip_close()

Close a zip file

 

Ø  zip_compress()

Set compression mode and level for a would-be zip file

 

Ø  zip_del()

Delete one or more files from a zip file

 

Ø  zip_encrypt()

Set encryption mode for a zip file

 

Ø  zip_extract()

Extract one or more files from a zip file