Commit c7218046 by Dan Markwat

Fixed spelling error in AEntityBean

parent d8d9da29
package org.apache.hadoop.metadata.bridge; package org.apache.hadoop.metadata.bridge;
public abstract class AEnitityBean { public abstract class AEntityBean {
} }
...@@ -47,5 +47,10 @@ ...@@ -47,5 +47,10 @@
<groupId>commons-configuration</groupId> <groupId>commons-configuration</groupId>
<artifactId>commons-configuration</artifactId> <artifactId>commons-configuration</artifactId>
</dependency> </dependency>
<dependency>
<groupId>com.google.inject.extensions</groupId>
<artifactId>guice-multibindings</artifactId>
<version>3.0</version>
</dependency>
</dependencies> </dependencies>
</project> </project>
\ No newline at end of file
...@@ -26,13 +26,13 @@ import com.google.common.collect.ImmutableList; ...@@ -26,13 +26,13 @@ import com.google.common.collect.ImmutableList;
public abstract class ABridge implements IBridge { public abstract class ABridge implements IBridge {
protected ArrayList<Class<? extends AEnitityBean>> typeBeanClasses = new ArrayList<Class<? extends AEnitityBean>>(); protected ArrayList<Class<? extends AEntityBean>> typeBeanClasses = new ArrayList<Class<? extends AEntityBean>>();
MetadataRepository repo; MetadataRepository repo;
protected static final Logger LOG = BridgeManager.LOG; protected static final Logger LOG = BridgeManager.LOG;
protected HierarchicalTypeDefinition<ClassType> createClassTypeDef(String name, ImmutableList<String> superTypes, AttributeDefinition... attrDefs) {return new HierarchicalTypeDefinition(ClassType.class, name, superTypes, attrDefs);} protected HierarchicalTypeDefinition<ClassType> createClassTypeDef(String name, ImmutableList<String> superTypes, AttributeDefinition... attrDefs) {return new HierarchicalTypeDefinition(ClassType.class, name, superTypes, attrDefs);}
public ArrayList<Class<? extends AEnitityBean>> getTypeBeanClasses() { public ArrayList<Class<? extends AEntityBean>> getTypeBeanClasses() {
return typeBeanClasses; return typeBeanClasses;
} }
...@@ -41,12 +41,12 @@ public abstract class ABridge implements IBridge { ...@@ -41,12 +41,12 @@ public abstract class ABridge implements IBridge {
this.repo = repo; this.repo = repo;
} }
public AEnitityBean get(String id) throws RepositoryException { public AEntityBean get(String id) throws RepositoryException {
// get from the system by id (?) // get from the system by id (?)
ITypedReferenceableInstance ref = repo.getEntityDefinition(id); ITypedReferenceableInstance ref = repo.getEntityDefinition(id);
// turn into a HiveLineageBean // turn into a HiveLineageBean
try { try {
Class<AEnitityBean> c = getTypeBeanInListByName(ref.getTypeName()); Class<AEntityBean> c = getTypeBeanInListByName(ref.getTypeName());
return this.convertFromITypedReferenceable(ref, getTypeBeanInListByName(ref.getTypeName())); return this.convertFromITypedReferenceable(ref, getTypeBeanInListByName(ref.getTypeName()));
} catch (BridgeException | InstantiationException | IllegalAccessException | IllegalArgumentException | InvocationTargetException | NoSuchMethodException | SecurityException e) { } catch (BridgeException | InstantiationException | IllegalAccessException | IllegalArgumentException | InvocationTargetException | NoSuchMethodException | SecurityException e) {
// TODO Auto-generated catch block // TODO Auto-generated catch block
...@@ -55,7 +55,7 @@ public abstract class ABridge implements IBridge { ...@@ -55,7 +55,7 @@ public abstract class ABridge implements IBridge {
return null; return null;
} }
public String create(AEnitityBean bean) throws MetadataException { public String create(AEntityBean bean) throws MetadataException {
ClassType type = TypeSystem.getInstance().getDataType(ClassType.class, bean.getClass().getSimpleName()); ClassType type = TypeSystem.getInstance().getDataType(ClassType.class, bean.getClass().getSimpleName());
ITypedReferenceableInstance refBean = null; ITypedReferenceableInstance refBean = null;
...@@ -90,7 +90,7 @@ public abstract class ABridge implements IBridge { ...@@ -90,7 +90,7 @@ public abstract class ABridge implements IBridge {
return false; return false;
} }
protected final Class<AEnitityBean> getTypeBeanInListByName(String s) throws BridgeException{ protected final Class<AEntityBean> getTypeBeanInListByName(String s) throws BridgeException{
if (containsType(s)){ if (containsType(s)){
for (Class c: typeBeanClasses){ for (Class c: typeBeanClasses){
if (c.getSimpleName().equals(s)){ if (c.getSimpleName().equals(s)){
...@@ -103,7 +103,7 @@ public abstract class ABridge implements IBridge { ...@@ -103,7 +103,7 @@ public abstract class ABridge implements IBridge {
throw new BridgeException("No EntityBean Definition Found"); throw new BridgeException("No EntityBean Definition Found");
} }
protected final <T extends AEnitityBean> Referenceable convertToReferencable(T o ) throws IllegalArgumentException, IllegalAccessException{ protected final <T extends AEntityBean> Referenceable convertToReferencable(T o ) throws IllegalArgumentException, IllegalAccessException{
Referenceable selfAware = new Referenceable(o.getClass().getSimpleName()); Referenceable selfAware = new Referenceable(o.getClass().getSimpleName());
for(Field f : o.getClass().getFields()){ for(Field f : o.getClass().getFields()){
selfAware.set(f.getName(), f.get(o)); selfAware.set(f.getName(), f.get(o));
...@@ -111,7 +111,7 @@ public abstract class ABridge implements IBridge { ...@@ -111,7 +111,7 @@ public abstract class ABridge implements IBridge {
return selfAware; return selfAware;
} }
protected final <T extends AEnitityBean>T convertFromITypedReferenceable(ITypedReferenceableInstance instance, Class<? extends AEnitityBean> c) throws InstantiationException, IllegalAccessException, IllegalArgumentException, InvocationTargetException, NoSuchMethodException, SecurityException, BridgeException{ protected final <T extends AEntityBean>T convertFromITypedReferenceable(ITypedReferenceableInstance instance, Class<? extends AEntityBean> c) throws InstantiationException, IllegalAccessException, IllegalArgumentException, InvocationTargetException, NoSuchMethodException, SecurityException, BridgeException{
if(!instance.getTypeName().equals(c.getSimpleName())){ if(!instance.getTypeName().equals(c.getSimpleName())){
throw new BridgeException("ReferenceableInstance type not the same as bean"); throw new BridgeException("ReferenceableInstance type not the same as bean");
} }
......
...@@ -94,7 +94,7 @@ public class BridgeManager { ...@@ -94,7 +94,7 @@ public class BridgeManager {
} }
private final boolean loadTypes(ABridge bridge, TypeSystem ts) throws MetadataException{ private final boolean loadTypes(ABridge bridge, TypeSystem ts) throws MetadataException{
for (Class<? extends AEnitityBean> clazz : bridge.getTypeBeanClasses()){ for (Class<? extends AEntityBean> clazz : bridge.getTypeBeanClasses()){
ts.defineClassType(BridgeManager.convertEntityBeanToClassTypeDefinition(clazz)); ts.defineClassType(BridgeManager.convertEntityBeanToClassTypeDefinition(clazz));
} }
return false; return false;
...@@ -102,7 +102,7 @@ public class BridgeManager { ...@@ -102,7 +102,7 @@ public class BridgeManager {
} }
public final static HierarchicalTypeDefinition<ClassType> convertEntityBeanToClassTypeDefinition(Class<? extends AEnitityBean> class1){ public final static HierarchicalTypeDefinition<ClassType> convertEntityBeanToClassTypeDefinition(Class<? extends AEntityBean> class1){
ArrayList<AttributeDefinition> attDefAL = new ArrayList<AttributeDefinition>(); ArrayList<AttributeDefinition> attDefAL = new ArrayList<AttributeDefinition>();
for (Field f: class1.getFields()){ for (Field f: class1.getFields()){
try { try {
......
...@@ -9,7 +9,7 @@ import org.apache.hadoop.metadata.repository.MetadataRepository; ...@@ -9,7 +9,7 @@ import org.apache.hadoop.metadata.repository.MetadataRepository;
public class HiveLineageBridge extends ABridge { public class HiveLineageBridge extends ABridge {
@Inject @Inject
public HiveLineageBridge(MetadataRepository mr) { HiveLineageBridge(MetadataRepository mr) {
super(mr); super(mr);
this.typeBeanClasses.add(HiveLineage.class); this.typeBeanClasses.add(HiveLineage.class);
} }
......
...@@ -5,9 +5,9 @@ import java.io.Serializable; ...@@ -5,9 +5,9 @@ import java.io.Serializable;
import java.util.List; import java.util.List;
import java.util.ArrayList; import java.util.ArrayList;
import org.apache.hadoop.metadata.bridge.AEnitityBean; import org.apache.hadoop.metadata.bridge.AEntityBean;
public class HiveLineage extends AEnitityBean implements Serializable { public class HiveLineage extends AEntityBean implements Serializable {
/** /**
* *
......
...@@ -4,9 +4,9 @@ import java.io.Serializable; ...@@ -4,9 +4,9 @@ import java.io.Serializable;
import java.util.List; import java.util.List;
import java.util.ArrayList; import java.util.ArrayList;
import org.apache.hadoop.metadata.bridge.AEnitityBean; import org.apache.hadoop.metadata.bridge.AEntityBean;
public class HiveLineage extends AEnitityBean implements Serializable { public class HiveLineage extends AEntityBean implements Serializable {
/** /**
* *
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment