class_docstr: A Kinesis Data Firehose (KDF) Sink that performs async requests against a destination delivery
  stream using the buffering protocol.
class_docstr_tok: ["A","Kinesis","Data","Firehose","(","KDF",")","Sink","that","performs","async","requests","against","a","destination","delivery","stream","using","the","buffering","protocol","."]
code: def __init__(self, j_kinesis_firehose_sink):
      super(KinesisFirehoseSink, self).__init__(
          sink=j_kinesis_firehose_sink
      )
  
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 KinesisFirehoseSink object from inherited base classes: Sink with example: obj = KinesisFirehoseSink(j_kinesis_firehose_sink)