class org.apache.hadoop.hive.kafka.KafkaStorageHandler$3 extends java.lang.Object implements org.apache.hadoop.hive.kafka.RetryUtils$CleanupAfterFailure
{
final java.util.Map val$producersMap;
final org.apache.hadoop.hive.kafka.KafkaStorageHandler this$0;
void <init>(org.apache.hadoop.hive.kafka.KafkaStorageHandler, java.util.Map)
{
org.apache.hadoop.hive.kafka.KafkaStorageHandler v;
org.apache.hadoop.hive.kafka.KafkaStorageHandler$3 v;
java.util.Map v;
v := @this: org.apache.hadoop.hive.kafka.KafkaStorageHandler$3;
v := @parameter: org.apache.hadoop.hive.kafka.KafkaStorageHandler;
v := @parameter: java.util.Map;
v.<org.apache.hadoop.hive.kafka.KafkaStorageHandler$3: org.apache.hadoop.hive.kafka.KafkaStorageHandler this$0> = v;
v.<org.apache.hadoop.hive.kafka.KafkaStorageHandler$3: java.util.Map val$producersMap> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void cleanup()
{
java.util.Map v, v;
java.util.function.BiConsumer v;
org.apache.hadoop.hive.kafka.KafkaStorageHandler$3 v;
v := @this: org.apache.hadoop.hive.kafka.KafkaStorageHandler$3;
v = v.<org.apache.hadoop.hive.kafka.KafkaStorageHandler$3: java.util.Map val$producersMap>;
v = staticinvoke <org.apache.hadoop.hive.kafka.KafkaStorageHandler$3$lambda_cleanup_0__38: java.util.function.BiConsumer bootstrap$()>();
interfaceinvoke v.<java.util.Map: void forEach(java.util.function.BiConsumer)>(v);
v = v.<org.apache.hadoop.hive.kafka.KafkaStorageHandler$3: java.util.Map val$producersMap>;
interfaceinvoke v.<java.util.Map: void clear()>();
return;
}
}