Modified defailt implementation of applicationId

avulanov · Sep 29, 2014 · 2cdd009 · 2cdd009
1 parent 9aadb0b
commit 2cdd009
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/core/src/main/java/org/apache/spark/ApplicationId.java b/core/src/main/java/org/apache/spark/ApplicationId.java
@@ -52,4 +52,18 @@ public int hashCode() {
   public String toString() {
     return appId;
   }
+
+
+  private static ApplicationId defaultAppId =
+    new ApplicationId(String.valueOf(System.currentTimeMillis()));
+
+  /**
+   *  Default implementation of Application Id
+   *
+   *  @return Default implementation of Application id based on System.currentTimeMillis
+   */
+  public static ApplicationId getApplicationId() {
+    return defaultAppId;
+  }
+
 }