You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: README.md
+33-33Lines changed: 33 additions & 33 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -1,25 +1,25 @@
1
-
Data Mesh Manager SDK
1
+
Entropy Data SDK
2
2
======================
3
3
4
-
The Data Mesh Manager SDK is a Java library that provides a set of APIs to interact with [Data Mesh Manager](https://datamesh-manager.com) and [Data Contract Manager](https://datacontract-manager.com).
4
+
The Entropy Data SDK is a Java library that provides a set of APIs to interact with [Entropy Data](https://entropy-data.com).
5
5
6
6
Using the SDK, you can build Java applications to automate data platform operations, such as:
7
7
8
-
- Synchronize data products and data assets from the data platform to the Data Mesh Manager
9
-
- Synchronize datacontract.yaml in Git repositories with Data Contract Manager
8
+
- Synchronize data products and data assets from the data platform to Entropy Data
9
+
- Synchronize datacontract.yaml in Git repositories with Entropy Data
10
10
- Automate permissions in the data platform when an access request has been approved
11
11
- Notify downstream consumers when data contract tests have failed
12
-
- Publish data product costs and usage data to Data Mesh Manager
12
+
- Publish data product costs and usage data to Entropy Data
13
13
14
14
This SDK is designed as a foundation for building data platform integrations that run as long-running connectors on customer's data platform, e.g., as containers running in a Kubernetes cluster or any other container-runtime.
15
15
16
-
It interacts with the Data Mesh Manager APIs to send metadata and to subscribe to events to trigger actions in the data platform or with other services.
16
+
It interacts with the Entropy Data APIs to send metadata and to subscribe to events to trigger actions in the data platform or with other services.
17
17
18
18
19
19
Existing Connectors
20
20
---
21
21
22
-
We provide some connectors for commonly-used platforms that that use this SDK and that can be used out-of-the-box or as a template for custom integrations:
22
+
We provide some connectors for commonlyused platforms that use this SDK and that can be used out-of-the-box or as a template for custom integrations:
@@ -53,64 +53,64 @@ Add this dependency to your `pom.xml`:
53
53
54
54
```xml
55
55
<dependency>
56
-
<groupId>com.datamesh-manager</groupId>
57
-
<artifactId>datamesh-manager-sdk</artifactId>
56
+
<groupId>com.entropy-data</groupId>
57
+
<artifactId>entropy-data-sdk</artifactId>
58
58
<version>RELEASE</version>
59
59
</dependency>
60
60
```
61
61
62
62
Replace the `RELEASE` with the latest version of the SDK.
63
63
64
-
### Instantiate a DataMeshManagerClient
64
+
### Instantiate an EntropyDataClient
65
65
66
-
To work with the API, you need an [API key](https://docs.datamesh-manager.com/quickstart).
67
-
Then you can instantiate a `DataMeshManagerClient`:
66
+
To work with the API, you need an [API key](https://docs.entropy-data.com/quickstart).
67
+
Then you can instantiate an `EntropyDataClient`:
68
68
69
69
```java
70
-
var client =newDataMeshManagerClient(
71
-
"https://api.datamesh-manager.com",
72
-
"dmm_live_..."
70
+
var client =newEntropyDataClient(
71
+
"https://api.entropy-data.com",
72
+
"ed_live_..."
73
73
);
74
74
```
75
75
76
-
This client has all methods to interact with the [Data Mesh Manager API](https://api.datamesh-manager.com/swagger/index.html).
76
+
This client has all methods to interact with the [Entropy Data API](https://api.entropy-data.com/swagger/index.html).
77
77
78
78
### Implement an AssetsProvider (optional)
79
79
80
-
To synchronize assets (such as tables, views, files, topics, ...) from your data platform with Data Mesh Manager, implement the `DataMeshManagerAssetsProvider` interface:
80
+
To synchronize assets (such as tables, views, files, topics, ...) from your data platform with Entropy Data, implement the `EntropyDataAssetsProvider` interface:
// use the DataMeshManagerClient to retrieve the current access resource and data product and consumer resource for details
113
+
// use the EntropyDataClient to retrieve the current access resource and data product and consumer resource for details
114
114
}
115
115
116
116
@Override
@@ -120,41 +120,41 @@ public class MyEventHandler implements DataMeshManagerEventHandler {
120
120
}
121
121
```
122
122
123
-
You can listen to any event from Data Mesh Manager. The SDK provides a method for each event type.
123
+
You can listen to any event from Entropy Data. The SDK provides a method for each event type.
124
124
125
-
With this implementation, you can start an `DataMeshManagerEventListener`:
125
+
With this implementation, you can start an `EntropyDataEventListener`:
126
126
127
127
```java
128
128
var connectorid ="my-unique-event-listener-connector-id";
129
129
var eventHandler =newMyEventHandler();
130
130
var stateRepository =...// see below
131
-
var eventListener =newDataMeshManagerEventListener(connectorid, client, eventHandler, stateRepository);
132
-
eventListener.start(); // This will start a long-running connector that listens to events from Data Mesh Manager
131
+
var eventListener =newEntropyDataEventListener(connectorid, client, eventHandler, stateRepository);
132
+
eventListener.start(); // This will start a long-running connector that listens to events from Entropy Data
133
133
```
134
134
135
135
If you have multiple connectors in an application, make sure to start the `start()` methods in separate threads.
136
136
137
137
### State Repository
138
138
139
-
The `DataMeshManagerEventListener` requires a `DataMeshManagerStateRepository` to store the `lastEventId` that has been processed.
139
+
The `EntropyDataEventListener` requires an `EntropyDataStateRepository` to store the `lastEventId` that has been processed.
140
140
Also, you can use the state repository in other connectors, if you need to store information what has been processed or what is the current state of your connector.
141
141
You can implement this interface to store the state in a database, a file, or any other storage:
142
142
143
143
```java
144
-
publicinterfaceDataMeshManagerStateRepository {
144
+
publicinterfaceEntropyDataStateRepository {
145
145
Map<String, Object>getState();
146
146
voidsaveState(Map<String, Object>state);
147
147
}
148
148
```
149
149
150
-
For your convenience, you can use the `DataMeshManagerStateRepositoryRemote` to store the state directly in the Data Mesh Manager:
150
+
For your convenience, you can use the `EntropyDataStateRepositoryRemote` to store the state directly in Entropy Data:
151
151
152
152
```java
153
153
var connectorId ="my-unique-event-listener-connector-id";
154
-
var stateRepository =newDataMeshManagerStateRepositoryRemote(connectorId, client);
154
+
var stateRepository =newEntropyDataStateRepositoryRemote(connectorId, client);
155
155
```
156
156
157
-
and for testing there is also a `DataMeshManagerStateRepositoryInMemory`.
157
+
and for testing there is also an `EntropyDataStateRepositoryInMemory`.
Copy file name to clipboardExpand all lines: src/main/java/entropydata/sdk/EntropyDataAssetsProvider.java
+4-4Lines changed: 4 additions & 4 deletions
Original file line number
Diff line number
Diff line change
@@ -1,11 +1,11 @@
1
-
packagedatameshmanager.sdk;
1
+
packageentropydata.sdk;
2
2
3
-
importdatameshmanager.sdk.client.model.Asset;
3
+
importentropydata.sdk.client.model.Asset;
4
4
5
5
/**
6
-
* Implementations of this interface fetch assets (tables, views, schemas, ...) from the data platform or data catalog. They convert them to the Asset format of the Data Mesh Manager, and can either send them for creation/update or for deletion to synchronize the asset metadata.
6
+
* Implementations of this interface fetch assets (tables, views, schemas, ...) from the data platform or data catalog. They convert them to the Asset format of Entropy Data, and can either send them for creation/update or for deletion to synchronize the asset metadata.
0 commit comments