Package com.rpl.rama.module

Interface MicrobatchSourceOptions.Impl

All Superinterfaces:

MicrobatchSourceOptions

Enclosing interface:

MicrobatchSourceOptions

public static interface MicrobatchSourceOptions.Impl
extends MicrobatchSourceOptions

Nested Class Summary

Nested classes/interfaces inherited from interface com.rpl.rama.module.MicrobatchSourceOptions

MicrobatchSourceOptions.Impl

Method Summary

Modifier and Type	Method	Description
MicrobatchSourceOptions.Impl	sourceId(String sourceId)	The source ID for this subscription.
MicrobatchSourceOptions.Impl	startFromBeginning()	Start processing from beginning of depot partition.
MicrobatchSourceOptions.Impl	startFromOffsetAfterTimestamp(long millis)	Start processing each depot partition from a point in the past.
MicrobatchSourceOptions.Impl	startFromOffsetAgo(long amt, OffsetAgo unit)	Start processing each depot partition from a point in the past.

Method Details

sourceId

MicrobatchSourceOptions.Impl sourceId(String sourceId)

The source ID for this subscription.

startFromBeginning

MicrobatchSourceOptions.Impl startFromBeginning()

Start processing from beginning of depot partition. Only takes effect the first time the topology encounters this depot.

See Also:

• Documentation on start options for stream topologies
• Documentation on start options for microbatch topologies

startFromOffsetAgo

MicrobatchSourceOptions.Impl startFromOffsetAgo(long amt,
 OffsetAgo unit)

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 unit

unit - Cardinality or time-based unit

See Also:

• Documentation on start options for stream topologies
• Documentation on start options for microbatch topologies

startFromOffsetAfterTimestamp

MicrobatchSourceOptions.Impl startFromOffsetAfterTimestamp(long millis)

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:

• Documentation on start options for stream topologies
• Documentation on start options for microbatch topologies