DefaultJdbcStreamState

Default implementation of JdbcStreamState.

Constructors

constructor(sharedState: DefaultJdbcSharedState, streamFeedBootstrap: StreamFeedBootstrap)

open override var cursorUpperBound: JsonNode?

Value to use as upper bound for the cursor column.

open override var fetchSize: Int?

Value to use for JDBC fetchSize, if specified.

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

open override val limit: Long

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

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.

open override fun reset()

Resets the transient state to its initial setting.

Adjusts the limit value up or down.