DirectWriteHBaseStore.java 文件源码

@Override
public PersistentEObject apply(Id id) {
    PersistentEObject object;
    EClass eClass = DirectWriteHBaseStore.this.resolveInstanceOf(id);
    if (nonNull(eClass)) {
        EObject eObject;
        if (Objects.equals(eClass.getEPackage().getClass(), EPackageImpl.class)) {
            // Dynamic EMF
            eObject = PersistenceFactory.getInstance().create(eClass);
        }
        else {
            eObject = EcoreUtil.create(eClass);
        }
        object = PersistentEObject.from(eObject);
        object.id(id);
        object.setMapped(true);
    }
    else {
        throw new RuntimeException("Element " + id + " does not have an associated EClass");
    }
    return object;
}