dataflow

const (
	DATA_FLOW_MAIL_ADDR = "[email protected]"

	ACTION_TYPE_HIVE     = "HIVE"
	ACTION_TYPE_HDFS     = "HDFS"
	ACTION_TYPE_SPARK    = "SPARK"
	ACTION_TYPE_DECISION = "DECISION"
	ACTION_TYPE_SSH      = "SSH"
	ACTION_TYPE_KAFKA    = "KAFKA"

	ACTION_TYPE_MAP_REDUCE = "MR"
	ACTION_TYPE_EMAIL      = "EMAIL"
	ACTION_TYPE_STOP       = "STOP"
	ACTION_TYPE_FORK       = "FORK"
	ACTION_TYPE_JAVA       = "JAVA"

	FORK_TYPE_ALL       = "ALL"
	FORK_TYPE_ONE       = "ONE"
	FORK_TYPE_MANDATORY = "MANDATORY"

	SSH_OPERATION_MKDIR = "MKDIR"

	//ACT_RESULT_PATH      = "/usr/eaciit/dataflow/result/"
	CMD_SPARK            = "spark-submit %v"
	CMD_MAP_REDUCE       = "hadoop jar %v -input %v -output %v -mapper %v -reducer %v"
	CMD_JAVA             = "java -jar %v"
	GLOBAL_PARAM_KEYWORD = "global."

	PROCESS_STATUS_RUN     = "RUN"
	PROCESS_STATUS_SUCCESS = "SUCCESS"
	PROCESS_STATUS_ERROR   = "ERROR"
)