Package com.rpl.rama.module
Interface MicrobatchSourceOptions
- All Known Subinterfaces:
MicrobatchSourceOptions.Impl
public interface MicrobatchSourceOptions
Depot source options for microbatch topologies using builder pattern
Microbatch topologies documentation
-
Nested Class Summary
Nested Classes -
Method Summary
Static MethodsModifier and TypeMethodDescriptionstatic MicrobatchSourceOptions.Implcreate()Creates an empty MicrobatchSourceOptions.static MicrobatchSourceOptions.ImplThe source ID for this subscription.static MicrobatchSourceOptions.ImplStart processing from beginning of depot partition.static MicrobatchSourceOptions.ImplstartFromOffsetAfterTimestamp(long millis) Start processing each depot partition from a point in the past.static MicrobatchSourceOptions.ImplstartFromOffsetAgo(long amt, OffsetAgo unit) Start processing each depot partition from a point in the past.
-
Method Details
-
create
Creates an empty MicrobatchSourceOptions.MicrobatchSourceOptions.startFromBeginning()is the same asMicrobatchSourceOptions.create().startFromBeginning() -
sourceId
The source ID for this subscription. -
startFromBeginning
Start processing from beginning of depot partition. Only takes effect the first time the topology encounters this depot.- See Also:
-
startFromOffsetAgo
Start processing each depot partition from a point in the past. Only takes effect the first time the topology encounters this depot.- Parameters:
amt- How far back to start in terms of specified unitunit- Cardinality or time-based unit- See Also:
-
startFromOffsetAfterTimestamp
Start processing each depot partition from a point in the past. Only takes effect the first time the topology encounters this depot.- Parameters:
millis- Timestamp based on number of milliseconds since midnight, January 1, 1970 UTC- See Also:
-