Skip to main content

Unanswered questions

3
M
Fan
Mahender_SSFan
 Community Articles and Got a Question?
How can we use the aggregation query/pipeline in MongoDB Atlas lookup processor or any other processor?

Hi All, I have a requirement to use the aggregation query using match,group,sum,min,max and counts on a MongoDB Atlas collection in a StreamSets pipeline probably in a lookup processor by passing the input fields.Is it possible? Thanks,Mahender

20
M
Fan
elefthkam
Fan
elefthkamFan
 Share your Best Practices
How to Implement Real-Time Deduplication to Keep Latest Event per (GUID, EVENT_ACTION) in StreamSets from Kafka?

Deduplicate and keep latest based on timestamp field in streamsets ibm?  

80
elefthkam
Fan
D
Fan
dhanrajshindeFan
 Community Articles and Got a Question?
HTTP Client Processor Pagination for using Page number for Binary data

Hi, I have an API which takes page_no and page_size as parameter for pagination.API response is not a json data or had a records in list/array but a Binary Byte array as string.API returns a zip file.In response header it has total_pages, page_no and page_size. In streamsets for pagination with page number we have to provide result field path for incrementing to next page number. which is not possible in my case.refer doc https://learn.ocp.ai/guides/exports-api Could anyone please suggest solution for it.     

40
D
Fan

Badge winners

Show all badges
Terms & Conditions