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:

Depot documentation

Method Summary

Modifier and Type	Method and Description
Depot.Declaration	global() Configures depot to have a single partition.
Depot.Declaration	migration(java.lang.String migrationId, RamaFunction1<?,?> migrationFunction) Specify a migration on this depot.

Method Detail

global

Depot.Declaration global()

Configures depot to have a single partition. Partition will be assigned to task 0.

migration

Depot.Declaration migration(java.lang.String migrationId,
                            RamaFunction1<?,?> migrationFunction)

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:

Depot migrations documentation