JdbcStreamState

Encapsulates database-specific transient state for a particular stream.

Implementations should be thread-safe.

Properties

abstract var cursorUpperBound: JsonNode?

Value to use as upper bound for the cursor column.

abstract var fetchSize: Int?

Value to use for JDBC fetchSize, if specified.

Same as fetchSize, but falls back to a default value.

abstract val limit: Long

Value to use for the LIMIT clause in resumable reads, if applicable.

abstract val sharedState: A

The transient state shared by all partitions. Includes global resources.

Convenience getter for the current Stream.

StreamFeedBootstrap instance passed to the JdbcPartitionsCreatorFactory instance which created this object.

abstract fun reset()

Resets the transient state to its initial setting.

Adjusts the limit value up or down.