Packages

object EnvUtils

EnvUtils helps you deal with all the required environment variables along with their default values.

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. EnvUtils
  2. AnyRef
  3. 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 ALLOW_DDL_CLAUSE_IN_SQL: String
  5. val ALLOW_RESERVED_KEYWORDS_AS_COLLECTION_NAME: String
  6. val BUILD_VERSION: String
  7. val DATAOS_CONF_DIR: String
  8. val DATAOS_IS_DRY_RUN: String
  9. val DATAOS_JOB_DESCRIPTION: String
  10. val DATAOS_JOB_SCHEDULE: String
  11. val DATAOS_JOB_TAGS: String
  12. val DATAOS_RUN_AS_APIKEY: String
  13. val DATAOS_RUN_AS_USER: String
  14. val DATAOS_RUN_AS_USER_AGENT: String
  15. val DATAOS_SECRET_DIR: String
  16. val DATAOS_WORKSPACE: String
  17. val DATAPOLICY_GATEWAY_SSL: String
  18. val DATASET_ADDRESS: String
  19. val DATASET_CHANGE_NOTIFICATION_KAFKA_TOPIC: String
  20. val DEPOT_SERVICE_URL: String
  21. val ENABLE_PULSAR_AUTH: String
  22. val ENABLE_TOPIC_CREATION: String
  23. val ENVIRONMENT: String
  24. val FINGERPRINT_CONFIG_PATH: String
  25. val FINGERPRINT_URL: String
  26. val FLARE_AUDIT_MODE: String
  27. val GATEWAY_BASE_URL: String
  28. val HEIMDALL_SSL: String
  29. val HEIMDALL_URL: String
  30. val HERA_URL: String
  31. val ICEBERG_ACTIONS: String
  32. val IOSA_PUBLISHER_MAX_RETRY_COUNT: String
  33. val IOSA_PUBLISHER_RETRY_BACKOFF_MULTIPLE: String
  34. val IOSA_PUBLISHER_RETRY_INTERVAL: String
  35. val IOSA_RECEIVER_URL: String
  36. val METIS_JOB_NAME: String
  37. val METIS_JOB_OWNER_NAME: String
  38. val METIS_URL: String
  39. val MINERVA_JDBC_URL: String
  40. val MINERVA_SSL: String
  41. val NOTIFICATION_KAFKA_BROKERS: String
  42. val PUBLISH_LINEAGE_CONNECT_TIMEOUT_MS: String
  43. val PUBLISH_LINEAGE_SOCKET_TIMEOUT_MS: String
  44. val PULSAR_SSL: String
  45. val PUSHGATEWAY_HOST: String
  46. val PUSHGATEWAY_PORT: String
  47. val REFRESHER_POLLING_INTERVAL: String
  48. val RUNNABLE_NAME: String
  49. val RUNNABLE_RUN_ID: String
  50. val RUNNABLE_WORKFLOW_NAME: String
  51. val RUNNABLE_WORKFLOW_RUN_ID: String
  52. val SKIP_PUBLISHING_RUN_STATS: String
  53. val SKIP_TOPOLOGY_REGISTRATION: String
  54. val SSL_CA_CERT_PATH: String
  55. val SSL_KEYSTORE_PASSWORD: String
  56. val SSL_KEYSTORE_PATH: String
  57. val SSL_TRUSTSTORE_PASSWORD: String
  58. val SSL_TRUSTSTORE_PATH: String
  59. val STORE_URL: String
  60. val STREAMING_JOB_LINEAGE_TIMEOUT_MILLIS: String
  61. val STREAMING_QUERY_POLL_INTERVAL_BEFORE_EXIT: String
  62. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  63. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  64. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  65. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  66. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  67. def getAuditMode: String
  68. def getBuildVersion: String
  69. def getCaCertFilePath: String
  70. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  71. def getDatasetRefreshKafkaTopic: String
  72. def getDepotServiceUrl: String
  73. def getEnvironment: Option[String]
  74. def getFingerprintConfig: Option[String]
  75. def getFingerprintUrl: String
  76. def getFlareConfDir: Option[String]
  77. def getFlareSecretConfDir: Option[String]
  78. def getGatewayBaseUrl: String
  79. def getHeimdallUrl: String
  80. def getHeraUrl: String
  81. def getIosaPublisherMaxRetryCount: Int
  82. def getIosaPublisherRetryBackoffMultiple: Int
  83. def getIosaPublisherRetryInterval: Int
  84. def getIosaServiceUrl: Option[String]
  85. def getJobSchedule: Option[String]
  86. def getKeyStorePassword: String
  87. def getKeyStorePath: String
  88. def getLineageConnectTimeout: Integer
  89. def getLineageSocketTimeout: Integer
  90. def getMetisUrl: String
  91. def getMinervaJdbcConnectionUrl: String
  92. def getNotificationKafkaEndpoint: String
  93. def getOwnerName: String
  94. def getPollingInterval: Int
  95. def getRunnableDescription: Option[String]
  96. def getRunnableName: String
  97. def getRunnableRunId: String
  98. def getRunnableRunIdOrThrow: String
  99. def getRunnableTags: Option[String]
  100. def getRunnableWorkflowName: Option[String]
  101. def getRunnableWorkflowRunId: Option[String]
  102. def getStoreUrl: String
  103. def getStreamingJobLineageTimeout: Long
  104. def getStreamingQueryPollIntervalBeforeExit: Long
  105. def getTrustStorePassword: String
  106. def getTrustStorePath: String
  107. def getUser: String
  108. def getUserAgent: String
  109. def getUserApiKey: String
  110. def getWorkspace: String
  111. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  112. def isDryRun: Boolean
  113. def isEnabledDataPolicyGatewaySSL: Boolean
  114. def isEnabledHeimdallSSL: Boolean
  115. def isEnabledMinervaSSL: Boolean
  116. def isEnabledPulsarAuth: Boolean
  117. def isEnabledPulsarSSL: Boolean
  118. def isEnabledTopicCreation: Boolean
  119. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  120. def isPublishingRunStatsEnabled: Boolean
  121. def isStandaloneEnvironment: Boolean
  122. def isTopologyRegistrationEnabled: Boolean
  123. def isWorkspaceProvided: Boolean
  124. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  125. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  126. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  127. def pushGatewayHost: Option[String]
  128. def pushGatewayPort: String
  129. def skipDDLQueryValidation: Boolean
  130. def skipValidationOnCollectionName: Boolean
  131. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  132. def toString(): String
    Definition Classes
    AnyRef → Any
  133. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  134. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  135. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped