bulk-cdk-core-extract/io.airbyte.cdk.read/StreamFeedBootstrap

StreamFeedBootstrap

class StreamFeedBootstrap(outputConsumer: StandardOutputConsumer, metaFieldDecorator: MetaFieldDecorator, stateManager: StateManager, stream: Stream, dataChannelFormat: DataChannelFormat, dataChannelMedium: DataChannelMedium, bufferByteSizeThresholdForFlush: Int, clock: Clock) : FeedBootstrap<Stream>

FeedBootstrap implementation for Stream feeds.

Constructors

Link copied to clipboard
constructor(outputConsumer: StandardOutputConsumer, metaFieldDecorator: MetaFieldDecorator, stateManager: StateManager, stream: Stream, dataChannelFormat: DataChannelFormat, dataChannelMedium: DataChannelMedium, bufferByteSizeThresholdForFlush: Int, clock: Clock)

Properties

Link copied to clipboard
Link copied to clipboard
val clock: Clock
Link copied to clipboard
val currentState: OpaqueStateValue?

Convenience getter for the current state value for this feed.

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
val feed: Stream

Feed to emit records for.

Link copied to clipboard
val feeds: List<Feed>

Delegates to StateManager.feeds.

Link copied to clipboard
val metaFieldDecorator: MetaFieldDecorator

The MetaFieldDecorator instance which StreamRecordConsumer will use to decorate records.

Link copied to clipboard
val outputConsumer: StandardOutputConsumer

The OutputConsumer instance to which StreamRecordConsumer will delegate to.

Functions

Link copied to clipboard
fun currentState(feed: Feed): OpaqueStateValue?

Deletages to StateManager to return the current state value for any Feed.

Link copied to clipboard
fun resetAll()

Resets the state value of this feed and the streams in it to zero.

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard