Java ORM pour Hbase

La force de HBase que je vois c'est dans le maintien de la dynamique des colonnes statiques des familles de la colonne. À partir de mon expérience dans le développement d'applications avec HBase, je trouve que c'est pas aussi facile que de SQL pour déterminer la cellule de qualification et des valeurs.

Par exemple, dans un livre, comme de nombreux auteurs, en fonction de vos profils d'accès, l'auteur édite, l'application de la couche de cache de la mise en œuvre, vous pouvez choisir d'enregistrer ensemble de l'auteur dans le livre de la table (qui est l'auteur réside dans le tableau 2, l'auteur de la table et de la table des livres) ou tout simplement l'id de l'auteur. De plus, la collection de l'auteur peut être sauvegardée dans une cellule au format XML/JSON ou des cellules individuelles pour chacun des auteurs.

Avec cette compréhension, j'ai conclu par écrit un véritable ORM comme Hibernate ne sera pas seulement être très difficile n'est pas concluante. J'ai donc pris une approche différente, beaucoup plus comme iBatis est à Hiberner.

• Mon mini-cadre: http://github.com/smart-it/smart-dao [smart-hbase]
• Utilisation: https://github.com/smart-it/smart-cms [contenu-spi-impl module a les usages]
• Utilisation: https://github.com/smart-it/jetty-session-hbase [hbase-impl module a les usages]

Laissez-moi vous expliquer comment il fonctionne. Pour cela, je vais utiliser les codes source de ici et ici.

1. Et avant la première tâche est de mettre en œuvre un ObjectRowConverter interface, dans ce cas SessionDataObjectConverter. La classe abstraite encapsule de base, les meilleures pratiques tel que discuté et appris de la HBase de la communauté. L'extension vous donne essentiellement à 100% de contrôle sur la façon de convertir votre objet de HBase ligne et vice-versa. Pour cette seule restriction à partir de l'API, c'est que vos objets de domaine doit implémenter l'interface PersistentDTO qui est utilisé en interne pour créer Put, Delete, ne byte[] à l'id de l'objet et vice-versa.
2. Prochaine tâche est de câbler les dépendances comme le fait le HBaseImplModule. S'il vous plaît laissez-moi savoir si vous êtes intéressé, je vais passer par la dépendance des injections.

Et c'est tout. Comment sont-ils utilisés sont disponibles ici. Il utilise essentiellement des CommonReadDao, CommonWriteDao pour lire et écrire des données vers et à partir de HBase. La commune de lire dao met en œuvre multithread ligne d'objet de conversion sur les requêtes, multithread obtenir par id, obtenir par id et a sa mise en veille prolongée Critères tels que l'API de requête pour HBase par Scan (pas de fonctions d'agrégation disponibles). Commune écrire dao met en œuvre commune écrire le code associé avec des installations, telles que les optimistes/pessimistes de verrouillage, la cellule de remplacer/fusion de vérification de l'entité (non)-existence sur enregistrer, mettre à jour, supprimer etc.

Ce ORM a été développé à des fins internes de but et j'ai été jusqu'à mon cou et, partant, ne peuvent pas encore faire partie de la documentation. Mais si vous êtes intéressé faites le moi savoir et je sera prendre le temps pour la documentation en priorité.

Comment sur datanucleus: vous pouvez utiliser JPA ou JDO que votre API et hbase comme le backend magasin: http://www.datanucleus.org/plugins/store.hbase.html

Il est pigi et parhely et je n'ai usé d'aucun d'eux. OMI HBase est rapide magasin de clé/valeur du moteur, mais si vous avez besoin d'une autre couche d'abstraction, vous devriez les vérifier.