Packages

object Utils extends Logging

Linear Supertypes
Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Utils
  2. Logging
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val DEFAULT_SHUTDOWN_PRIORITY: Int
  5. val SERVER_SHUTDOWN_PRIORITY: Int
  6. val SPARK_CONTEXT_SHUTDOWN_PRIORITY: Int
  7. def addShutdownHook(hook: Runnable, priority: Int = DEFAULT_SHUTDOWN_PRIORITY): Unit

    Add some operations that you want into ShutdownHook

  8. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  9. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  10. def createDirectory(root: String, namePrefix: String = "kyuubi"): Path

    Create a directory inside the given parent directory.

    Create a directory inside the given parent directory. The directory is guaranteed to be newly created, and is not marked for automatic deletion.

  11. def createTempDir(root: String = ..., namePrefix: String = "kyuubi"): Path

    Create a temporary directory inside the given parent directory.

    Create a temporary directory inside the given parent directory. The directory will be automatically deleted when the VM shuts down.

  12. def currentUser: String
  13. def debug(message: ⇒ Any): Unit
    Definition Classes
    Logging
  14. def deleteDirectoryRecursively(f: File): Boolean

    Delete a directory recursively.

  15. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  17. def error(message: ⇒ Any): Unit
    Definition Classes
    Logging
  18. def error(message: ⇒ Any, t: Throwable): Unit
    Definition Classes
    Logging
  19. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  20. def findLocalInetAddress: InetAddress

    This block of code is based on Spark's Utils.findLocalInetAddress()

  21. def getAbsolutePathFromWork(pathStr: String, env: Map[String, String] = sys.env): Path
  22. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  23. def getDateFromTimestamp(time: Long): String

    return date of format yyyyMMdd

  24. def getDefaultPropertiesFile(env: Map[String, String] = sys.env): Option[File]
  25. def getPropertiesFromFile(file: Option[File]): Map[String, String]
  26. def getSystemProperties: Map[String, String]
  27. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  28. def info(message: ⇒ Any): Unit
    Definition Classes
    Logging
  29. def initializeLoggerIfNecessary(isInterpreter: Boolean): Unit
    Attributes
    protected
    Definition Classes
    Logging
  30. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  31. def isTesting: Boolean

    Indicates whether Kyuubi is currently running unit tests.

  32. val isWindows: Boolean

    Whether the underlying operating system is Windows.

  33. def logger: Logger
    Attributes
    protected
    Definition Classes
    Logging
  34. def loggerName: String
    Attributes
    protected
    Definition Classes
    Logging
  35. def majorMinorVersion(version: String): (Int, Int)

    Given a Kyuubi/Spark/Hive version string, return the (major version number, minor version number).

    Given a Kyuubi/Spark/Hive version string, return the (major version number, minor version number). E.g., for 2.0.1-SNAPSHOT, return (2, 0).

  36. def majorVersion(version: String): Int

    Given a Kyuubi/Spark/Hive version string, return the major version number.

    Given a Kyuubi/Spark/Hive version string, return the major version number. E.g., for 2.0.1-SNAPSHOT, return 2.

  37. def minorVersion(version: String): Int

    Given a Kyuubi/Spark/Hive version string, return the minor version number.

    Given a Kyuubi/Spark/Hive version string, return the minor version number. E.g., for 2.0.1-SNAPSHOT, return 0.

  38. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  39. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  40. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  41. def shortVersion(version: String): String

    Given a Kyuubi/Spark/Hive version string, return the short version string.

    Given a Kyuubi/Spark/Hive version string, return the short version string. E.g., for 3.0.0-SNAPSHOT, return '3.0.0'.

  42. def strToSeq(s: String, sp: String = ","): Seq[String]
  43. def stringifyException(e: Throwable): String

    Make a string representation of the exception.

  44. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  45. def toString(): String
    Definition Classes
    AnyRef → Any
  46. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  47. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  48. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  49. def warn(message: ⇒ Any, t: Throwable): Unit
    Definition Classes
    Logging
  50. def warn(message: ⇒ Any): Unit
    Definition Classes
    Logging

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped