class_docstr: Utility to map Kinesis shards to Flink subtask indices. Users can provide a Java
  KinesisShardAssigner in Python if they want to provide custom shared assigner.
class_docstr_tok: ["Utility","to","map","Kinesis","shards","to","Flink","subtask","indices",".","Users","can","provide","a","Java","KinesisShardAssigner","in","Python","if","they","want","to","provide","custom","shared","assigner","."]
code: def __init__(self, j_kinesis_shard_assigner):
      self._j_kinesis_shard_assigner = j_kinesis_shard_assigner
  
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 KinesisShardAssigner object from inherited base classes: object with example: obj = KinesisShardAssigner(j_kinesis_shard_assigner)