Ingestion API client
This client is new in v4 of the Java API clients.
The Ingestion API client is part of the algoliasearch package.
You can add this package to your pom.xml file for Maven:
1
2
3
4
5
<dependency>
<groupId>com.algolia</groupId>
<artifactId>algoliasearch</artifactId>
<version>4.23.0</version>
</dependency>
or to your build.gradle file for Gradle:
1
implementation 'com.algolia:algoliasearch:4.23.0'
To use the Ingestion client, add these imports to your files:
1
2
import com.algolia.api.IngestionClient;
import com.algolia.config.*;
To create an instance of the client:
1
IngestionClient client = new IngestionClient("ALGOLIA_APPLICATION_ID", "ALGOLIA_API_KEY", "ALGOLIA_APPLICATION_REGION");
Replace ALGOLIA_APPLICATION_ID_REGION with your Algolia application’s analytics region: us for the United States or eu for Europe.
You can check your analytics region in the Infrastructure > Analytics section of the Algolia dashboard.
List of methods
Each method makes one request to the Ingestion API.
Tasks
| client.push | Push records by indexName |
| client.listTasks | List tasks |
| client.createTask | Create a task |
| client.searchTasks | Search for tasks |
| client.getTask | Retrieve a task |
| client.updateTask | Update a task |
| client.deleteTask | Delete a task |
| client.runTask | Run a task |
| client.pushTask | Push records by taskID |
| client.enableTask | Enable a task |
| client.disableTask | Disable a task |
| client.listTasksV1 | List tasks V1 |
| client.createTaskV1 | Create a task V1 |
| client.searchTasksV1 | Search for tasks V1 |
| client.getTaskV1 | Retrieve a task V1 |
| client.updateTaskV1 | Update a task V1 |
| client.deleteTaskV1 | Delete a task |
| client.runTaskV1 | Run a task V1 |
| client.enableTaskV1 | Enable a task V1 |
| client.disableTaskV1 | Disable a task V1 |
Authentications
| client.listAuthentications | List authentication resources |
| client.createAuthentication | Create an authentication resource |
| client.searchAuthentications | Search for authentication resources |
| client.getAuthentication | Retrieve an authentication resource |
| client.updateAuthentication | Update an authentication resource |
| client.deleteAuthentication | Delete an authentication resource |
Destinations
| client.listDestinations | List destinations |
| client.createDestination | Create a destination |
| client.searchDestinations | Search for destinations |
| client.getDestination | Retrieve a destination |
| client.updateDestination | Update a destination |
| client.deleteDestination | Delete a destination |
Sources
| client.listSources | List sources |
| client.createSource | Create a source |
| client.validateSource | Validates a source payload |
| client.searchSources | Search for sources |
| client.getSource | Retrieve a source |
| client.updateSource | Update a source |
| client.deleteSource | Delete a source |
| client.validateSourceBeforeUpdate | Validates an update of a source payload |
| client.triggerDockerSourceDiscover | Trigger a stream-listing request |
| client.runSource | Run all tasks linked to a source |
Transformations
| client.listTransformations | List transformations |
| client.createTransformation | Create a transformation |
| client.tryTransformation | Try a transformation before creating it |
| client.searchTransformations | Search for transformations |
| client.getTransformation | Retrieve a transformation |
| client.updateTransformation | Update a transformation |
| client.deleteTransformation | Delete a transformation |
| client.tryTransformationBeforeUpdate | Try a transformation before updating it |
Observability
| client.listRuns | List task runs |
| client.getRun | Retrieve a task run |
| client.listEvents | List task run events |
| client.getEvent | Retrieve a task run event |