Contents

package org.embulk.input

import com.google.common.base.Optional
import org.embulk.config.ConfigException

package object dynamodb {
  def require[A](value: Optional[A], message: String): A = {
    if (value.isPresent) {
      value.get()
    } else {
      throw new ConfigException("Required option is not set: " + message)
    }
  }
}

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
embulk-input-dynamodb-0.2.0	src/main/scala/org/embulk/input/dynamodb/package.scala
embulk-input-dynamodb-0.1.1	src/main/scala/org/embulk/input/dynamodb/package.scala