Package com.rpl.rama
Interface Depot.Declaration
- Enclosing interface:
Depot
public static interface Depot.Declaration
Builder-style object to specify options when declaring a depot in a module
- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionglobal()
Configures depot to have a single partition.migration
(String migrationId, RamaFunction1<?, ?> migrationFunction) Specify a migration on this depot.
-
Method Details
-
global
Depot.Declaration global()Configures depot to have a single partition. Partition will be assigned to task 0. -
migration
Specify a migration on this depot. Migrations iterate over the full depot and can change or remove records from a depot.- Parameters:
migrationId
- Used to determine if a migration should be restarted or continue where it left off when the module is updated mid-migration. If this remains the same, it continues where it left off. Otherwise, it restarts from the beginning of the depot.migrationFunction
- Function from depot record to migrated record. Return Depot.TOMBSTONE to remove the record from the depot.- See Also:
-