Package org.springframework.data.hadoop.test.context

Examples of org.springframework.data.hadoop.test.context.HadoopCluster.start()

44
45
46
47
48
49
50
51
52
53
54
  @Test
  public void testOneStandalone() throws Exception {
    HadoopClusterManager manager = HadoopClusterManager.getInstance();
    HadoopCluster cluster = manager.getCluster(new ClusterInfo());
    cluster.start();

    Configuration configuration = cluster.getConfiguration();
    assertThat(getHdfsUrl(configuration), startsWith("hdfs"));

    // these are not yet created
View Full Code Here
66
67
68
69
70
71
72
73
74
75
76
  public void testTwoStandalone() throws Exception {
    HadoopClusterManager manager = HadoopClusterManager.getInstance();
    HadoopCluster cluster1 = manager.getCluster(new ClusterInfo("def", 1));
    HadoopCluster cluster2 = manager.getCluster(new ClusterInfo("def", 2));
    cluster1.start();
    cluster2.start();
    Configuration configuration1 = cluster1.getConfiguration();
    Configuration configuration2 = cluster2.getConfiguration();
    assertThat(getHdfsUrl(configuration1), startsWith("hdfs"));
    assertThat(getHdfsUrl(configuration2), startsWith("hdfs"));
View Full Code Here
100
101
102
103
104
105
106
107
108
109
110
  public void testTwoEquals() throws Exception {
    HadoopClusterManager manager = HadoopClusterManager.getInstance();
    HadoopCluster cluster1 = manager.getCluster(new ClusterInfo("def", 1));
    HadoopCluster cluster2 = manager.getCluster(new ClusterInfo("def", 1));
    cluster1.start();
    cluster2.start();
    Configuration configuration1 = cluster1.getConfiguration();
    Configuration configuration2 = cluster2.getConfiguration();
    assertThat(getHdfsUrl(configuration1), startsWith("hdfs"));
    assertThat(getHdfsUrl(configuration2), startsWith("hdfs"));
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.