Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add documentation for using DataConnectionService [SUP-523] #1361

Merged
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Apply suggestions from code review
Co-authored-by: Rob Swain <rob.swain@hazelcast.com>
frant-hartm and Rob-Hazelcast authored Nov 28, 2024
commit 83235e74ae2fc1d3625e18077de12b965d53f4bc
Original file line number Diff line number Diff line change
@@ -39,7 +39,7 @@ You can implement HazelcastInstanceAware in listeners, entry processors, tasks e
to the `HazelcastInstance`.

In the pipeline API you can use
https://docs.hazelcast.org/docs/{full-version}/javadoc/com/hazelcast/jet/core/ProcessorMetaSupplier.Context.html#dataConnectionService()[ProcessorMetaSupplier.Context#dataConnectionService()]
https://docs.hazelcast.org/docs/{full-version}/javadoc/com/hazelcast/jet/core/ProcessorMetaSupplier.Context.html#dataConnectionService()[ProcessorMetaSupplier.Context#dataConnectionService()].

NOTE: The Data Connection Service is only available on the member side. Calling `getDataConnectionService()` on client will result in `UnsupportedOperationException`.

Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
= Map Loader using Data Connection

:description: In this tutorial you build a custom map loader that uses a configured data connection to load the data not present in an IMap.
:description: In this tutorial you build a custom map loader that uses a configured data connection to load data not present in an IMap.

{description}

@@ -106,7 +106,7 @@ Create a blank Java project named pipeline-service-data-connection-example and c
</project>
----

== Step 2. MapLoader
== Step 3. MapLoader

The following map loader implements the `com.hazelcast.map.MapLoader` and `com.hazelcast.map.MapLoaderLifecycleSupport`
interfaces.
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
= Pipeline Service using Data Connection

:description: In this tutorial you build a service that transforms a stream of items. The service uses a data connection to retrieve a connection to a relational database, uses a table in the database to enrich a stream of numbers with a textual representation of the last digit.
:description: This tutorial builds a service that transforms a stream of items. The service uses a data connection to retrieve a connection to a relational database, uses a table in the database to enrich a stream of numbers with a textual representation of the last digit.

{description}

@@ -21,7 +21,7 @@ To complete this tutorial, you need the following:

|===

=== Step 1. Create and Populate the Database
== Step 1. Create and Populate the Database

This tutorial uses Docker to run the Postgres database.

@@ -104,7 +104,7 @@ Create a blank Java project named pipeline-service-data-connection-example and c
</project>
----

== Step 3. the Pipeline and the Job
== Step 3. Create the Pipeline and the Job

Create a class `EnrichUsingDataConnection` with `main` method that will be the main job class. The `main` method will do the following steps: