Fixed runtime issues

cangencer · Feb 6, 2018 · cfeb68a · cfeb68a
1 parent 88c3972
commit cfeb68a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/flight-telemetry/pom.xml b/flight-telemetry/pom.xml
@@ -32,7 +32,7 @@
                     </descriptorRefs>
                     <archive>
                         <manifest>
-                            <mainClass>com.hazelcast.jet.demo.Demo</mainClass>
+                            <mainClass>com.hazelcast.jet.demo.FlightTelemetry</mainClass>
                         </manifest>
                     </archive>
                 </configuration>
@@ -51,7 +51,7 @@
                 <artifactId>exec-maven-plugin</artifactId>
                 <version>1.6.0</version>
                 <configuration>
-                    <mainClass>com.hazelcast.jet.demo.Demo</mainClass>
+                    <mainClass>com.hazelcast.jet.demo.FlightTelemetry</mainClass>
                 </configuration>
             </plugin>
         </plugins>

diff --git a/flight-telemetry/src/main/java/com/hazelcast/jet/demo/FlightTelemetry.java b/flight-telemetry/src/main/java/com/hazelcast/jet/demo/FlightTelemetry.java
@@ -150,7 +150,7 @@ private static DAG buildDAG() {
                 (Aircraft ac) -> !ac.isGnd() && ac.getAlt() > 0 && ac.getAlt() < 3000)
         ).localParallelism(1);
 
-        Vertex assignAirport = dag.newVertex("assignAirport", mapP(Demo::assignAirport)).localParallelism(1);
+        Vertex assignAirport = dag.newVertex("assignAirport", mapP(FlightTelemetry::assignAirport)).localParallelism(1);
 
         WindowDefinition wDefTrend = WindowDefinition.slidingWindowDef(60_000, 30_000);
         DistributedSupplier<Processor> insertWMP = insertWatermarksP(wmGenParams(
@@ -173,7 +173,7 @@ private static DAG buildDAG() {
                 allOf(toList(), linearTrend(Aircraft::getPosTime, Aircraft::getAlt))
         ));
 
-        Vertex addVerticalDirection = dag.newVertex("addVerticalDirection", mapP(Demo::assignDirection));
+        Vertex addVerticalDirection = dag.newVertex("addVerticalDirection", mapP(FlightTelemetry::assignDirection));
 
         Vertex filterAscending = dag.newVertex("filterAscending", filterP(
                 (Entry<Long, Aircraft> e) -> e.getValue().verticalDirection == ASCENDING));