class_docstr: Builder to construct KinesisFirehoseSink.
  
  The following example shows the minimum setup to create a KinesisFirehoseSink that writes
  String values to a Kinesis Data Firehose delivery stream named delivery-stream-name.
  
  Example:
  ::
  
      >>> from pyflink.common.serialization import SimpleStringSchema
      >>> sink_properties = {"aws.region": "eu-west-1"}
      >>> sink = KinesisFirehoseSink.builder() \
      ...     .set_firehose_client_properties(sink_properties) \
      ...     .set_delivery_stream_name("delivery-stream-name") \
      ...     .set_serialization_schema(SimpleStringSchema()) \
      ...     .set_max_batch_size(20) \
      ...     .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 4 MB i.e. 4 * 1024 * 1024
  - maxTimeInBufferMS will be 5000ms
  - maxRecordSizeInBytes will be 1000 KB i.e. 1000 * 1024
  - failOnError will be false
class_docstr_tok: ["Builder","to","construct","KinesisFirehoseSink",".","The","following","example","shows","the","minimum","setup","to","create","a","KinesisFirehoseSink","that","writes","String","values","to","a","Kinesis","Data","Firehose","delivery","stream","named","delivery-stream-name",".","Example",":",":",":",">",">",">","from","pyflink.common.serialization","import","SimpleStringSchema",">",">",">","sink_properties","=","{","``","aws.region","''",":","``","eu-west-1","''","}",">",">",">","sink","=","KinesisFirehoseSink.builder","(",")","\\","...",".set_firehose_client_properties","(","sink_properties",")","\\","...",".set_delivery_stream_name","(","``","delivery-stream-name","''",")","\\","...",".set_serialization_schema","(","SimpleStringSchema","(",")",")","\\","...",".set_max_batch_size","(","20",")","\\","...",".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","4","MB","i.e",".","4","*","1024","*","1024","-","maxTimeInBufferMS","will","be","5000ms","-","maxRecordSizeInBytes","will","be","1000","KB","i.e",".","1000","*","1024","-","failOnError","will","be","false"]
docstr: Maximum number of uncompleted calls to submitRequestEntries that the SinkWriter will allow
  at any given point. Once this point has reached, writes and callbacks to add elements to
  the buffer may block until one or more requests to submitRequestEntries completes.
docstr_tok: ["Maximum","number","of","uncompleted","calls","to","submitRequestEntries","that","the","SinkWriter","will","allow","at","any","given","point",".","Once","this","point","has","reached",",","writes","and","callbacks","to","add","elements","to","the","buffer","may","block","until","one","or","more","requests","to","submitRequestEntries","completes","."]
code: def set_max_in_flight_requests(
      self, max_in_flight_requests: int
  ) -> "KinesisFirehoseSinkBuilder":
      """
      Maximum number of uncompleted calls to submitRequestEntries that the SinkWriter will allow
      at any given point. Once this point has reached, writes and callbacks to add elements to
      the buffer may block until one or more requests to submitRequestEntries completes.
      """
      self._j_kinesis_sink_builder.setMaxInFlightRequests(
          max_in_flight_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 7 for calling the KinesisFirehoseSinkBuilder obj's underlying member method code with example usage: obj.set_max_in_flight_requests(max_in_flight_requests) and returns: self