Uses of Interface
software.amazon.awssdk.services.glue.model.KinesisStreamingSourceOptions.Builder
Packages that use KinesisStreamingSourceOptions.Builder
-
Uses of KinesisStreamingSourceOptions.Builder in software.amazon.awssdk.services.glue.model
Methods in software.amazon.awssdk.services.glue.model that return KinesisStreamingSourceOptions.BuilderModifier and TypeMethodDescriptionKinesisStreamingSourceOptions.Builder.addIdleTimeBetweenReads(Boolean addIdleTimeBetweenReads) Adds a time delay between two consecutive getRecords operations.KinesisStreamingSourceOptions.Builder.addRecordTimestamp(String addRecordTimestamp) When this option is set to 'true', the data output will contain an additional column named "__src_timestamp" that indicates the time when the corresponding record received by the stream.KinesisStreamingSourceOptions.Builder.avoidEmptyBatches(Boolean avoidEmptyBatches) Avoids creating an empty microbatch job by checking for unread data in the Kinesis data stream before the batch is started.KinesisStreamingSourceOptions.builder()KinesisStreamingSourceOptions.Builder.classification(String classification) An optional classification.Specifies the delimiter character.KinesisStreamingSourceOptions.Builder.describeShardInterval(Long describeShardInterval) The minimum time interval between two ListShards API calls for your script to consider resharding.KinesisStreamingSourceOptions.Builder.emitConsumerLagMetrics(String emitConsumerLagMetrics) When this option is set to 'true', for each batch, it will emit the metrics for the duration between the oldest record received by the stream and the time it arrives in Glue to CloudWatch.KinesisStreamingSourceOptions.Builder.endpointUrl(String endpointUrl) The URL of the Kinesis endpoint.KinesisStreamingSourceOptions.Builder.fanoutConsumerARN(String fanoutConsumerARN) The Amazon Resource Name (ARN) of the Kinesis Data Streams enhanced fan-out consumer.KinesisStreamingSourceOptions.Builder.idleTimeBetweenReadsInMs(Long idleTimeBetweenReadsInMs) The minimum time delay between two consecutive getRecords operations, specified in ms.KinesisStreamingSourceOptions.Builder.maxFetchRecordsPerShard(Long maxFetchRecordsPerShard) The maximum number of records to fetch per shard in the Kinesis data stream per microbatch.KinesisStreamingSourceOptions.Builder.maxFetchTimeInMs(Long maxFetchTimeInMs) The maximum time spent for the job executor to read records for the current batch from the Kinesis data stream, specified in milliseconds (ms).KinesisStreamingSourceOptions.Builder.maxRecordPerRead(Long maxRecordPerRead) The maximum number of records to fetch from the Kinesis data stream in each getRecords operation.KinesisStreamingSourceOptions.Builder.maxRetryIntervalMs(Long maxRetryIntervalMs) The maximum cool-off time period (specified in ms) between two retries of a Kinesis Data Streams API call.KinesisStreamingSourceOptions.Builder.numRetries(Integer numRetries) The maximum number of retries for Kinesis Data Streams API requests.KinesisStreamingSourceOptions.Builder.retryIntervalMs(Long retryIntervalMs) The cool-off time period (specified in ms) before retrying the Kinesis Data Streams API call.The Amazon Resource Name (ARN) of the role to assume using AWS Security Token Service (AWS STS).KinesisStreamingSourceOptions.Builder.roleSessionName(String roleSessionName) An identifier for the session assuming the role using AWS STS.KinesisStreamingSourceOptions.Builder.startingPosition(String startingPosition) The starting position in the Kinesis data stream to read data from.KinesisStreamingSourceOptions.Builder.startingPosition(StartingPosition startingPosition) The starting position in the Kinesis data stream to read data from.KinesisStreamingSourceOptions.Builder.startingTimestamp(Instant startingTimestamp) The timestamp of the record in the Kinesis data stream to start reading data from.The Amazon Resource Name (ARN) of the Kinesis data stream.KinesisStreamingSourceOptions.Builder.streamName(String streamName) The name of the Kinesis data stream.KinesisStreamingSourceOptions.toBuilder()Methods in software.amazon.awssdk.services.glue.model that return types with arguments of type KinesisStreamingSourceOptions.BuilderModifier and TypeMethodDescriptionstatic Class<? extends KinesisStreamingSourceOptions.Builder>KinesisStreamingSourceOptions.serializableBuilderClass()Method parameters in software.amazon.awssdk.services.glue.model with type arguments of type KinesisStreamingSourceOptions.BuilderModifier and TypeMethodDescriptiondefault CatalogKinesisSource.BuilderCatalogKinesisSource.Builder.streamingOptions(Consumer<KinesisStreamingSourceOptions.Builder> streamingOptions) Additional options for the Kinesis streaming data source.default DirectKinesisSource.BuilderDirectKinesisSource.Builder.streamingOptions(Consumer<KinesisStreamingSourceOptions.Builder> streamingOptions) Additional options for the Kinesis streaming data source.