External applications also can ingest json data to chango. For example, external applications like spark streaming application consumes json from kafka and then send these streaming json data to chango. For such cases,

chango provides Chango Client API Library written in java.

Create Iceberg Table before sending json to chango

As seen in ingestion of json to chango using Chango CLI https://mykidong.atlassian.net/wiki/spaces/CHANGOCLOUD/pages/2212724750/Chango+CLI#Create-Iceberg-Table-before-Json-Data-Ingestion , you need to create iceberg table beforehand.

Download Chango Client API Library

Download chango client library. It needs to be added to your application classpath.

curl -L -O https://github.com/cloudcheflabs/spark/releases/download/chango-client-1.0.0-SNAPSHOT/chango-client-1.0.0-SNAPSHOT-executable.jar;

Example of sending json to chango using Chango Client Library

You may construct chango client instance like this.

import com.cloudcheflabs.chango.client.component.ChangoClient;

...


String adminServer = "https://chango-admin-oci.cloudchef-labs.com";
String user = "user1";
String password = "anypassword";
String dataApiServer = "https://chango-data-api-jetty-oci-user1.cloudchef-labs.com";
int batchSize = 10000;
long interval = 1000;
String schema = "iceberg_db";
String table = "test_iceberg";

ChangoClient changoClient = new ChangoClient(adminServer,
        user,
        password,
        dataApiServer,
        schema,
        table,
        batchSize,
        interval);      

• batchSize : the size of json list which will be sent to chango in batch mode and in gzip format.

• interval : json data will be queued internally in chango client. The queued json list will be sent in this period whose unit is milliseconds.

And then just call add() .

...