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"]
code: def __init__(self):
      JKinesisStreamsSink = (
          get_gateway().jvm.org.apache.flink.connector.kinesis.sink.KinesisStreamsSink
      )
      self._j_kinesis_sink_builder = JKinesisStreamsSink.builder()
  
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 1 to create a new KinesisStreamsSinkBuilder object from inherited base classes: object with example: obj = KinesisStreamsSinkBuilder()