Table of Contents |
---|
...
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.
...
Install Chango Client API Library
...
Add chango client as dependency in maven.
Code Block |
---|
<dependency>
<groupId>co.cloudcheflabs.chango</groupId>
<artifactId>chango-client</artifactId>
<version>1.1.0</version>
</dependency> |
Or, download chango client library . It which needs to be added to your application classpath.
Code Block |
---|
curl -L -O https://github.com/cloudcheflabs/chango-client/releases/download/1.1.0/chango-client-1.1.0-executable.jar; |
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.
Example of sending json to chango using Chango Client Library
You may construct chango client instance like this.
...
Code Block |
---|
String json = ... // add json coming from your application to the internal queue in chango client. changoClient.add(json); |
Query Iceberg Table using Trino Clients
Json data ingested to iceberg table in chango can be queries using trino clients like Trino CLI, Redash and Metabase.
...