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 and Description
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.

Methods inherited from interface com.rpl.rama.module.MicrobatchSourceOptions

create, startFromBeginning, startFromOffsetAfterTimestamp, startFromOffsetAgo

Method Detail

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