code: def __init__(self, runtime_context, job_parameters):
      self._runtime_context = runtime_context
      self._job_parameters = job_parameters
      self._keyed_state_backend = None
  
imports: from pyflink.datastream import RuntimeContext
  from pyflink.datastream.state import AggregatingStateDescriptor, AggregatingState, ReducingStateDescriptor, ReducingState, MapStateDescriptor, MapState, ListStateDescriptor, ListState, ValueStateDescriptor, ValueState
  from pyflink.fn_execution.embedded.state_impl import KeyedStateBackend
  from pyflink.fn_execution.metrics.embedded.metric_impl import MetricGroupImpl
  from pyflink.metrics import MetricGroup
label_desc: Use image node_id 1 to create a new StreamingRuntimeContext object from inherited base classes: RuntimeContext with example: obj = StreamingRuntimeContext(runtime_context, job_parameters)