Packages

object XskipperConf extends Configuration with Logging

JVM wide xskipper + metadatastore specific parameters such as user, password, host.

Linear Supertypes
Logging, Configuration, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. XskipperConf
  2. Logging
  3. Configuration
  4. AnyRef
  5. 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 BLOOM_FILTER_FPP: ConfigEntry[Double]
  5. val BLOOM_FILTER_FPP_KEY: String
  6. val BLOOM_FILTER_NDV: ConfigEntry[Long]
  7. val BLOOM_FILTER_NDV_KEY: String
  8. val XSKIPPER_CONF_PREFIX: String
  9. val XSKIPPER_EVALUATION_ENABLED: ConfigEntry[Boolean]
  10. val XSKIPPER_EVALUATION_ENABLED_KEY: String
  11. val XSKIPPER_IDENTIFIER_CLASS: ConfigEntry[String]
  12. val XSKIPPER_IDENTIFIER_CLASS_KEY: String
  13. val XSKIPPER_INDEX_CREATION_MIN_CHUNK_SIZE: ConfigEntry[Int]
  14. val XSKIPPER_INDEX_CREATION_MIN_CHUNK_SIZE_KEY: String
  15. val XSKIPPER_INDEX_CREATION_PARALLELISM: ConfigEntry[Int]
  16. val XSKIPPER_INDEX_CREATION_PARALLELISM_KEY: String
  17. val XSKIPPER_INDEX_DRIVER_MEMORY_FRACTION: ConfigEntry[Double]
  18. val XSKIPPER_INDEX_DRIVER_MEMORY_FRACTION_KEY: String
  19. val XSKIPPER_MINMAX_IN_FILTER_THRESHOLD: ConfigEntry[Int]
  20. val XSKIPPER_MINMAX_IN_FILTER_THRESHOLD_KEY: String
  21. val XSKIPPER_PARQUET_MINMAX_INDEX_OPTIMIZED: ConfigEntry[Boolean]
  22. val XSKIPPER_PARQUET_MINMAX_INDEX_OPTIMIZED_KEY: String
  23. val XSKIPPER_PARQUET_MINMAX_OPTIMIZED_PARALLELISM: ConfigEntry[Int]
  24. val XSKIPPER_PARQUET_MINMAX_OPTIMIZED_PARALLELISM_KEY: String
  25. val XSKIPPER_TIMEOUT: ConfigEntry[Int]
  26. val XSKIPPER_TIMEOUT_KEY: String
  27. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  28. def clearConf(): Unit

    clean the context for the configuration by clearing the configuration map defaults are used in case the values don't exist in the map

    clean the context for the configuration by clearing the configuration map defaults are used in case the values don't exist in the map

    Definition Classes
    Configuration
  29. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  30. val confEntries: ConcurrentHashMap[String, String]
    Definition Classes
    Configuration
  31. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  32. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  33. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  34. def get(key: String): String

    Retrieves the value associated with the given key in the configuration

    Retrieves the value associated with the given key in the configuration

    key

    the key to lookup

    returns

    the value associated with the key or null if the key doesn't exist

    Definition Classes
    Configuration
  35. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  36. def getConf(): Map[String, String]

    Returns a map of all configurations currently set

    Returns a map of all configurations currently set

    Definition Classes
    Configuration
  37. def getConf[T](configEntry: ConfigEntry[T]): T

    Generic functions that returns the config value of the given key or the default value if the config doesn't exist

    Generic functions that returns the config value of the given key or the default value if the config doesn't exist

    configEntry

    the config entry to be returned

    returns

    the config value or the default value if the config value is not defined

    Definition Classes
    Configuration
  38. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  39. def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
    Attributes
    protected
    Definition Classes
    Logging
  40. def initializeLogIfNecessary(isInterpreter: Boolean): Unit
    Attributes
    protected
    Definition Classes
    Logging
  41. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  42. def isTraceEnabled(): Boolean
    Attributes
    protected
    Definition Classes
    Logging
  43. def log: Logger
    Attributes
    protected
    Definition Classes
    Logging
  44. def logDebug(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  45. def logDebug(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  46. def logError(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  47. def logError(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  48. def logInfo(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  49. def logInfo(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  50. def logName: String
    Attributes
    protected
    Definition Classes
    Logging
  51. def logTrace(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  52. def logTrace(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  53. def logWarning(msg: ⇒ String, throwable: Throwable): Unit
    Attributes
    protected
    Definition Classes
    Logging
  54. def logWarning(msg: ⇒ String): Unit
    Attributes
    protected
    Definition Classes
    Logging
  55. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  56. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  57. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  58. def set(key: String, value: String): Unit

    Sets a new key in the configuration

    Sets a new key in the configuration

    key

    the key to set

    value

    the value associated with the key

    Definition Classes
    Configuration
  59. def setConf(params: Map[String, String]): Unit

    Update the configuration with the following entries

    Update the configuration with the following entries

    params

    a map of parameters to be set

    Definition Classes
    XskipperConf → Configuration
  60. final def setConf(params: Map[String, String]): Unit
    Definition Classes
    Configuration
  61. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  62. def toString(): String
    Definition Classes
    AnyRef → Any
  63. def unset(key: String): Unit

    Removes a key from the configuration

    Removes a key from the configuration

    key

    the key to remove

    Definition Classes
    Configuration
  64. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  65. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  66. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from Logging

Inherited from Configuration

Inherited from AnyRef

Inherited from Any

Ungrouped