Documentation
¶
Index ¶
Constants ¶
View Source
const KindSparkApplication = "SparkApplication"
Variables ¶
This section is empty.
Functions ¶
Types ¶
type SparkConfig ¶
type SparkConfig struct {
DefaultSparkConfig map[string]string `json:"spark-config-default" pflag:",Key value pairs of default spark configuration that should be applied to every SparkJob"`
SparkHistoryServerURL string `json:"spark-history-server-url" pflag:",URL for SparkHistory Server that each job will publish the execution history to."`
}
Spark-specific configs
func GetSparkConfig ¶
func GetSparkConfig() *SparkConfig
type WaitableConfig ¶
type WaitableConfig struct {
// TODO: Reconsider this once we plug Console as a Log Provider plugin.
ConsoleURI config.URL `json:"console-uri" pflag:",URI for console. Used to expose links in the emitted events."`
LruCacheSize int `json:"lru-cache-size" pflag:",Size of the AutoRefreshCache"`
}
func GetWaitableConfig ¶
func GetWaitableConfig() *WaitableConfig
Click to show internal directories.
Click to hide internal directories.