D-Net

{"type_source": "SVN", "goal": "package -U -T 4C source:jar", "url": "http://svn-public.driver.research-infrastructures.eu/driver/dnet40/modules/dnet-hadoop-service-rmi/trunk/", "deploy_repository": "dnet4-snapshots", "version": "4", "mail": "sandro.labruzzo@isti.cnr.it,michele.artini@isti.cnr.it, claudio.atzori@isti.cnr.it, alessia.bardi@isti.cnr.it", "deploy_repository_url": "http://maven.research-infrastructures.eu/nexus/content/repositories/dnet4-snapshots", "name": "dnet-hadoop-service-rmi"}

package eu.dnetlib.data.hadoop.rmi.hbase.schema;

import java.io.IOException;

import java.io.InputStream;

import org.apache.commons.io.IOUtils;

import org.junit.Test;

import static org.junit.Assert.assertFalse;

import static org.junit.Assert.assertNotNull;

/**

 * Created by claudio on 11/11/15.

 */

public class HBaseTableDescriptorTest {

	@Test

	public void testSerialise() throws IOException {

		final InputStream is = getClass().getResourceAsStream("hbaseTable.json");

		final String json = IOUtils.toString(is);

		final HBaseTableDescriptor desc = HBaseTableDescriptor.fromJSON(json);

		assertNotNull(desc);

		assertNotNull(desc.getColumns());

		assertNotNull(desc.getRegions());

		assertFalse(desc.getColumns().isEmpty());

		assertFalse(desc.getRegions().isEmpty());

		System.out.println(desc.toString());

	}

}

package eu.dnetlib.data.hadoop.rmi.hbase;

import java.util.List;

import com.google.common.collect.Lists;

import org.junit.Test;

import static org.junit.Assert.assertEquals;

/**

 * Created by claudio on 23/10/15.

 */

public class HBaseRowDescriptorTest {

	@Test

	public void testSerialisation() {

		HBaseRowDescriptor d1 = new HBaseRowDescriptor();

		d1.setRowKey("k1");

		d1.getColumns().add(new Column("c1", l("q1", "q2")));

		d1.getColumns().add(new Column("c2", l("q1", "q2")));

		final String d1s = d1.toString();

		System.out.println(d1s);

		final HBaseRowDescriptor d2 = HBaseRowDescriptor.fromJSON(d1s);

		assertEquals(d1.toString(), d2.toString());

	}

	private List<String> l(String... s) {

		return Lists.newArrayList(s);

	}

}

{

  "columns": [

	"result",

	"resultProject_outcome_isProducedBy",

	"person",

	"resultResult_similarity_hasAmongTopNSimilarDocuments",

	"resultResult_dedup_merges",

	"organizationOrganization_dedup_merges",

	"projectPerson_contactPerson_isContact",

	"personPerson_dedup_merges",

	"personPerson_coauthorship_isCoauthorOf",

	"personResult_authorship_hasAuthor",

	"organization",

	"resultProject_outcome_produces",

	"resultResult_similarity_isAmongTopNSimilarDocuments",

	"datasourceOrganization_provision_provides",

	"resultOrganization_affiliation_isAffiliatedWith",

	"organizationOrganization_dedupSimilarity_isSimilarTo",

	"datasource",

	"personPerson_dedupSimilarity_isSimilarTo",

	"resultResult_publicationDataset_isRelatedTo",

	"organizationOrganization_dedup_isMergedIn",

	"projectOrganization_participation_hasParticipant",

	"projectOrganization_participation_isParticipant",

	"project",

	"personResult_authorship_isAuthorOf",

	"resultResult_dedup_isMergedIn",

	"personPerson_dedup_isMergedIn",

	"projectPerson_contactPerson_hasContact",

	"datasourceOrganization_provision_isProvidedBy",

	"resultResult_dedupSimilarity_isSimilarTo"

  ],

  "regions": [

	{

	  "startKey": "",

	  "endKey": "30|dedup_wf_001::01f6ec93ba93d5dee29436e446a19cff"

	},

	{

	  "startKey": "30|dedup_wf_001::01f6ec93ba93d5dee29436e446a19cff",

	  "endKey": "30|dedup_wf_001::06cdeeae3ffe195d2d346c8f969d3733"

	},

	{

	  "startKey": "30|dedup_wf_001::06cdeeae3ffe195d2d346c8f969d3733",

	  "endKey": "30|dedup_wf_001::0f9e3af0a62c397f5c79b3040e4fc2cb"

	},

	{

	  "startKey": "30|dedup_wf_001::0f9e3af0a62c397f5c79b3040e4fc2cb",

	  "endKey": "30|dedup_wf_001::18037d1fc2e9f4766074b31ba355622c"

	},

	{

	  "startKey": "30|dedup_wf_001::18037d1fc2e9f4766074b31ba355622c",

	  "endKey": "30|dedup_wf_001::1fb797d8e394bb01ac35a662dde2b0f8"

	},

	{

	  "startKey": "30|dedup_wf_001::1fb797d8e394bb01ac35a662dde2b0f8",

	  "endKey": "30|dedup_wf_001::268b0ae37189c8dadb8f13ab0606c97f"

	},

	{

	  "startKey": "30|dedup_wf_001::268b0ae37189c8dadb8f13ab0606c97f",

	  "endKey": "30|dedup_wf_001::30ca5b71cafc2f5f1b9e863469e532d5"

	},

	{

	  "startKey": "30|dedup_wf_001::30ca5b71cafc2f5f1b9e863469e532d5",

	  "endKey": "30|dedup_wf_001::3c06a9d133ac0a6bc811eec8328c977e"

	},

	{

	  "startKey": "30|dedup_wf_001::3c06a9d133ac0a6bc811eec8328c977e",

	  "endKey": "30|dedup_wf_001::44befcc568dbe380106b7f6fe9ef8307"

	},

	{

	  "startKey": "30|dedup_wf_001::44befcc568dbe380106b7f6fe9ef8307",

	  "endKey": "30|dedup_wf_001::4da577deebb7d8b2c18874b1e715a482"

	},

	{

	  "startKey": "30|dedup_wf_001::4da577deebb7d8b2c18874b1e715a482",

	  "endKey": "30|dedup_wf_001::563c55f0830ce083e4c410b1f4f59c55"

	},

	{

	  "startKey": "30|dedup_wf_001::563c55f0830ce083e4c410b1f4f59c55",

	  "endKey": "30|dedup_wf_001::636f3edbe11558886c4ba24c5c09ea89"

	},

	{

	  "startKey": "30|dedup_wf_001::636f3edbe11558886c4ba24c5c09ea89",

	  "endKey": "30|dedup_wf_001::6dd9d6802123c6063b4ce706a8748624"

	},

	{

	  "startKey": "30|dedup_wf_001::6dd9d6802123c6063b4ce706a8748624",

	  "endKey": "30|dedup_wf_001::76b663bd033d59e1b17f37cc8b0a80d8"

	},

	{

	  "startKey": "30|dedup_wf_001::76b663bd033d59e1b17f37cc8b0a80d8",

	  "endKey": "30|dedup_wf_001::7f056a7b3d7410087f317d6630c526d3"

	},

	{

	  "startKey": "30|dedup_wf_001::7f056a7b3d7410087f317d6630c526d3",

	  "endKey": "30|dedup_wf_001::8b80a91fc8c4045ceb650a22b495c18e"

	},

	{

	  "startKey": "30|dedup_wf_001::8b80a91fc8c4045ceb650a22b495c18e",

	  "endKey": "30|dedup_wf_001::964cad44b7c717bc9b6166a329b2c19f"

	},

	{

	  "startKey": "30|dedup_wf_001::964cad44b7c717bc9b6166a329b2c19f",

	  "endKey": "30|dedup_wf_001::a05a81f85cbd08f4ef8ea424ab1f6c2d"

	},

	{

	  "startKey": "30|dedup_wf_001::a05a81f85cbd08f4ef8ea424ab1f6c2d",

	  "endKey": "30|dedup_wf_001::aa24cb2a368b4775b39c0d2d524959d3"

	},

	{

	  "startKey": "30|dedup_wf_001::aa24cb2a368b4775b39c0d2d524959d3",

	  "endKey": "30|dedup_wf_001::b99149295238e372c7a41f30480600a7"

	},

	{

	  "startKey": "30|dedup_wf_001::b99149295238e372c7a41f30480600a7",

	  "endKey": "30|dedup_wf_001::c6e679f5bade940987bf3ab69e76cf8c"

	},

	{

	  "startKey": "30|dedup_wf_001::c6e679f5bade940987bf3ab69e76cf8c",

	  "endKey": "30|dedup_wf_001::d377cfadcd3799b5c509addc4a99c3bb"

	},

	{

	  "startKey": "30|dedup_wf_001::d377cfadcd3799b5c509addc4a99c3bb",

	  "endKey": "30|dedup_wf_001::e10b99fb6d1f8698077ca9b4cfb701b9"

	},

	{

	  "startKey": "30|dedup_wf_001::e10b99fb6d1f8698077ca9b4cfb701b9",

	  "endKey": "30|dedup_wf_001::ed0fff7f00ee9b2101836c95e9e09d23"

	},

	{

	  "startKey": "30|dedup_wf_001::ed0fff7f00ee9b2101836c95e9e09d23",

	  "endKey": "30|dedup_wf_001::f7a73e3a03a09a10ee7f7697122f0681"

	},

	{

	  "startKey": "30|dedup_wf_001::f7a73e3a03a09a10ee7f7697122f0681",

	  "endKey": "30|doajarticles::0fdd94fa342532f903b50e88a99e10bd"

	},

	{

	  "startKey": "30|doajarticles::0fdd94fa342532f903b50e88a99e10bd",

	  "endKey": "30|doajarticles::451d3a1643b5be43f4ae2a34cdd27937"

	},

	{

	  "startKey": "30|doajarticles::451d3a1643b5be43f4ae2a34cdd27937",

	  "endKey": "30|doajarticles::71a1fc746b5365f574e3156747f18745"

	},

	{

	  "startKey": "30|doajarticles::71a1fc746b5365f574e3156747f18745",

	  "endKey": "30|doajarticles::98b1fe3e237757b6eb4de63baafd1923"

	},

	{

	  "startKey": "30|doajarticles::98b1fe3e237757b6eb4de63baafd1923",

	  "endKey": "30|doajarticles::c67bbcd47b4be3ac87dd57dee962f75b"

	},

	{

	  "startKey": "30|doajarticles::c67bbcd47b4be3ac87dd57dee962f75b",

	  "endKey": "30|doajarticles::f34078dfbfb6474825db277fa83b393b"

	},

	{

	  "startKey": "30|doajarticles::f34078dfbfb6474825db277fa83b393b",

	  "endKey": "30|frontiers___::977250f5038a72ca8903dd0caa49d375"

	},

	{

	  "startKey": "30|frontiers___::977250f5038a72ca8903dd0caa49d375",

	  "endKey": "30|od______1064::1892eb3502552398aafbcc80ec822556"

	},

	{

	  "startKey": "30|od______1064::1892eb3502552398aafbcc80ec822556",

	  "endKey": "30|od______1064::4c7dc52ff8927d3a4d3097ddfa6affa0"

	},

	{

	  "startKey": "30|od______1064::4c7dc52ff8927d3a4d3097ddfa6affa0",

	  "endKey": "30|od______1064::77f5c1d6ee91c1e278148a135315a0b2"

	},

	{

	  "startKey": "30|od______1064::77f5c1d6ee91c1e278148a135315a0b2",

	  "endKey": "30|od______1064::a50d37c3bf2951b531c7fb1911c4fe5b"

	},

	{

	  "startKey": "30|od______1064::a50d37c3bf2951b531c7fb1911c4fe5b",

	  "endKey": "30|od______1064::d281738255d0caf028e142d83bb23194"

	},

	{

	  "startKey": "30|od______1064::d281738255d0caf028e142d83bb23194",

	  "endKey": "30|od______1106::41f8c3d8d5acef5d0c00fe7c187ca808"

	},

	{

	  "startKey": "30|od______1106::41f8c3d8d5acef5d0c00fe7c187ca808",

	  "endKey": "30|od______1222::32ef3ea6510baca180965a9ee42cdfb1"

	},

	{

	  "startKey": "30|od______1222::32ef3ea6510baca180965a9ee42cdfb1",

	  "endKey": "30|od______1412::25f6b55fd946f8b2a81747a8c5202dc7"

	},

	{

	  "startKey": "30|od______1412::25f6b55fd946f8b2a81747a8c5202dc7",

	  "endKey": "30|od______2001::246e27b8c42ee8e0580958eedc79e28b"

	},

	{

	  "startKey": "30|od______2001::246e27b8c42ee8e0580958eedc79e28b",

	  "endKey": "30|od______3061::fae9705d71631c06b9e6b36d14f81661"

	},

	{

	  "startKey": "30|od______3061::fae9705d71631c06b9e6b36d14f81661",

	  "endKey": "30|od_______165::194583341339bd02e9e02422926bf630"

	},

	{

	  "startKey": "30|od_______165::194583341339bd02e9e02422926bf630",

	  "endKey": "30|od_______165::9b47f3c8f28ce97d32350389104f9899"

	},

	{

	  "startKey": "30|od_______165::9b47f3c8f28ce97d32350389104f9899",

	  "endKey": "30|od_______185::453155023cbb2afeca98b640d6594a08"

	},

	{

	  "startKey": "30|od_______185::453155023cbb2afeca98b640d6594a08",

	  "endKey": "30|od_______322::84120a66fff81cd34cbc8cbef3edd715"

	},

	{

	  "startKey": "30|od_______322::84120a66fff81cd34cbc8cbef3edd715",

	  "endKey": "30|od_______484::2a821095a78aa2b2ad82d73b2c5ad62a"

	},

	{

	  "startKey": "30|od_______484::2a821095a78aa2b2ad82d73b2c5ad62a",

	  "endKey": "30|od_______603::0b7b6c2731fb1fc372ef59e1cc2faf63"

	},

	{

	  "startKey": "30|od_______603::0b7b6c2731fb1fc372ef59e1cc2faf63",

	  "endKey": "30|od_______908::09d20b1f39dfc14eb45acd5dda8d4a21"

	},

	{

	  "startKey": "30|od_______908::09d20b1f39dfc14eb45acd5dda8d4a21",

	  "endKey": "30|od_______908::2087f4d03e16fae94512220255a3cd1d"

	},

	{

	  "startKey": "30|od_______908::2087f4d03e16fae94512220255a3cd1d",

	  "endKey": "30|od_______908::31abbab96ceda6e60d5dccd140f58e3c"

	},

	{

	  "startKey": "30|od_______908::31abbab96ceda6e60d5dccd140f58e3c",

	  "endKey": "30|od_______908::45ddf56ad9ee5360bf1a1a191b3baeb8"

	},

	{

	  "startKey": "30|od_______908::45ddf56ad9ee5360bf1a1a191b3baeb8",

	  "endKey": "30|od_______908::5b6b219395b454fb0bd8a394c5070912"

	},

	{

	  "startKey": "30|od_______908::5b6b219395b454fb0bd8a394c5070912",

	  "endKey": "30|od_______908::6bd349faba19949050732b44b6269abb"

	},

	{

	  "startKey": "30|od_______908::6bd349faba19949050732b44b6269abb",

	  "endKey": "30|od_______908::7f53ececb9bb91daec9e2a9eaa7bbc4c"

	},

	{

	  "startKey": "30|od_______908::7f53ececb9bb91daec9e2a9eaa7bbc4c",

	  "endKey": "30|od_______908::8ed6cd6e2bbdeb9025948accab37b26f"

	},

	{

	  "startKey": "30|od_______908::8ed6cd6e2bbdeb9025948accab37b26f",

	  "endKey": "30|od_______908::a1d2f2e7212b3f7bbe6cdabc668c7769"

	},

	{

	  "startKey": "30|od_______908::a1d2f2e7212b3f7bbe6cdabc668c7769",

	  "endKey": "30|od_______908::b683f5a3b98b03154b8a5150d036eaba"

	},

	{

	  "startKey": "30|od_______908::b683f5a3b98b03154b8a5150d036eaba",

	  "endKey": "30|od_______908::cc0e85209e37d16b0be196dc3d173c8a"

	},

	{

	  "startKey": "30|od_______908::cc0e85209e37d16b0be196dc3d173c8a",

	  "endKey": "30|od_______908::dd2df143167b3b9040eb58436a22378d"

	},

	{

	  "startKey": "30|od_______908::dd2df143167b3b9040eb58436a22378d",

	  "endKey": "30|od_______908::f10a377825e517763a631a8e3cae6468"

	},

	{

	  "startKey": "30|od_______908::f10a377825e517763a631a8e3cae6468",

	  "endKey": "30|od_______961::b2172ece477c3b2bb379c41a70f2a729"

	},

	{

	  "startKey": "30|od_______961::b2172ece477c3b2bb379c41a70f2a729",

	  "endKey": "30|od________18::25b7030f6520a8c34f9c0f9c1bafb001"

	},

	{

	  "startKey": "30|od________18::25b7030f6520a8c34f9c0f9c1bafb001",

	  "endKey": "30|od________18::70f2be65de065ff0ae060b9fcf431c1d"

	},

	{

	  "startKey": "30|od________18::70f2be65de065ff0ae060b9fcf431c1d",

	  "endKey": "30|od________18::bf3e05da5f0bf7d0931e0b6f30924b33"

	},

	{

	  "startKey": "30|od________18::bf3e05da5f0bf7d0931e0b6f30924b33",

	  "endKey": "50|dedup_wf_001::02034127aa0e85feaa5f73e673c7c0d7"

	},

	{

	  "startKey": "50|dedup_wf_001::02034127aa0e85feaa5f73e673c7c0d7",

	  "endKey": "50|dedup_wf_001::0c6d39819631cb0049875aaa0e3f1fdc"

	},

	{

	  "startKey": "50|dedup_wf_001::0c6d39819631cb0049875aaa0e3f1fdc",

	  "endKey": "50|dedup_wf_001::16c764873dd9cd30039cfa6eafb66633"

	},

	{

	  "startKey": "50|dedup_wf_001::16c764873dd9cd30039cfa6eafb66633",

	  "endKey": "50|dedup_wf_001::2256f1d993f2e2dc3ee261a3221e9898"

	},

	{

	  "startKey": "50|dedup_wf_001::2256f1d993f2e2dc3ee261a3221e9898",

	  "endKey": "50|dedup_wf_001::2f20fc3902b09c13cb611556f88b6051"

	},

	{

	  "startKey": "50|dedup_wf_001::2f20fc3902b09c13cb611556f88b6051",

	  "endKey": "50|dedup_wf_001::3d120775a140a00e3265ebde52b47118"

	},

	{

	  "startKey": "50|dedup_wf_001::3d120775a140a00e3265ebde52b47118",

	  "endKey": "50|dedup_wf_001::4bc418b1fe54e4fa2a05629a06dd3a4c"

	},

	{

	  "startKey": "50|dedup_wf_001::4bc418b1fe54e4fa2a05629a06dd3a4c",

	  "endKey": "50|dedup_wf_001::5c6a6cce61901445bef19011e7a9cdd3"

	},

	{

	  "startKey": "50|dedup_wf_001::5c6a6cce61901445bef19011e7a9cdd3",

	  "endKey": "50|dedup_wf_001::6cccee8a482edd160d8b32500d210451"

	},

	{

	  "startKey": "50|dedup_wf_001::6cccee8a482edd160d8b32500d210451",

	  "endKey": "50|dedup_wf_001::7f03900f6f068d95d144cca696eada9d"

	},

	{

	  "startKey": "50|dedup_wf_001::7f03900f6f068d95d144cca696eada9d",

	  "endKey": "50|dedup_wf_001::93700a5d375511cb40b86026850c0c04"

	},

	{

	  "startKey": "50|dedup_wf_001::93700a5d375511cb40b86026850c0c04",

	  "endKey": "50|dedup_wf_001::a91b3388333d2ce8543f6d18e9230184"

	},

	{

	  "startKey": "50|dedup_wf_001::a91b3388333d2ce8543f6d18e9230184",

	  "endKey": "50|dedup_wf_001::b5692a63f5561061fdf347d442c125c9"

	},

	{

	  "startKey": "50|dedup_wf_001::b5692a63f5561061fdf347d442c125c9",

	  "endKey": "50|dedup_wf_001::c23ccd4da7d56c6042ad153d101e3b4a"

	},

	{

	  "startKey": "50|dedup_wf_001::c23ccd4da7d56c6042ad153d101e3b4a",

	  "endKey": "50|dedup_wf_001::d9bd4adea34900b74b1083e0aa973d14"

	},

	{

	  "startKey": "50|dedup_wf_001::d9bd4adea34900b74b1083e0aa973d14",

	  "endKey": "50|dedup_wf_001::f3df01ae80f7ee559e45c682740526f6"

	},

	{

	  "startKey": "50|dedup_wf_001::f3df01ae80f7ee559e45c682740526f6",

	  "endKey": "50|doajarticles::114db5b70d6bb92281c0a48a3cdeab90"

	},

	{

	  "startKey": "50|doajarticles::114db5b70d6bb92281c0a48a3cdeab90",

	  "endKey": "50|doajarticles::308e70820d5eb34b379a27f44cec58eb"

	},

	{

	  "startKey": "50|doajarticles::308e70820d5eb34b379a27f44cec58eb",

	  "endKey": "50|doajarticles::52da1a571f4a5c558d4041f86d57a740"

	},

	{

	  "startKey": "50|doajarticles::52da1a571f4a5c558d4041f86d57a740",

	  "endKey": "50|doajarticles::70bb02eee5d62a2b0155934753b3d55b"

	},

	{

	  "startKey": "50|doajarticles::70bb02eee5d62a2b0155934753b3d55b",

	  "endKey": "50|doajarticles::90e46c2630de99bf901b6f9d5ccff508"

	},

	{

	  "startKey": "50|doajarticles::90e46c2630de99bf901b6f9d5ccff508",

	  "endKey": "50|doajarticles::b01eb463260993ab479ae998f29bcf7c"

	},

	{

	  "startKey": "50|doajarticles::b01eb463260993ab479ae998f29bcf7c",

	  "endKey": "50|doajarticles::cba7f3680eab0417b1f0c93a0319ba64"

	},

	{

	  "startKey": "50|doajarticles::cba7f3680eab0417b1f0c93a0319ba64",

	  "endKey": "50|doajarticles::e76f01bc97e39d5e220452928b0f01c0"

	},

	{

	  "startKey": "50|doajarticles::e76f01bc97e39d5e220452928b0f01c0",

	  "endKey": "50|fp7_env_____::55381a5c6aa3147c4b105ab4f1f341a6"

	},

	{

	  "startKey": "50|fp7_env_____::55381a5c6aa3147c4b105ab4f1f341a6",

	  "endKey": "50|od______1064::0db8b9d3d5b726dd486715a201819fe0"

	},

	{

	  "startKey": "50|od______1064::0db8b9d3d5b726dd486715a201819fe0",

	  "endKey": "50|od______1064::4135d9b247a3d7c2af4bec1360ef77ff"

	},

	{

	  "startKey": "50|od______1064::4135d9b247a3d7c2af4bec1360ef77ff",

	  "endKey": "50|od______1064::71cf5d71f20907e836a84b14085851fc"

	},

	{

	  "startKey": "50|od______1064::71cf5d71f20907e836a84b14085851fc",

	  "endKey": "50|od______1064::9b9c24d0e70c897be2b702184b4758fd"

	},

	{

	  "startKey": "50|od______1064::9b9c24d0e70c897be2b702184b4758fd",

	  "endKey": "50|od______1064::d4424e2a2d13074f01581de61395357d"

	},

	{

	  "startKey": "50|od______1064::d4424e2a2d13074f01581de61395357d",

	  "endKey": "50|od______1064::ffd165b7795b6a6386fa7a5b2eb56e18"

	},

	{

	  "startKey": "50|od______1064::ffd165b7795b6a6386fa7a5b2eb56e18",

	  "endKey": "50|od______1201::7a8d284e224d73834f7ff0415abb53a6"

	},

	{

	  "startKey": "50|od______1201::7a8d284e224d73834f7ff0415abb53a6",

	  "endKey": "50|od______1272::db9ab1802259f3aa3f37f982b7f2b130"

	},

	{

	  "startKey": "50|od______1272::db9ab1802259f3aa3f37f982b7f2b130",

	  "endKey": "50|od______1389::60314c89ce4de7fa72cfb2fdad10e1b7"

	},

	{

	  "startKey": "50|od______1389::60314c89ce4de7fa72cfb2fdad10e1b7",

	  "endKey": "50|od______1502::f9401983425dee941b3021b59ef606fc"

	},

	{

	  "startKey": "50|od______1502::f9401983425dee941b3021b59ef606fc",

	  "endKey": "50|od______1687::e5fc94cd56e8bf70c59e67e7871b6250"

	},

	{

	  "startKey": "50|od______1687::e5fc94cd56e8bf70c59e67e7871b6250",

	  "endKey": "50|od______2001::9d1cdaaa9fc6f5fcc7bc7b5c4e547ff4"

	},

	{

	  "startKey": "50|od______2001::9d1cdaaa9fc6f5fcc7bc7b5c4e547ff4",

	  "endKey": "50|od______3061::4173eaee46b73cd5f43d2417d54e4ebe"

	},

	{

	  "startKey": "50|od______3061::4173eaee46b73cd5f43d2417d54e4ebe",

	  "endKey": "50|od_______162::5336859ed82fab129bfffcd2d8bb9806"

	},

	{

	  "startKey": "50|od_______162::5336859ed82fab129bfffcd2d8bb9806",

	  "endKey": "50|od_______165::14a78f7d1f6a358122eb3348e9a2f8b2"

	},

	{

	  "startKey": "50|od_______165::14a78f7d1f6a358122eb3348e9a2f8b2",

	  "endKey": "50|od_______165::4a81f0ac988218c4805275db0809ee87"

	},

	{

	  "startKey": "50|od_______165::4a81f0ac988218c4805275db0809ee87",

	  "endKey": "50|od_______165::987fa6a514917d6d503087b85e205f7d"

	},

	{

	  "startKey": "50|od_______165::987fa6a514917d6d503087b85e205f7d",

	  "endKey": "50|od_______165::d63335b5b0d6d8acb92840c371fb02fe"

	},

	{

	  "startKey": "50|od_______165::d63335b5b0d6d8acb92840c371fb02fe",

	  "endKey": "50|od_______206::f300a704c38f523b3fcec2a2b282ee6e"

	},

	{

	  "startKey": "50|od_______206::f300a704c38f523b3fcec2a2b282ee6e",

	  "endKey": "50|od_______322::7c58d6a5d5a9cda35bacf1272834cb26"

	},

	{

	  "startKey": "50|od_______322::7c58d6a5d5a9cda35bacf1272834cb26",

	  "endKey": "50|od_______369::d6e7494e5141d30a56e2eebf7f5ee33d"

	},

	{

	  "startKey": "50|od_______369::d6e7494e5141d30a56e2eebf7f5ee33d",

	  "endKey": "50|od_______540::28c6e29fd1fbe925c74ef15f3462f83d"

	},

	{

	  "startKey": "50|od_______540::28c6e29fd1fbe925c74ef15f3462f83d",

	  "endKey": "50|od_______642::a62315284dad20594bf02b6705b1ff49"

	},

	{

	  "startKey": "50|od_______642::a62315284dad20594bf02b6705b1ff49",

	  "endKey": "50|od_______908::01bde75cb624a9f54558cfc630fab270"

	},

	{

	  "startKey": "50|od_______908::01bde75cb624a9f54558cfc630fab270",

	  "endKey": "50|od_______908::0ce7e68c6e1e3ec87e3837569a7164c5"

	},

	{

	  "startKey": "50|od_______908::0ce7e68c6e1e3ec87e3837569a7164c5",

	  "endKey": "50|od_______908::178c6c5809f3a7ac7789ff97cf7bdea6"

	},

	{

	  "startKey": "50|od_______908::178c6c5809f3a7ac7789ff97cf7bdea6",

	  "endKey": "50|od_______908::225596f36d88fc945720ae38026127be"

	},

	{

	  "startKey": "50|od_______908::225596f36d88fc945720ae38026127be",

	  "endKey": "50|od_______908::2f2a95b64aac1cf130bc5262840663cc"

	},

	{

	  "startKey": "50|od_______908::2f2a95b64aac1cf130bc5262840663cc",

	  "endKey": "50|od_______908::3cd3b7d891c22944507fa04dabffe014"

	},

	{

	  "startKey": "50|od_______908::3cd3b7d891c22944507fa04dabffe014",

	  "endKey": "50|od_______908::49829a5e128c0179d6a97705c8e62325"

	},

	{

	  "startKey": "50|od_______908::49829a5e128c0179d6a97705c8e62325",

	  "endKey": "50|od_______908::58e11440d1bd36196ce307b73a1ceb3f"

	},

	{

	  "startKey": "50|od_______908::58e11440d1bd36196ce307b73a1ceb3f",

	  "endKey": "50|od_______908::67cf9887d98ee7bd160a44f6bed53ae3"

	},

	{

	  "startKey": "50|od_______908::67cf9887d98ee7bd160a44f6bed53ae3",

	  "endKey": "50|od_______908::78c37e55717fca99a50b346427b93e73"

	},

	{

	  "startKey": "50|od_______908::78c37e55717fca99a50b346427b93e73",

	  "endKey": "50|od_______908::88dc399017a984de9e2272c8b67c3a37"

	},

	{

	  "startKey": "50|od_______908::88dc399017a984de9e2272c8b67c3a37",

	  "endKey": "50|od_______908::99c9b13da30b6de059089e1573e3e5d9"

	},

	{

	  "startKey": "50|od_______908::99c9b13da30b6de059089e1573e3e5d9",

	  "endKey": "50|od_______908::ab14999d98f71e580f169eff61bd0064"

	},

	{

	  "startKey": "50|od_______908::ab14999d98f71e580f169eff61bd0064",

	  "endKey": "50|od_______908::bf8f7155a5c180418e9d31815b2a8461"

	},

	{

	  "startKey": "50|od_______908::bf8f7155a5c180418e9d31815b2a8461",

	  "endKey": "50|od_______908::d0c3b0de981570db3c41d11bc015400c"

	},

	{

	  "startKey": "50|od_______908::d0c3b0de981570db3c41d11bc015400c",

	  "endKey": "50|od_______908::e33858348d1f218d7233b5b0ce2ab2f6"

	},

	{

	  "startKey": "50|od_______908::e33858348d1f218d7233b5b0ce2ab2f6",

	  "endKey": "50|od_______908::f669e13899aef0eca6d7c45e6cb3fcad"

	},

	{

	  "startKey": "50|od_______908::f669e13899aef0eca6d7c45e6cb3fcad",

	  "endKey": "50|od_______970::e7887b56b0cdab4759f0daaf482f8e77"

	},

	{

	  "startKey": "50|od_______970::e7887b56b0cdab4759f0daaf482f8e77",

	  "endKey": "50|od________18::29fcec61e938883d1edee2bd4b1b247e"

	},

	{

	  "startKey": "50|od________18::29fcec61e938883d1edee2bd4b1b247e",

	  "endKey": "50|od________18::56cc9edd064372e6f3f81e9576cac953"

	},

	{

	  "startKey": "50|od________18::56cc9edd064372e6f3f81e9576cac953",

	  "endKey": "50|od________18::879d332de7942af09ff782d3fbb757b0"

	},

	{

	  "startKey": "50|od________18::879d332de7942af09ff782d3fbb757b0",

	  "endKey": "50|od________18::b46caa47ef0cfd7bc38335c4143ff766"

	},

	{

	  "startKey": "50|od________18::b46caa47ef0cfd7bc38335c4143ff766",

	  "endKey": "50|od________18::deb18d84795807a91e4276c0eb146d03"

	},

	{

	  "startKey": "50|od________18::deb18d84795807a91e4276c0eb146d03",

	  "endKey": "50|od________18::fe9cea245af7bc693e39f349c163e051"

	},

	{

	  "startKey": "50|od________18::fe9cea245af7bc693e39f349c163e051",

	  "endKey": ""

	}

  ]

}

package eu.dnetlib.data.hadoop.rmi;

/**

 * Enum of the available HadoopBlackboardActions.

 */

public enum HadoopBlackboardActions {

	/** The submit mapreduce job. */

	SUBMIT_MAPREDUCE_JOB,

	/** The submit admin job. */

	SUBMIT_ADMIN_JOB,

	/** The kill job. */

	KILL_JOB,

	/** The submit oozie job. */

	SUBMIT_OOZIE_JOB,

	/** The import epr to hbase job. */

	IMPORT_EPR_HBASE,

	/** The delete epr from hbase job */

	DELETE_EPR_HBASE,

	/** The import epr to hdfs job */

	IMPORT_EPR_HDFS,

	/** The delete hdfs path. */

	DELETE_HDFS_PATH,

	/** The create hdfs directory. */

	CREATE_HDFS_DIR

}

package eu.dnetlib.data.hadoop.rmi.hbase.schema;

import java.util.List;

import java.util.Set;

import com.google.gson.Gson;

/**

 * Created by claudio on 11/11/15.

 */

public class HBaseTableDescriptor {

	private Set<String> columns;

	private List<HBaseTableRegionInfo> regions;

	public HBaseTableDescriptor() {

	}

	public HBaseTableDescriptor(final Set<String> columns, final List<HBaseTableRegionInfo> regions) {

		this.columns = columns;

		this.regions = regions;

	}

	public static HBaseTableDescriptor fromJSON(String json) {

		return new Gson().fromJson(json, HBaseTableDescriptor.class);

	}

	public Set<String> getColumns() {

		return columns;

	}

	public void setColumns(final Set<String> columns) {

		this.columns = columns;

	}

	public List<HBaseTableRegionInfo> getRegions() {

		return regions;

	}

	public void setRegions(final List<HBaseTableRegionInfo> regions) {

		this.regions = regions;

	}

	@Override

	public String toString() {

		return new Gson().toJson(this);

	}

}

package eu.dnetlib.data.hadoop.rmi.hbase.schema;

import com.google.gson.Gson;

/**

 * Created by claudio on 11/11/15.

 */

public class HBaseTableRegionInfo {

	private String startKey;

	private String endKey;

	public HBaseTableRegionInfo() {

	}

	public HBaseTableRegionInfo(final String startKey, final String endKey) {

		this.startKey = startKey;

		this.endKey = endKey;

	}

	public String getStartKey() {

		return startKey;

	}

	public void setStartKey(final String startKey) {

		this.startKey = startKey;

	}

	public String getEndKey() {

		return endKey;

	}

	public void setEndKey(final String endKey) {

		this.endKey = endKey;

	}

	@Override

	public String toString() {

		return new Gson().toJson(this);

	}

}

package eu.dnetlib.data.hadoop.rmi.hbase;

import java.util.List;

import javax.xml.bind.annotation.XmlRootElement;

import com.google.common.collect.Lists;

import com.google.gson.Gson;

/**

 * Created by claudio on 23/10/15.

 */

@XmlRootElement

public class HBaseRowDescriptor {

	private String rowKey;

	private List<Column> columns;

	public HBaseRowDescriptor() {

		columns = Lists.newArrayList();

	}

	public HBaseRowDescriptor(String rowKey, List<Column> columns) {

		this.rowKey = rowKey;

		this.columns = columns;

	}

	public static HBaseRowDescriptor fromJSON(String json) {

		return new Gson().fromJson(json, HBaseRowDescriptor.class);

	}

	public String getRowKey() {

		return rowKey;

	}

	public List<Column> getColumns() {

		return columns;

	}

	public void setRowKey(final String rowKey) {

		this.rowKey = rowKey;

	}

	public void setColumns(final List<Column> columns) {

		this.columns = columns;

	}

	@Override

	public String toString() {

		return new Gson().toJson(this);

	}

}

package eu.dnetlib.data.hadoop.rmi.hbase;

import java.util.List;

import javax.xml.bind.annotation.XmlRootElement;

import com.google.common.collect.Lists;

import com.google.gson.Gson;

/**

 * Created by claudio on 23/10/15.

 */

@XmlRootElement

public class Column {

	private String family;

	private List<String> qualifier;

	public Column() {

		this.qualifier = Lists.newArrayList();

	}

	public Column(final String family) {

		this.family = family;

		this.qualifier = Lists.newArrayList();

	}

	public Column(final String family, final List<String> qualifier) {

		this.family = family;

		this.qualifier = qualifier;

	}

	public String getFamily() {

		return family;

	}

	public void setFamily(final String family) {

		this.family = family;

	}

	public List<String> getQualifier() {

		return qualifier;

	}

	public void setQualifier(final List<String> qualifier) {

		this.qualifier = qualifier;

	}

	@Override

	public String toString() {

		return new Gson().toJson(this);

	}

}

package eu.dnetlib.data.hadoop.rmi;

import javax.xml.bind.annotation.XmlRootElement;

/**

 * <pre>

 * {@code

 * <hadoopJobDescriptor>

 * 	<jobName>ImportRecordsJob</jobName>

 * 	<jobDescription>map only job that maps xml metada records from a sequence file into an hbase table</jobDescription>

 * 	<id>abc</id>

 * 	<status>xyz</status>

 * </hadoopJobDescriptor>

 * }

 * </pre>

 * 

 * @author claudio

 */

@XmlRootElement

public class HadoopJobDescriptor {

	/** The id. */

	private String id;

	/** The job name. */

	private String jobName;

	/** The job description. */

	private String jobDescription;

	/** The status. */

	private String status;

	/** The start time. */

	private String startTime;

	/** The last activity. */

	private String lastActivity;

	/** The hadoop id. */

	private String hadoopId;

	/** The tracking url. */

	private String trackingUrl;

	/**

	 * Instantiates a new hadoop job descriptor.

	 */

	public HadoopJobDescriptor() {}

	/**

	 * Instantiates a new hadoop job descriptor.

	 * 

	 * @param jobName

	 *            the job name

	 * @param jobDescription

	 *            the job description

	 * @param id

	 *            the id

	 * @param status

	 *            the status

	 * @param startTime

	 *            the start time

	 * @param lastActivity

	 *            the last activity

	 * @param hadoopId

	 *            the hadoop id

	 * @param trackingUrl

	 *            the tracking url

	 */

	public HadoopJobDescriptor(final String jobName, final String jobDescription, final String id, final String status, final String startTime,

			final String lastActivity, final String hadoopId, final String trackingUrl) {

		super();

		this.id = id;

		this.jobName = jobName;

		this.jobDescription = jobDescription;

		this.status = status;

		this.startTime = startTime;

		this.lastActivity = lastActivity;

		this.hadoopId = hadoopId;

		this.trackingUrl = trackingUrl;

	}

	/**

	 * Gets the job name.

	 * 

	 * @return the job name

	 */

	public String getJobName() {

		return jobName;

	}

	/**

	 * Sets the job name.

	 * 

	 * @param jobName

	 *            the new job name

	 */

	public void setJobName(final String jobName) {

		this.jobName = jobName;

	}

	/**

	 * Gets the id.

	 * 

	 * @return the id

	 */

	public String getId() {

		return id;

	}

	/**

	 * Sets the id.

	 * 

	 * @param id

	 *            the new id

	 */

	public void setId(final String id) {

		this.id = id;

	}

	/**

	 * Gets the job description.

	 * 

	 * @return the job description

	 */

	public String getJobDescription() {

		return jobDescription;

	}

	/**

	 * Sets the job description.

	 * 

	 * @param jobDescription

	 *            the new job description

	 */

	public void setJobDescription(final String jobDescription) {

		this.jobDescription = jobDescription;

	}

	/**

	 * Gets the status.

	 * 

	 * @return the status

	 */

	public String getStatus() {

		return status;

	}

	/**

	 * Sets the status.

	 * 

	 * @param status

	 *            the new status

	 */

	public void setStatus(final String status) {

		this.status = status;

	}

	/**

	 * Gets the start time.

	 * 

	 * @return the start time

	 */

	public String getStartTime() {

		return startTime;

	}

	/**

	 * Sets the start time.

	 * 

	 * @param startTime

	 *            the new start time

	 */

	public void setStartTime(final String startTime) {

		this.startTime = startTime;

	}

	/**

	 * Gets the last activity.

	 * 

	 * @return the last activity

	 */

	public String getLastActivity() {

		return lastActivity;

	}

	/**

	 * Sets the last activity.

	 * 

	 * @param lastActivity

	 *            the new last activity

	 */

	public void setLastActivity(final String lastActivity) {

		this.lastActivity = lastActivity;

	}

	/**

	 * Gets the hadoop id.

	 * 

	 * @return the hadoop id

	 */

	public String getHadoopId() {

		return hadoopId;

	}

	/**

	 * Sets the hadoop id.

	 * 

	 * @param hadoopId

	 *            the new hadoop id

	 */

	public void setHadoopId(final String hadoopId) {

		this.hadoopId = hadoopId;

	}

	/**

	 * Gets the tracking url.

	 * 

	 * @return the tracking url

	 */

	public String getTrackingUrl() {

		return trackingUrl;

	}

	/**

	 * Sets the tracking url.

	 * 

	 * @param trackingUrl

	 *            the new tracking url

	 */

	public void setTrackingUrl(final String trackingUrl) {

		this.trackingUrl = trackingUrl;

	}

}

package eu.dnetlib.data.hadoop.rmi;

import java.util.Arrays;

import java.util.List;

import java.util.Set;

import com.google.common.base.Function;

import com.google.common.collect.Iterables;

import com.google.common.collect.Lists;

import com.google.common.collect.Sets;

/**

 * Enum of supported hadoop job types.

 *

 * @author claudio

 */

public enum HadoopJobType {

	/** The mapreduce. */

	mapreduce,

	/** The admin. */

	admin,

	/** The oozie. */

	oozie;

	/**

	 * The Enum AdminJobType.

	 */

	public enum AdminJobType {

		/**

		 * The copytable job.

		 *

		 * <pre>

		 * {@code

		 * bin/hbase org.apache.hadoop.hbase.mapreduce.CopyTable --starttime=1265875194289 --endtime=1265878794289

		 * --peer.adr=server1,server2,server3:2181:/hbase --families=myOldCf:myNewCf,cf2,cf3 TestTable <code>

		 * 

		 * Options:

		 * rs.class     hbase.regionserver.class of the peer cluster,

		 *              specify if different from current cluster

		 * rs.impl      hbase.regionserver.impl of the peer cluster,

		 * startrow     the start row

		 * stoprow      the stop row

		 * starttime    beginning of the time range (unixtime in millis)

		 *              without endtime means from starttime to forever

		 * endtime      end of the time range.  Ignored if no starttime specified.

		 * versions     number of cell versions to copy

		 * new.name     new table's name

		 * peer.adr     Address of the peer cluster given in the format

		 *              hbase.zookeeer.quorum:hbase.zookeeper.client.port:zookeeper.znode.parent

		 * families     comma-separated list of families to copy

		 *              To copy from cf1 to cf2, give sourceCfName:destCfName.

		 *              To keep the same name, just give "cfName"

		 * all.cells    also copy delete markers and deleted cells

		 * 

		 * Args:

		 * tablename    Name of the table to copy

		 * }

		 * </pre>

		 *

		 * */

		copytable;

		public static Set<String> asStringSet() {

			return Sets.newHashSet(asStringList());

		}

		public static List<String> asStringList() {

			return Lists.newArrayList(Iterables.transform(asList(), new Function<AdminJobType, String>() {

				@Override

				public String apply(final AdminJobType type) {

					return type.toString();

				}

			}));

		}

		public static List<AdminJobType> asList() {

			return Arrays.asList(AdminJobType.values());

		}

	}

}

package eu.dnetlib.data.hadoop.rmi;

import eu.dnetlib.common.rmi.RMIException;

/**

 * The Class HadoopServiceException.

 */

public class HadoopServiceException extends RMIException {

	/** The Constant serialVersionUID. */

	private static final long serialVersionUID = 7523999812098059764L;

	/**

	 * Instantiates a new hadoop service exception.

	 * 

	 * @param string

	 *            the string

	 */

	public HadoopServiceException(final String string) {

		super(string);

	}

	/**

	 * Instantiates a new hadoop service exception.

	 * 

	 * @param string

	 *            the string

	 * @param exception

	 *            the exception

	 */

	public HadoopServiceException(final String string, final Throwable exception) {

		super(string, exception);

	}

	/**

	 * Instantiates a new hadoop service exception.

	 * 

	 * @param exception

	 *            the exception

	 */

	public HadoopServiceException(final Throwable exception) {

		super(exception);

	}

}

package eu.dnetlib.data.hadoop.rmi;

import java.util.List;

import java.util.Map;

import java.util.Set;

import javax.jws.WebParam;

import javax.jws.WebService;

import eu.dnetlib.common.rmi.BaseService;

import eu.dnetlib.data.hadoop.rmi.hbase.HBaseRowDescriptor;

/**

 * The Interface HadoopService.

 */

@WebService(targetNamespace = "http://services.dnetlib.eu/")

public interface HadoopService extends BaseService {

	/**

	 * List available jobs.

	 *

	 * @return the list

	 * @throws HadoopServiceException the hadoop service exception

	 */

	List<String> listAvailableJobs() throws HadoopServiceException;

	/**

	 * List jobs.

	 *

	 * @param clusterName the cluster name

	 * @return the list

	 * @throws HadoopServiceException the hadoop service exception

	 */

	List<HadoopJobDescriptor> listJobs(@WebParam(name = "clusterName") String clusterName) throws HadoopServiceException;

	/**

	 * Kill job.

	 *

	 * @param jobId the job id

	 * @return true, if successful

	 * @throws HadoopServiceException the hadoop service exception

	 */

	boolean killJob(@WebParam(name = "id") String jobId) throws HadoopServiceException;

	/**

	 * List hbase tables.

	 *

	 * @param clusterName the cluster name

	 * @return the list

	 * @throws HadoopServiceException the hadoop service exception

	 */

	List<String> listHbaseTables(@WebParam(name = "clusterName") String clusterName) throws HadoopServiceException;

	/**

	 * Ensure hbase table.

	 *

	 * @param clusterName the cluster name

	 * @param tableName   the table name

	 * @param columns     the columns

	 * @return true, if successful

	 * @throws HadoopServiceException the hadoop service exception

	 */

	boolean ensureHbaseTable(@WebParam(name = "clusterName") String clusterName,

			@WebParam(name = "tableName") String tableName,

			@WebParam(name = "columns") Set<String> columns) throws HadoopServiceException;

	/**

	 * Creates the hbase table.

	 *

	 * @param clusterName the cluster name

	 * @param tableName   the table name

	 * @param columns     the columns

	 * @return true, if successful

	 * @throws HadoopServiceException the hadoop service exception

	 */

	boolean createHbaseTable(@WebParam(name = "clusterName") String clusterName,

			@WebParam(name = "tableName") String tableName,

			@WebParam(name = "columns") Set<String> columns) throws HadoopServiceException;

	/**

	 * Creates the hbase table.

	 *

	 * @param clusterName the cluster name

	 * @param tableName   the table name

	 * @param tableConfiguration     the table configuration: columns and region splits

	 * @return true, if successful

	 * @throws HadoopServiceException the hadoop service exception

	 */

	boolean createConfiguredHbaseTable(@WebParam(name = "clusterName") String clusterName,

			@WebParam(name = "tableName") String tableName,

			@WebParam(name = "tableConfiguration") String tableConfiguration) throws HadoopServiceException;

	/**

	 * Truncate hbase table.

	 *

	 * @param clusterName the cluster name

	 * @param tableName   the table name

	 * @return true, if successful

	 * @throws HadoopServiceException the hadoop service exception

	 */

	boolean truncateHbaseTable(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "tableName") String tableName)

			throws HadoopServiceException;

	/**

	 * Drop hbase table.

	 *

	 * @param clusterName the cluster name

	 * @param tableName   the table name

	 * @return true, if successful

	 * @throws HadoopServiceException the hadoop service exception

	 */

	boolean dropHbaseTable(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "tableName") String tableName) throws HadoopServiceException;

	/**

	 * Exist hbase table.

	 *

	 * @param clusterName the cluster name

	 * @param tableName   the table name

	 * @return true, if successful

	 * @throws HadoopServiceException the hadoop service exception

	 */

	boolean existHbaseTable(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "tableName") String tableName) throws HadoopServiceException;

	/**

	 * Describe hbase table.

	 *

	 * @param clusterName the cluster name

	 * @param tableName   the table name

	 * @return the list of columns defined for that table.

	 * @throws HadoopServiceException the hadoop service exception

	 */

	List<String> describeHbaseTable(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "tableName") String tableName)

			throws HadoopServiceException;

	/**

	 * Gets the cluster configuration.

	 *

	 * @param clusterName the cluster name

	 * @return the cluster configuration

	 * @throws HadoopServiceException the hadoop service exception

	 */

	Map<String, String> getClusterConfiguration(@WebParam(name = "clusterName") String clusterName) throws HadoopServiceException;

	/**

	 * Deletes a path on HDFS

	 *

	 * @param clusterName the cluster name

	 * @param path        the path to be deleted

	 * @return true in case of success

	 * @throws HadoopServiceException

	 */

	boolean deleteHdfsPath(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "path") String path)

			throws HadoopServiceException;

	/**

	 * Check if path on HDFS exists

	 *

	 * @param clusterName the cluster name

	 * @param path        the path to be deleted

	 * @return true in case the path exists

	 * @throws HadoopServiceException

	 */

	boolean existHdfsPath(@WebParam(name = "clusterName") String clusterName, @WebParam(name = "path") String path)

			throws HadoopServiceException;

	/**

	 * Creates a directory on HDFS, eventually deleteing its content.

	 *

	 * @param clusterName the cluster name

	 * @param path        the path to be created

	 * @param force       force delete before create

	 * @return true in case of success

	 * @throws HadoopServiceException

	 */

	boolean createHdfsDirectory(@WebParam(name = "clusterName") String clusterName,

			@WebParam(name = "path") String path,

			@WebParam(name = "force") boolean force)

			throws HadoopServiceException;

	/**

	 * List the configured cluster names.

	 *

	 * @return the list of configured cluster names.

	 * @throws HadoopServiceException shouldn't happen

	 */

	List<String> listClusters() throws HadoopServiceException;