List<ExtractionPipeline> listPipelinesResults = new ArrayList<>(); 
client.extractionPipelines() 
          .list(Request.create() 
               .withFilterParameter("source", "source")) 
          .forEachRemaining(events -> listPipelinesResults.addAll(events));

{
  "items": [
    {
      "externalId": "<string>",
      "name": "<string>",
      "dataSetId": 4503599627370495,
      "description": "<string>",
      "rawTables": [
        {
          "dbName": "<string>",
          "tableName": "<string>"
        }
      ],
      "schedule": "<string>",
      "contacts": [
        {
          "name": "<string>",
          "email": "jsmith@example.com",
          "role": "<string>",
          "sendNotification": true
        }
      ],
      "metadata": {
        "property1": "string",
        "property2": "string"
      },
      "source": "<string>",
      "documentation": "<string>",
      "notificationConfig": {
        "allowedNotSeenRangeInMinutes": 1
      },
      "createdBy": "<string>",
      "id": 4503599627370495,
      "lastSuccess": 123,
      "lastFailure": 123,
      "lastMessage": "<string>",
      "lastSeen": 123,
      "createdTime": 1730204346000,
      "lastUpdatedTime": 1730204346000
    }
  ]
}