public class oadd.org.apache.drill.exec.coord.zk.EventDispatcher extends java.lang.Object implements oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheListener
{
public static final java.util.Map MAPPINGS;
private final oadd.org.apache.drill.exec.coord.zk.ZkEphemeralStore store;
protected void <init>(oadd.org.apache.drill.exec.coord.zk.ZkEphemeralStore)
{
oadd.org.apache.drill.exec.coord.zk.ZkEphemeralStore v;
java.lang.Object v;
oadd.org.apache.drill.exec.coord.zk.EventDispatcher v;
v := @this: oadd.org.apache.drill.exec.coord.zk.EventDispatcher;
v := @parameter: oadd.org.apache.drill.exec.coord.zk.ZkEphemeralStore;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: java.lang.Object checkNotNull(java.lang.Object,java.lang.Object)>(v, "store is required");
v.<oadd.org.apache.drill.exec.coord.zk.EventDispatcher: oadd.org.apache.drill.exec.coord.zk.ZkEphemeralStore store> = v;
return;
}
public void childEvent(oadd.org.apache.curator.framework.CuratorFramework, oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent) throws java.lang.Exception
{
byte[] v;
oadd.org.apache.curator.framework.recipes.cache.ChildData v, v;
oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent v;
oadd.org.apache.drill.exec.serialization.InstanceSerializer v;
java.util.Map v;
java.lang.String v;
oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type v;
oadd.org.apache.drill.exec.coord.store.TransientStoreEvent v;
oadd.org.apache.curator.framework.CuratorFramework v;
oadd.org.apache.drill.exec.coord.zk.ZkEphemeralStore v, v;
oadd.org.apache.drill.exec.coord.store.TransientStoreConfig v;
java.lang.Object v, v;
oadd.org.apache.drill.exec.coord.zk.EventDispatcher v;
v := @this: oadd.org.apache.drill.exec.coord.zk.EventDispatcher;
v := @parameter: oadd.org.apache.curator.framework.CuratorFramework;
v := @parameter: oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent: oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type getType()>();
v = <oadd.org.apache.drill.exec.coord.zk.EventDispatcher: java.util.Map MAPPINGS>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent: oadd.org.apache.curator.framework.recipes.cache.ChildData getData()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.ChildData: java.lang.String getPath()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent: oadd.org.apache.curator.framework.recipes.cache.ChildData getData()>();
v = virtualinvoke v.<oadd.org.apache.curator.framework.recipes.cache.ChildData: byte[] getData()>();
v = v.<oadd.org.apache.drill.exec.coord.zk.EventDispatcher: oadd.org.apache.drill.exec.coord.zk.ZkEphemeralStore store>;
v = virtualinvoke v.<oadd.org.apache.drill.exec.coord.zk.ZkEphemeralStore: oadd.org.apache.drill.exec.coord.store.TransientStoreConfig getConfig()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.coord.store.TransientStoreConfig: oadd.org.apache.drill.exec.serialization.InstanceSerializer getSerializer()>();
v = interfaceinvoke v.<oadd.org.apache.drill.exec.serialization.InstanceSerializer: java.lang.Object deserialize(byte[])>(v);
v = v.<oadd.org.apache.drill.exec.coord.zk.EventDispatcher: oadd.org.apache.drill.exec.coord.zk.ZkEphemeralStore store>;
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.zk.ZkEphemeralStore: void fireListeners(oadd.org.apache.drill.exec.coord.store.TransientStoreEvent)>(v);
label:
return;
}
static void <clinit>()
{
oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type v, v, v;
oadd.org.apache.drill.exec.coord.store.TransientStoreEventType v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder builder()>();
v = <oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type: oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type CHILD_ADDED>;
v = <oadd.org.apache.drill.exec.coord.store.TransientStoreEventType: oadd.org.apache.drill.exec.coord.store.TransientStoreEventType CREATE>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = <oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type: oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type CHILD_REMOVED>;
v = <oadd.org.apache.drill.exec.coord.store.TransientStoreEventType: oadd.org.apache.drill.exec.coord.store.TransientStoreEventType DELETE>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = <oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type: oadd.org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent$Type CHILD_UPDATED>;
v = <oadd.org.apache.drill.exec.coord.store.TransientStoreEventType: oadd.org.apache.drill.exec.coord.store.TransientStoreEventType UPDATE>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap build()>();
<oadd.org.apache.drill.exec.coord.zk.EventDispatcher: java.util.Map MAPPINGS> = v;
return;
}
}