package kinesis
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- case class KinesisFlowSettings(parallelism: Int, maxBatchSize: Int, maxRecordsPerSecond: Int, maxBytesPerSecond: Int, maxRetries: Int, backoffStrategy: RetryBackoffStrategy, retryInitialTimeout: FiniteDuration) extends Product with Serializable
- class KinesisSourceStage extends GraphStage[SourceShape[Record]]
- case class ShardSettings(streamName: String, shardId: String, shardIteratorType: ShardIteratorType, startingSequenceNumber: Option[String] = None, atTimestamp: Option[Date] = None, refreshInterval: FiniteDuration, limit: Int) extends Product with Serializable
Value Members
- object KinesisErrors
- object KinesisFlowSettings extends Serializable
- object KinesisFlowStage
- object KinesisSourceStage
- object ShardSettings extends Serializable