Package backtype.storm

Examples of backtype.storm.LocalDRPC.execute()

75
76
77
78
79
80
81
82
83
84
85
      cluster.submitTopology(this.getClass().getSimpleName(), new Config(), toppology.build());

      Thread.sleep(10000);

      Integer result11 = extractPrediction(localDRPC.execute("predict", "1.0 1.0 1.0"));
      Integer result12 = extractPrediction(localDRPC.execute("predict", "0.8 1.1 0.9"));
      assertEquals(result11, result12);

      Integer result21 = extractPrediction(localDRPC.execute("predict", "1.0 -1.0 1.0"));
      Integer result22 = extractPrediction(localDRPC.execute("predict", "0.8 -1.1 0.9"));
      assertEquals(result21, result22);
View Full Code Here
78
79
80
81
82
83
84
85
86
87
88
      Integer result11 = extractPrediction(localDRPC.execute("predict", "1.0 1.0 1.0"));
      Integer result12 = extractPrediction(localDRPC.execute("predict", "0.8 1.1 0.9"));
      assertEquals(result11, result12);

      Integer result21 = extractPrediction(localDRPC.execute("predict", "1.0 -1.0 1.0"));
      Integer result22 = extractPrediction(localDRPC.execute("predict", "0.8 -1.1 0.9"));
      assertEquals(result21, result22);

      Integer result31 = extractPrediction(localDRPC.execute("predict", "1.0 -1.0 -1.0"));
      Integer result32 = extractPrediction(localDRPC.execute("predict", "0.8 -1.1 -0.9"));
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
      Integer result11 = extractPrediction(localDRPC.execute("predict", "1.0 1.0 1.0"));
      Integer result12 = extractPrediction(localDRPC.execute("predict", "0.8 1.1 0.9"));
      assertEquals(result11, result12);

      Integer result21 = extractPrediction(localDRPC.execute("predict", "1.0 -1.0 1.0"));
      Integer result22 = extractPrediction(localDRPC.execute("predict", "0.8 -1.1 0.9"));
      assertEquals(result21, result22);

      Integer result31 = extractPrediction(localDRPC.execute("predict", "1.0 -1.0 -1.0"));
      Integer result32 = extractPrediction(localDRPC.execute("predict", "0.8 -1.1 -0.9"));
      assertEquals(result31, result32);
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
      Integer result21 = extractPrediction(localDRPC.execute("predict", "1.0 -1.0 1.0"));
      Integer result22 = extractPrediction(localDRPC.execute("predict", "0.8 -1.1 0.9"));
      assertEquals(result21, result22);

      Integer result31 = extractPrediction(localDRPC.execute("predict", "1.0 -1.0 -1.0"));
      Integer result32 = extractPrediction(localDRPC.execute("predict", "0.8 -1.1 -0.9"));
      assertEquals(result31, result32);
    } finally {
      cluster.shutdown();
      localDRPC.shutdown();
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
      Integer result21 = extractPrediction(localDRPC.execute("predict", "1.0 -1.0 1.0"));
      Integer result22 = extractPrediction(localDRPC.execute("predict", "0.8 -1.1 0.9"));
      assertEquals(result21, result22);

      Integer result31 = extractPrediction(localDRPC.execute("predict", "1.0 -1.0 -1.0"));
      Integer result32 = extractPrediction(localDRPC.execute("predict", "0.8 -1.1 -0.9"));
      assertEquals(result31, result32);
    } finally {
      cluster.shutdown();
      localDRPC.shutdown();
    }
View Full Code Here
79
80
81
82
83
84
85
86
87
88
89
          .project(new Fields("eval"));

      cluster.submitTopology(this.getClass().getSimpleName(), new Config(), toppology.build());
      Thread.sleep(4000);

      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 0.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 1.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 0.0")));
      assertEquals(Boolean.FALSE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 1.0")));

      Double evaluation = extractEvaluation(localDRPC.execute("evaluate", ""));
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
      cluster.submitTopology(this.getClass().getSimpleName(), new Config(), toppology.build());
      Thread.sleep(4000);

      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 0.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 1.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 0.0")));
      assertEquals(Boolean.FALSE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 1.0")));

      Double evaluation = extractEvaluation(localDRPC.execute("evaluate", ""));
      assertTrue(evaluation > 0.9);
View Full Code Here
81
82
83
84
85
86
87
88
89
90
91
      cluster.submitTopology(this.getClass().getSimpleName(), new Config(), toppology.build());
      Thread.sleep(4000);

      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 0.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 1.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 0.0")));
      assertEquals(Boolean.FALSE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 1.0")));

      Double evaluation = extractEvaluation(localDRPC.execute("evaluate", ""));
      assertTrue(evaluation > 0.9);
      assertTrue(evaluation < 1);
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
      Thread.sleep(4000);

      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 0.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 1.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 0.0")));
      assertEquals(Boolean.FALSE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 1.0")));

      Double evaluation = extractEvaluation(localDRPC.execute("evaluate", ""));
      assertTrue(evaluation > 0.9);
      assertTrue(evaluation < 1);
    } finally {
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 0.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 0.0 1.0")));
      assertEquals(Boolean.TRUE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 0.0")));
      assertEquals(Boolean.FALSE, extractPrediction(localDRPC.execute("predict", "1.0 1.0 1.0")));

      Double evaluation = extractEvaluation(localDRPC.execute("evaluate", ""));
      assertTrue(evaluation > 0.9);
      assertTrue(evaluation < 1);
    } finally {
      cluster.shutdown();
      localDRPC.shutdown();
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.