class_docstr: Builder to construct KinesisStreamsSink.
  
  The following example shows the minimum setup to create a KinesisStreamsSink that writes String
  values to a Kinesis Data Streams stream named your_stream_here.
  
  Example:
  ::
  
      >>> from pyflink.common.serialization import SimpleStringSchema
      >>> sink_properties = {"aws.region": "eu-west-1"}
      >>> sink = KinesisStreamsSink.builder() \
      ...     .set_kinesis_client_properties(sink_properties) \
      ...     .set_stream_name("your_stream_name") \
      ...     .set_serialization_schema(SimpleStringSchema()) \
      ...     .set_partition_key_generator(PartitionKeyGenerator.random()) \
      ...     .build()
  
  If the following parameters are not set in this builder, the following defaults will be used:
  
      - maxBatchSize will be 500
      - maxInFlightRequests will be 50
      - maxBufferedRequests will be 10000
      - maxBatchSizeInBytes will be 5 MB i.e. 5 * 1024 * 1024
      - maxTimeInBufferMS will be 5000ms
      - maxRecordSizeInBytes will be 1 MB i.e. 1 * 1024 * 1024
      - failOnError will be false
class_docstr_tok: ["Builder","to","construct","KinesisStreamsSink",".","The","following","example","shows","the","minimum","setup","to","create","a","KinesisStreamsSink","that","writes","String","values","to","a","Kinesis","Data","Streams","stream","named","your_stream_here",".","Example",":",":",":",">",">",">","from","pyflink.common.serialization","import","SimpleStringSchema",">",">",">","sink_properties","=","{","``","aws.region","''",":","``","eu-west-1","''","}",">",">",">","sink","=","KinesisStreamsSink.builder","(",")","\\","...",".set_kinesis_client_properties","(","sink_properties",")","\\","...",".set_stream_name","(","``","your_stream_name","''",")","\\","...",".set_serialization_schema","(","SimpleStringSchema","(",")",")","\\","...",".set_partition_key_generator","(","PartitionKeyGenerator.random","(",")",")","\\","...",".build","(",")","If","the","following","parameters","are","not","set","in","this","builder",",","the","following","defaults","will","be","used",":","-","maxBatchSize","will","be","500","-","maxInFlightRequests","will","be","50","-","maxBufferedRequests","will","be","10000","-","maxBatchSizeInBytes","will","be","5","MB","i.e",".","5","*","1024","*","1024","-","maxTimeInBufferMS","will","be","5000ms","-","maxRecordSizeInBytes","will","be","1","MB","i.e",".","1","*","1024","*","1024","-","failOnError","will","be","false"]
docstr: The maximum buffer length. Callbacks to add elements to the buffer and calls to write will
  block if this length has been reached and will only unblock if elements from the buffer have
  been removed for flushing.
docstr_tok: ["The","maximum","buffer","length",".","Callbacks","to","add","elements","to","the","buffer","and","calls","to","write","will","block","if","this","length","has","been","reached","and","will","only","unblock","if","elements","from","the","buffer","have","been","removed","for","flushing","."]
code: def set_max_buffered_requests(
      self, max_buffered_requests: int
  ) -> "KinesisStreamsSinkBuilder":
      """
      The maximum buffer length. Callbacks to add elements to the buffer and calls to write will
      block if this length has been reached and will only unblock if elements from the buffer have
      been removed for flushing.
      """
      self._j_kinesis_sink_builder.setMaxBufferedRequests(
          max_buffered_requests
      )
      return self
  
imports: from typing import Dict, Union, List
  from pyflink.common import SerializationSchema, DeserializationSchema, AssignerWithPeriodicWatermarksWrapper
  from pyflink.datastream.functions import SourceFunction
  from pyflink.datastream.connectors import Sink
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 9 for calling the KinesisStreamsSinkBuilder obj's underlying member method code with example usage: obj.set_max_buffered_requests(max_buffered_requests) and returns: self