Newest 'hazelcast-jet' Questions
executeOnKey executed on multiple nodes
We are using: iMap.executeOnKey( idInTheIMap, entry -> { return entry.setValue(....); } ); its really not anything complicated. The thing is, we observe ...
- 122k
0 votes
0 answers
36 views
Inject dependencies into pipeline sinks
This question has some background here We are using Hazelcast pipelines in the form of : Pipeline p = Pipeline.create(); p.readFrom(TestSources.items("the", "quick", "...
- 122k
0 votes
0 answers
51 views
Join large data in Hazelcast Jet
I am working on Hazelcast jet application and I trying to join two Sources using Left, Right or Inner Join with large data but I am stuck at below. Here is my code: BatchStage<Map<String,Object&...
- 670
Sources::jmsQueueBuilder for hazelcast jet
I was trying to use Sources.jmsQueueBuilder from hazelcast, and while it works, I would like to be able to hook into it a bit more. Specifically, I would like to be able to customize the jakarta.jms....
- 122k
0 votes
1 answer
48 views
How to use DataSource bean when calling Hazelcast Sources.jdbc
I'm trying to create a Source for Hazelcast Jet based on an SQL query. Instead of passing jdbc url directly, I want to use my DataSource registered in my Spring context. And then, I want to create a ...
- 3,896
Hazelcast: service in mapUsingService not serializable
My two questions: How to make HTTP request within a hazelcast pipeline? (My tries below) Why is my Foo class not serializable? I am using embedded hazelcast (5.4.0) within Java. The problematic ...
- 966
1 vote
1 answer
238 views
Synchronizing Hazelcast IMap with the database postgres
I am using hazelcast jet to capture database changes. I have a pipline which catch database changes and update IMap: Pipeline pipeline(StreamSource<ChangeRecord> theDataBase, IMap<Long, ...
- 23
0 votes
1 answer
56 views
Can Hazelcast jet be used for batch based workload?
We are working on a mainframe modernization program where we need to process 3-5 Billion records per day in 6 different cycles in 24 hours window. Records are stored in files in some specific format. ...
- 1
0 votes
1 answer
74 views
How does Hazelcast Jet assign task-to-CPU priority?
If I have the following code and let's say I'm running on 10 nodes of 32 cores each: IList<...> ds = ....; //large collection, eg 1e6 elements ds .map() //expensive computation .flatMap()//...
- 1,339
0 votes
1 answer
482 views
Hazelcast Jet Job is not able to access spring context
I am createing a spring boot application and in my application I am trying to use Hazelcast Jet in normal spring application it is working properly but while trying in spring boot application it is ...
- 670
1 vote
1 answer
303 views
Hazelcast Predicate SQL into map
I'm trying to build a method that deletes entries with attributes that are not null, but I keep failing in predicates and I don't know how to implement properly the predicate because hazelcast doesn't ...
- 41