public class oadd.org.apache.drill.exec.coord.local.MapBackedStore extends oadd.org.apache.drill.exec.coord.store.BaseTransientStore
{
private final java.util.concurrent.ConcurrentMap delegate;
public void <init>(oadd.org.apache.drill.exec.coord.store.TransientStoreConfig)
{
oadd.org.apache.drill.exec.coord.local.MapBackedStore v;
oadd.org.apache.drill.exec.coord.store.TransientStoreConfig v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.drill.exec.coord.local.MapBackedStore;
v := @parameter: oadd.org.apache.drill.exec.coord.store.TransientStoreConfig;
specialinvoke v.<oadd.org.apache.drill.exec.coord.store.BaseTransientStore: void <init>(oadd.org.apache.drill.exec.coord.store.TransientStoreConfig)>(v);
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Maps: java.util.concurrent.ConcurrentMap newConcurrentMap()>();
v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: java.util.concurrent.ConcurrentMap delegate> = v;
return;
}
public java.lang.Object get(java.lang.String)
{
oadd.org.apache.drill.exec.coord.local.MapBackedStore v;
java.lang.Object v;
java.lang.String v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.drill.exec.coord.local.MapBackedStore;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: java.util.concurrent.ConcurrentMap delegate>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public java.lang.Object put(java.lang.String, java.lang.Object)
{
oadd.org.apache.drill.exec.coord.store.TransientStoreEventType v;
oadd.org.apache.drill.exec.coord.store.TransientStoreEvent v;
java.util.concurrent.ConcurrentMap v, v;
oadd.org.apache.drill.exec.coord.local.MapBackedStore v;
java.lang.Object v, v;
java.lang.String v;
boolean v;
v := @this: oadd.org.apache.drill.exec.coord.local.MapBackedStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v = v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: java.util.concurrent.ConcurrentMap delegate>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: boolean containsKey(java.lang.Object)>(v);
v = v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: java.util.concurrent.ConcurrentMap delegate>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
if v == v goto label;
if v == 0 goto label;
v = <oadd.org.apache.drill.exec.coord.store.TransientStoreEventType: oadd.org.apache.drill.exec.coord.store.TransientStoreEventType UPDATE>;
goto label;
label:
v = <oadd.org.apache.drill.exec.coord.store.TransientStoreEventType: oadd.org.apache.drill.exec.coord.store.TransientStoreEventType CREATE>;
label:
v = staticinvoke <oadd.org.apache.drill.exec.coord.store.TransientStoreEvent: oadd.org.apache.drill.exec.coord.store.TransientStoreEvent of(oadd.org.apache.drill.exec.coord.store.TransientStoreEventType,java.lang.String,java.lang.Object)>(v, v, v);
virtualinvoke v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: void fireListeners(oadd.org.apache.drill.exec.coord.store.TransientStoreEvent)>(v);
label:
return v;
}
public java.lang.Object putIfAbsent(java.lang.String, java.lang.Object)
{
oadd.org.apache.drill.exec.coord.store.TransientStoreEventType v;
oadd.org.apache.drill.exec.coord.local.MapBackedStore v;
oadd.org.apache.drill.exec.coord.store.TransientStoreEvent v;
java.lang.Object v, v;
java.lang.String v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.drill.exec.coord.local.MapBackedStore;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object;
v = v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: java.util.concurrent.ConcurrentMap delegate>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object putIfAbsent(java.lang.Object,java.lang.Object)>(v, v);
if v != null goto label;
v = <oadd.org.apache.drill.exec.coord.store.TransientStoreEventType: oadd.org.apache.drill.exec.coord.store.TransientStoreEventType CREATE>;
v = staticinvoke <oadd.org.apache.drill.exec.coord.store.TransientStoreEvent: oadd.org.apache.drill.exec.coord.store.TransientStoreEvent of(oadd.org.apache.drill.exec.coord.store.TransientStoreEventType,java.lang.String,java.lang.Object)>(v, v, v);
virtualinvoke v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: void fireListeners(oadd.org.apache.drill.exec.coord.store.TransientStoreEvent)>(v);
label:
return v;
}
public java.lang.Object remove(java.lang.String)
{
oadd.org.apache.drill.exec.coord.store.TransientStoreEventType v;
oadd.org.apache.drill.exec.coord.local.MapBackedStore v;
oadd.org.apache.drill.exec.coord.store.TransientStoreEvent v;
java.lang.Object v;
java.lang.String v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.drill.exec.coord.local.MapBackedStore;
v := @parameter: java.lang.String;
v = v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: java.util.concurrent.ConcurrentMap delegate>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v == null goto label;
v = <oadd.org.apache.drill.exec.coord.store.TransientStoreEventType: oadd.org.apache.drill.exec.coord.store.TransientStoreEventType DELETE>;
v = staticinvoke <oadd.org.apache.drill.exec.coord.store.TransientStoreEvent: oadd.org.apache.drill.exec.coord.store.TransientStoreEvent of(oadd.org.apache.drill.exec.coord.store.TransientStoreEventType,java.lang.String,java.lang.Object)>(v, v, v);
virtualinvoke v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: void fireListeners(oadd.org.apache.drill.exec.coord.store.TransientStoreEvent)>(v);
label:
return v;
}
public java.util.Iterator entries()
{
java.util.Iterator v;
java.util.Set v;
oadd.org.apache.drill.exec.coord.local.MapBackedStore v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.drill.exec.coord.local.MapBackedStore;
v = v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: java.util.concurrent.ConcurrentMap delegate>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
return v;
}
public int size()
{
int v;
oadd.org.apache.drill.exec.coord.local.MapBackedStore v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.drill.exec.coord.local.MapBackedStore;
v = v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: java.util.concurrent.ConcurrentMap delegate>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: int size()>();
return v;
}
public void close() throws java.lang.Exception
{
oadd.org.apache.drill.exec.coord.local.MapBackedStore v;
java.util.concurrent.ConcurrentMap v;
v := @this: oadd.org.apache.drill.exec.coord.local.MapBackedStore;
v = v.<oadd.org.apache.drill.exec.coord.local.MapBackedStore: java.util.concurrent.ConcurrentMap delegate>;
interfaceinvoke v.<java.util.concurrent.ConcurrentMap: void clear()>();
return;
}
}