cmd

May 3, 2023

Changes in this version

+ const SPARK

+ func Version() (version, sum string)

Apr 17, 2023

Changes in this version

+ const DISTRIBUTION

+ const DISTRIBUTION_BIN

+ const RAW2SCIENCE

+ const S3

+ const STREAM2RAW

+ const ShellToUse

+ func ExecCmd(command string) (string, string)

+ func Execute()

+ type DistributionConfig struct

+ DistributionSchema string

+ DistributionServers string

+ Night string

+ SubstreamPrefix string

+ type Raw2ScienceConfig struct

+ Night string

+ type S3Config struct

+ AccessKeyID string

+ BucketName string

+ Endpoint string

+ SecretAccessKey string

+ UseSSL string

+ type SparkConfig struct

+ ApiServerUrl string

+ Binary string

+ FinkTriggerUpdate string

+ Image string

+ LogLevel string

+ OnlineDataPrefix string

+ Packages string

+ Producer string

+ StorageClass storageClass

+ type Stream2RawConfig struct

+ FinkAlertSchema string

+ KafkaSocket string

+ KafkaStartingOffset string

+ KafkaTopic string