IronCore Labs Scala Guide

This was forked from the Databricks Scala Guide ([email protected]:IronCoreLabs/scala-style-guide.git) and tweaked to fit our use at IronCore Labs.

Code is written once by its author, but read and modified multiple times by lots of other engineers. As most bugs actually come from future modification of the code, we need to optimize our codebase for long-term, global readability and maintainability. The best way to achieve this is to write simple code.

Scala is an incredibly powerful language that is capable of many paradigms. We have found that the following guidelines work well for us on projects with high velocity. Depending on the needs of your team, your mileage might vary.

Table of Contents

0. Document History
1. Syntactic Style - Formatting Code - Naming Convention - Line Length - Rule of 30 - Parentheses - Curly Braces - Long Literals - Documentation Style - Ordering within a Class - Imports - Pattern Matching - Infix Methods
2. Scala Language Features - apply Method - override Modifier - Destructuring Binds - Call by Name - Multiple Parameter Lists - Symbolic Methods (Operator Overloading) - Type Inference - Return Statements - Recursion and Tail Recursion - Implicits - Exception Handling, i.e. There is no Try, only / - Options - Monadic Chaining
3. Concurrency - Scala concurrent.Map - Explicit Synchronization vs Concurrent Collections - Explicit Synchronization vs Atomic Variables vs @volatile - Private Fields - Isolation
4. Performance - Microbenchmarks - Traversal and zipWithIndex - Option and null - Scala Collection Library - private[this]
5. Java Interoperability - Java Features Missing from Scala - Traits and Abstract Classes - Type Aliases - Default Parameter Values - Multiple Parameter Lists - Varargs - Implicits - Companion Objects, Static Methods and Fields
6. Miscellaneous - Prefer nanoTime over currentTimeMillis - Prefer URI over URL

Document History

• 2015-10-21: forked from DataBricks, initial modifications

Syntactic Style

Formatting Code

We use scalariform to format our Scala code, and our projects are set to auto-format on compile. Thus we don't have a lot of rules about spacing, indentation, and formatting. We let scalariform worry about that.

Naming Convention

We mostly follow Java's and Scala's standard naming conventions.

• Classes, traits, objects should follow Java class convention, i.e. CamelCase style with the first letter capitalized.

  class ClusterManager
  
  trait Expression

• Packages should follow Java package naming conventions, i.e. all-lowercase ASCII letters.

  package com.databricks.resourcemanager

• Methods/functions should be named in camelCase style.

• Constants should be all uppercase letters and be put in a companion object

  object Configuration {
    val DEFAULT_PORT = 10000
  }

• Enums should be CamelCase with first letter capitalized.

• Annotations should also follow Java convention, i.e. CamelCase with first letter capitalized. Note that this differs from Scala's official guide.

  final class MyAnnotation extends StaticAnnotation

Line Length

• Limit lines to 120 characters.
• The only exceptions are import statements and URLs (although even for those, try to keep them under 100 chars).

Rule of 30

"If an element consists of more than 30 subelements, it is highly probable that there is a serious problem" - Refactoring in Large Software Projects.

In general:

• A method should contain less than 30 lines of code.
• A class should contain less than 30 methods.

Parentheses

• Methods should be declared with parentheses, unless they are accessors that have no side-effect (state mutation, I/O operations are considered side-effects).

  class Job {
    // Wrong: killJob changes state. Should have ().
    def killJob: Unit
  
    // Correct:
    def killJob(): Unit
  }

• Callsite should follow method declaration, i.e. if a method is declared with parentheses, call with parentheses. Note that this is not just syntactic. It can affect correctness when apply is defined in the return object:

  class Foo {
    def apply(): Int
  }
  
  class Bar {
    def foo: Foo
  }
  
  new Bar().foo  // This returns a Foo
  new Bar().foo()  // This returns an Int!

Curly Braces

Put curly braces even around one-line conditional or loop statements. The only exception is if you are using if/else as an one-line ternary operator that is also side-effect free.

// Correct:
if (true) {
  println("Wow!")
}

// Correct:
if (true) statement1 else statement2

// Correct:
try {
  foo()
} catch {
  ...
}

// Wrong:
if (true)
  println("Wow!")

// Wrong:
try foo() catch {
  ...
}

Long Literals

Suffix long literal values with uppercase L. It is often hard to differentiate lowercase l from 1.

val longValue = 5432L  // Do this

val longValue = 5432l  // Do NOT do this

Documentation Style

Use Java docs style instead of Scala docs style.

/** This is a correct one-liner, short description. */

/**
 * This is a correct multi-line JavaDoc-style comment. And
 * this is my second line, and if I keep typing, this would be
 * my third line.
 *
 * NOTE: this DOES generate scaladoc, even though it is called
 * the JavaDco style. The difference is whether the text starts
 * on the same line as the start of the comment.
 */

/** We don't use the ScalaDoc style so this
  * is not correct.
  */

Ordering within a Class

A class should not be so long, with so many methods, that it requires elements to be grouped into different sections. If it is necessary to create a large class (such as a class supporting a public API, for some reason) and there are different logical sections, they should be moved into nested objects or separate classes.

Imports

• Avoid using wildcard imports, unless you are importing more than 6 entities, or implicit methods. Wildcard imports make the code less robust to external changes.
• Always import packages using absolute paths (e.g. scala.util.Random) instead of relative ones (e.g. util.Random).
• In addition, sort imports in the following order:
  • java.* and javax.*
  • scala.*
  • scalaz.*
  • Third-party libraries (org.*, com.*, etc)
  • Project classes (com.ironcorelabs.*)
• Within each group, imports should be sorted in alphabetic ordering, ignoring case. Note that _ sorts ahead of every character. For example,

  import scalaz.syntax.apply._
  import scalaz.syntax.std.option._
  import scalaz.syntax.validation._
  import scalaz.{ Validation, ValidationNel }
  import org.http4s._
  import org.http4s.dsl._
  import org.http4s.headers._
  import org.http4s.server._
  import org.http4s.server.blaze.BlazeBuilder

• Group imports of multiple entities from the same package with curly braces. For example,

  import com.ironcorelabs.identity.{ MockService, ProductionService }

Pattern Matching

• For method whose entire body is a pattern match expression, put the match on the same line as the method declaration if possible to reduce one level of indentation.

  def test(msg: Message): Unit = msg match {
    case ...
  }

• When calling a function with a closure (or partial function), if there is only one case, put the case on the same line as the function invocation.

  list.zipWithIndex.map { case (elem, i) =>
    // ...
  }

  If there are multiple cases, indent and wrap them.

  list.map {
    case a: Foo =>  ...
    case b: Bar =>  ...
  }

Infix Methods

Avoid infix notation for methods that aren't symbolic methods (i.e. operator overloading).

// Correct
list.map(func)
string.contains("foo")

// Wrong
list map (func)
string contains "foo"

// But overloaded operators should be invoked in infix style
arrayBuffer += elem

Scala Language Features

apply Method

Avoid defining apply methods on classes. These methods tend to make the code less readable, especially for people less familiar with Scala. It is also harder for IDEs (or grep) to trace. In the worst case, it can also affect correctness of the code in surprising ways, as demonstrated in Parentheses. It is however ok to define them in companion objects as factory methods.

override Modifier

Always add override modifier for methods, both for overriding concrete methods and implementing abstract methods. The Scala compiler does not require override for implementing abstract methods. However, we should always add override to make the override obvious, and to avoid accidental non-overrides due to non-matching signatures.

trait Parent {
  def hello(data: Map[String, String]): Unit = {
    print(data)
  }
}

class Child extends Parent {
  import scala.collection.Map

  // The following method does NOT override Parent.hello,
  // because the two Maps have different types.
  // If we added "override" modifier, the compiler would've caught it.
  def hello(data: Map[Int, String]): Unit = {
    print("This is supposed to override the parent method, but it is actually not!")
  }
}

Destructuring Binds

Destructuring bind (sometimes called tuple extraction) is a convenient way to assign two variables in one expression.

val (a, b) = (1, 2)

However, do NOT use them in constructors, especially when a and b need to be marked transient. The Scala compiler generates an extra Tuple2 field that will not be transient for the above example.

class MyClass {
  // This will NOT work because the compiler generates a non-transient Tuple2
  // that points to both a and b.
  @transient private val (a, b) = someFuncThatReturnsTuple2()
}

Call by Name

If you use either call-by-name parameters or the equivalent thunk () => T, and you reference the parameter more than once in the method, you must memoize the value before referencing it. For example

Background: Scala allows method parameters to be defined by-name, e.g. the following would work:

def print(value: => Int): Unit = {
  val localValue = value
  println(localValue)
  println(localValue + 1)
}

var a = 0
def inc(): Int = {
  a + 1
  a
}

print(inc())

In the above code, inc() is passed into print as a closure and would be executed (twice) in the method, rather than being passed in as a value 1, if the localValue was not in place. The main problem with call-by-name is that the caller cannot differentiate between call-by-name and call-by-value, and thus cannot know for sure whether the expression will be executed or not (or maybe worse, multiple times). This is especially dangerous for expressions that have side effects. The memoization avoids multiple evaluations.

Similarly,

def print(value: () => Int): Unit = {
  val tmpVal = value()
  println(tmpVal)
  println(tmpVal + 1)
}

print(() => inc())

If there's a chance no code path in the function might reference the local variable, make it a lazy val to avoid evaluating the parameter unnecessarily.

Multiple Parameter Lists

Avoid using multiple parameter lists. They complicate operator overloading, and can confuse programmers less familiar with Scala. For example:

// Avoid this!
case class Person(name: String, age: Int)(secret: String)

One notable exception is the use of a 2nd parameter list for implicits when defining low-level libraries. That said, implicits should be avoided!

Symbolic Methods (Operator Overloading)

Do NOT use symbolic method names, unless you are defining them for natural arithmetic operations (e.g. +, -, *, /). Under no other circumstances should they be used. Symbolic method names make it very hard to understand the intent of the methods. Consider the following two examples:

// symbolic method names are hard to understand
channel ! msg
stream1 >>= stream2

// self-evident what is going on
channel.send(msg)
stream1.join(stream2)

Type Inference

Scala type inference, especially left-side type inference and closure inference, can make code more concise. That said, there are a few cases where explicit typing should be used:

• Public methods should be explicitly typed, otherwise the compiler's inferred type can often surprise you.
• Implicit methods should be explicitly typed, otherwise it can crash the Scala compiler with incremental compilation.
• Variables or closures with non-obvious types should be explicitly typed. A good litmus test is that explicit types should be used if a code reviewer cannot determine the type in 3 seconds.

Return Statements

Avoid using return in closures. return is turned into try/catch of scala.runtime.NonLocalReturnControl by the compiler. This can lead to unexpected behaviors. Consider the following example:

def receive(rpc: WebSocketRPC): Option[Response] = {
  tableFut.onComplete { table =>
    if (table.isFailure) {
      return None // Do not do that!
    } else { ... }
  }
}

the .onComplete method takes the anonymous closure { table => ... } and passes it to a a different thread. This closure eventually throws the NonLocalReturnControl exception that is captured in a different thread . It has no effect on the poor method being executed here.

However, there are a few cases where return is preferred.

• Use return as a guard to simplify control flow without adding a level of indentation

  def doSomething(obj: Any): Any = {
    if (obj eq null) {
      return null
    }
    // do something ...
  }

• Use return to terminate a loop early, rather than constructing status flags

  while (true) {
    if (cond) {
      return
    }
  }

Recursion and Tail Recursion

Avoid using recursion, unless the problem can be naturally framed recursively (e.g. graph traversal, tree traversal).

For methods that are meant to be tail recursive, apply @tailrec annotation to make sure the compiler can check it is tail recursive (you will be surprised how often seemingly tail recursive code is actually not tail recursive due to the use of closures and functional transformations.)

Most code is easier to reason about with a simple loop and explicit state machines. Expressing it with tail recursions (and accumulators) can make it more verbose and harder to understand. For example, the following imperative code is more readable than the tail recursive version:

// Tail recursive version.
def max(data: Array[Int]): Int = {
  @tailrec
  def max0(data: Array[Int], pos: Int, max: Int): Int = {
    if (pos == data.length) {
      max
    } else {
      max0(data, pos + 1, if (data(pos) > max) data(pos) else max)
    }
  }
  max0(data, 0, Int.MinValue)
}

// Explicit loop version
def max(data: Array[Int]): Int = {
  var max = Int.MinValue
  for (v <- data) {
    if (v > max) {
      max = v
    }
  }
  max
}

Implicits

Avoid using implicits, unless:

• you are building a domain-specific language
• you are using it for implicit type parameters (e.g. ClassTag, TypeTag)
• you are using it private to your own class to reduce verbosity of converting from one type to another (e.g. Scala closure to Java closure)

When implicits are used, we must ensure that another engineer who did not author the code can understand the semantics of the usage without reading the implicit definition itself. Implicits have very complicated resolution rules and make the code base extremely difficult to understand. From Twitter's Effective Scala guide: "If you do find yourself using implicits, always ask yourself if there is a way to achieve the same thing without their help."

If you must use them (e.g. enriching some DSL), do not overload implicit methods, i.e. make sure each implicit method has a distinct name, so users can selectively import it.

// Don't do the following, as users cannot selectively import only one of the methods.
object ImplicitHolder {
  def toRdd(seq: Seq[Int]): RDD[Int] = ...
  def toRdd(seq: Seq[Long]): RDD[Long] = ...
}

// Do the following:
object ImplicitHolder {
  def intSeqToRdd(seq: Seq[Int]): RDD[Int] = ...
  def longSeqToRdd(seq: Seq[Long]): RDD[Long] = ...
}

Exception Handling, i.e. There is no Try, only /

• Do NOT catch Throwable or Exception. Use scala.util.control.NonFatal:

  try {
    ...
  } catch {
    case NonFatal(e) =>
      // handle exception; note that NonFatal does not match InterruptedException
    case e: InterruptedException =>
      // handle InterruptedException
  }

  This ensures that we do not catch NonLocalReturnControl (as explained in Return Statements).

• Do NOT use Try in APIs, i.e. do NOT return Try in any methods. Prefer disjunctions instead, with the error type as the left member of the disjunction. For instance,

  class UserService {
    /** Look up a user's profile in the user database. */
    def get(userId: Int): UserError \/ User
  }

Options

• Use Option when the value can be empty. Compared with null, an Option explicitly states in the API contract that the value can be None.
• When constructing an Option, use Option rather than Some to guard against null values.

  def myMethod1(input: String): Option[String] = Option(transform(input))
  
  // This is not as robust because transform can return null, and then
  // myMethod2 will return Some(null).
  def myMethod2(input: String): Option[String] = Some(transform(input))

• Do not use None to represent exceptions. Instead, throw exceptions explicitly.
• Do not call get directly on an Option, unless you know absolutely for sure the Option has some value.

Monadic Chaining

One of Scala's powerful features is monadic chaining. Almost everything (e.g. collections, Option, Future, Try) is a monad and operations on them can be chained together. This is an incredibly powerful concept, but chaining should be used sparingly. In particular:

• Avoid chaining (and/or nesting) too deeply. We don't have any hard or fast limit here - when you have chained things too far, break the chain and introduce a variable to hold the partial result.
• If it takes more than 5 seconds to figure out what the logic is, try hard to think about how you can expression the same functionality without using monadic chaining. As a general rule, watch out for flatMaps and folds.
• A chain should almost always be broken after a flatMap (because of the type change).

A chain can often be made more understandable by giving the intermediate result a variable name, by explicitly typing the variable, and by breaking it down into more procedural style. As a contrived example:

[ ?? Need a different example - the second approach here is worse than the first. ?? ]

class Person(val data: Map[String, String])
val database = Map[String, Person]
// Sometimes the client can store "null" in the key "address"

// A monadic chaining approach
def getAddress(name: String): Option[String] = {
  database.get(name).flatMap { elem =>
    elem.data.get("address")
      .flatMap(Option.apply)  // handle null value
  }
}

// A more readable approach, despite much longer
def getAddress(name: String): Option[String] = {
  if (!database.contains(name)) {
    return None
  }

  database(name).data.get("address") match {
    case Some(null) => None  // handle null value
    case Some(addr) => Option(addr)
    case None => None
  }
}

Concurrency

Scala concurrent.Map

Prefer java.util.concurrent.ConcurrentHashMap over scala.collection.concurrent.Map. In particular the getOrElseUpdate method in scala.collection.concurrent.Map is not atomic (fixed in Scala 2.11.6, SI-7943). Since all the projects we work on require cross-building for both Scala 2.10 and Scala 2.11, scala.collection.concurrent.Map should be avoided.

Explicit Synchronization vs Concurrent Collections

There are 3 recommended ways to make concurrent accesses to shared states safe. Do NOT mix them because that could make the program very hard to reason about and lead to deadlocks.

1. java.util.concurrent.ConcurrentHashMap: Use when all states are captured in a map, and high degree of contention is expected.

private[this] val map = new java.util.concurrent.ConcurrentHashMap[String, String]

2. java.util.Collections.synchronizedMap: Use when all states are captured in a map, and contention is not expected but you still want to make code safe. In case of no contention, the JVM JIT compiler is able to remove the synchronization overhead via biased locking.

private[this] val map = java.util.Collections.synchronizedMap(new java.util.HashMap[String, String])

3. Explicit synchronization by synchronizing all critical sections: can be used to guard multiple variables. Similar to 2, the JVM JIT compiler can remove the synchronization overhead via biased locking.

class Manager {
  private[this] var count = 0
  private[this] val map = new java.util.HashMap[String, String]
  def update(key: String, value: String): Unit = synchronized {
    map.put(key, value)
    count += 1
  }
  def getCount: Int = synchronized { count }
}

Note that for case 1 and case 2, do not let views or iterators of the collections escape the protected area. This can happen in non-obvious ways, e.g. when returning Map.keySet or Map.values. If views or values are required to pass around, make a copy of the data.

val map = java.util.Collections.synchronizedMap(new java.util.HashMap[String, String])

// This is broken!
def values: Iterable[String] = map.values

// Instead, copy the elements
def values: Iterable[String] = map.synchronized { Seq(map.values: _*) }

Explicit Synchronization vs Atomic Variables vs @volatile

The java.util.concurrent.atomic package provides primitives for lock-free access to primitive types, such as AtomicBoolean, AtomicInteger, and AtomicReference.

Always prefer Atomic variables over @volatile. They have a strict superset of the functionality and are more visible in code. Atomic variables are implemented using @volatile under the hood.

Prefer Atomic variables over explicit synchronization when: (1) all critical updates for an object are confined to a single variable and contention is expected. Atomic variables are lock-free and permit more efficient contention. Or (2) synchronization is clearly expressed as a getAndSet operation. For example:

// good: clearly and efficiently express only-once execution of concurrent code
val initialized = new AtomicBoolean(false)
...
if (!initialized.getAndSet(true)) {
  ...
}

// poor: less clear what is guarded by synchronization, may unnecessarily synchronize
val initialized = false
...
var wasInitialized = false
synchronized {
  wasInitialized = initialized
  initialized = true
}
if (!wasInitialized) {
  ...
}

Private Fields

Note that private fields are still accessible by other instances of the same class, so protecting it with this.synchronized (or just synchronized) is not technically sufficient. Make the field private[this] instead.

// The following is still unsafe.
class Foo {
  private var count: Int = 0
  def inc(): Unit = synchronized { count + 1 }
}

// The following is safe.
class Foo {
  private[this] var count: Int = 0
  def inc(): Unit = synchronized { count + 1 }
}

Isolation

In general, concurrency and synchronization logic should be isolated and contained as much as possible. This effectively means:

• Avoid surfacing the internals of synchronization primitives in APIs, in user-facing methods, callbacks.
• For complex modules, create a small, inner module that capture the concurrency primitives.

Performance

For the vast majority of the code you write, performance should not be a concern. However, for performance sensitive code, here are some tips:

Microbenchmarks

It is ridiculously hard to write a good microbenchmark because the Scala compiler and the JVM JIT compiler does a lot of magic to the code. More often than not your microbenchmark code is not measuring the thing you want to measure.

Use jmh if you are writing microbenchmark code. Make sure you read through all the sample microbenchmarks so you understand the effect of deadcode elimination, constant folding, and loop unrolling on microbenchmarks.

Traversal and zipWithIndex

Use while loops instead of for loops or functional transformations (e.g. map, foreach). For loops and functional transformations are very slow (due to virtual function calls and boxing).

val arr = // array of ints
// zero out even positions
val newArr = list.zipWithIndex.map { case (elem, i) =>
  if (i % 2 == 0) 0 else elem
}

// This is a high performance version of the above
val newArr = new Array[Int](arr.length)
var i = 0
val len = newArr.length
while (i < len) {
  newArr(i) = if (i % 2 == 0) 0 else arr(i)
  i += 1
}

Option and null

For performance sensitive code, prefer null over Option, in order to avoid virtual method calls and boxing. Label the nullable fields clearly with Nullable.

class Foo {
  @javax.annotation.Nullable
  private[this] var nullableField: Bar = _
}

Scala Collection Library

For performance sensitive code, prefer Java collection library over Scala ones, since the Scala collection library often is slower than Java's.

private[this]

For performance sensitive code, prefer private[this] over private. private[this] generates a field, rather than creating an accessor method. In our experience, the JVM JIT compiler cannot always inline private field accessor methods, and thus it is safer to use private[this] to ensure no virtual method call for accessing a field.

class MyClass {
  private val field1 = ...
  private[this] val field2 = ...

  def perfSensitiveMethod(): Unit = {
    var i = 0
    while (i < 1000000) {
      field1  // This might invoke a virtual method call
      field2  // This is just a field access
      i += 1
    }
  }
}

Java Interoperability

This section covers guidelines for building Java compatible APIs. NOTE: at this time, we don't anticipate needing to build Java compatible APIs. You will find plenty of IronCore Labs code that does not adhere to these guidelines. However, in the event that we do require interoperability with Java, we can refer to this section. It is mostly drawn from DataBrick's experience in developing the Java APIs for Spark.

Java Features Missing from Scala

The following Java features are missing from Scala. If you need the following, define them in Java instead. However, be reminded that ScalaDocs are not generated for files defined in Java.

• Static fields
• Static inner classes
• Java enums
• Annotations

Traits and Abstract Classes

For interfaces that can be implemented externally, keep in mind the following:

• Traits with default method implementations are not usable in Java. Use abstract classes instead.
• In general, avoid using traits unless you know for sure the interface will not have any default implementation even in its future evolution.

// The default implementation doesn't work in Java
trait Listener {
  def onTermination(): Unit = { ... }
}

// Works in Java
abstract class Listener {
  def onTermination(): Unit = { ... }
}

Type Aliases

Do NOT use type aliases. They are not visible in bytecode (and Java).

Default Parameter Values

Do NOT use default parameter values. Overload the method instead.

// Breaks Java interoperability
def sample(ratio: Double, withReplacement: Boolean = false): RDD[T] = { ... }

// The following two work
def sample(ratio: Double, withReplacement: Boolean): RDD[T] = { ... }
def sample(ratio: Double): RDD[T] = sample(ratio, withReplacement = false)

Multiple Parameter Lists

Do NOT use multi-parameter lists.

Varargs

• Apply @scala.annotation.varargs annotation for a vararg method to be usable in Java. The Scala compiler creates two methods, one for Scala (bytecode parameter is a Seq) and one for Java (bytecode parameter array).

  @scala.annotation.varargs
  def select(exprs: Expression*): DataFrame = { ... }

• Note that abstract vararg methods do NOT work for Java, due to a Scala compiler bug (SI-1459, SI-9013).

• Be careful with overloading varargs methods. Overloading a vararg method with another vararg type can break source compatibility.

  class Database {
    @scala.annotation.varargs
    def remove(elems: String*): Unit = ...
  
    // Adding this will break source compatibility for no-arg remove() call.
    @scala.annotation.varargs
    def remove(elems: People*): Unit = ...
  }
  
  // This won't compile anymore because it is ambiguous
  new Database().remove()

  Instead, define an explicit first parameter followed by vararg:

  class Database {
    @scala.annotation.varargs
    def remove(elems: String*): Unit = ...
  
    // The following is OK.
    @scala.annotation.varargs
    def remove(elem: People, elems: People*): Unit = ...
  }

Implicits

Do NOT use implicits for a class or method. This includes ClassTag, TypeTag.

class JavaFriendlyAPI {
  // This is NOT Java friendly, since the method contains an implicit parameter (ClassTag).
  def convertTo[T: ClassTag](): T
}

Companion Objects, Static Methods and Fields

There are a few things to watch out for when it comes to companion objects and static methods/fields.

• Companion objects are awkward to use in Java (a companion object Foo is a static field MODULE$ of type Foo$ in class Foo$).

  object Foo
  
  // equivalent to the following Java code
  public class Foo$ {
    Foo$ MODULE$ = // instantiation of the object
  }

  If the companion object is important to use, create a Java static field in a separate class.

• Unfortunately, there is no way to define a JVM static field in Scala. Create a Java file to define that.

• Methods in companion objects are automatically turned into static methods in the companion class, unless there is a method name conflict. The best (and future-proof) way to guarantee the generation of static methods is to add a test file written in Java that calls the static method.

  class Foo {
    def method2(): Unit = { ... }
  }
  
  object Foo {
    def method1(): Unit = { ... }  // a static method Foo.method1 is created in bytecode
    def method2(): Unit = { ... }  // a static method Foo.method1 is NOT created in bytecode
  }
  
  // FooJavaTest.java (in test/scala/com/databricks/...)
  public class FooJavaTest {
    public static compileTest() {
      Foo.method1();  // This one should compile fine
      Foo.method2();  // This one should fail because method2 is not generated.
    }
  }

• A case object (or even just plain companion object) MyClass is actually not of type MyClass

  case object MyClass
  
  // Test.java
  if (MyClass$.MODULE instanceof MyClass) {
    // The above condition is always false
  }

  To implement the proper type hierarchy, define a companion class, and then extend that in case object:

  class MyClass
  case object MyClass extends MyClass

Miscellaneous

Prefer nanoTime over currentTimeMillis

When computing a duration or checking for a timeout, avoid using System.currentTimeMillis(). Use System.nanoTime() instead, even if you are not interested in sub-millisecond precision.

System.currentTimeMillis() returns current wallclock time and will follow changes to the system clock. Thus, negative wallclock adjustments can cause timeouts to "hang" for a long time (until wallclock time has caught up to its previous value again). This can happen when ntpd does a "step" after the network has been disconnected for some time. The most canonoical example is during system bootup when DHCP takes longer than usual. This can lead to failures that are really hard to understand/reproduce. System.nanoTime() it is guaranteed to be monotonically increasing irrespective of wallclock changes.

Caveats:

• Never serialize an absolute nanoTime() value or pass it to another system. The absolute value is meaningless, system-specific and reset when the system reboots.
• The absolute nanoTime() value is not guaranteed to be positive (but t2 - t1 is guaranteed to yield the right result)
• nanoTime() rolls over every 292 years. So if your Spark job is going to take a really long time, you may need something else :)

Prefer URI over URL

When storing the URL of a service, you should use the URI representation.

The equality check of URL actually performs a (blocking) network call to resolve the IP address. The URI class performs field equality and is a superset of URL as to what it can represent.