scala - AWS Glue 作业访问参数
问题描述
我有一个用 Scala 编写的胶水作业(Spark 作业),我想将参数传递给它。我使用 lambda 函数来触发工作。我应该如何访问传递给作业的参数?
这是正确的方法吗?
def main(sysArgs: Array[String]) {
/** This is input parameter */
val par = sysArgs(0)
}
还是其他?
解决方案
使用GlueArgParser解析参数:
import com.amazonaws.services.glue.util.GlueArgParser
val args = GlueArgParser.getResolvedOptions(
sysArgs, Array(
"JOB_NAME",
"CUSTOM_PARAMETER")
)
val param = args("CUSTOM_PARAMETER")
请注意,参数应带前缀--
(即。--CUSTOM_PARAMETER
)
推荐阅读
- terminal - 我的终端 PS1 是 2 行,当我清除屏幕时,第一行也被清除,我该如何防止这种情况?
- python - Not receiving same OTP in a time step/interval - Django-otp
- c++ - 为在 C++ 中打印出给定字符串的所有排列的递归程序编写基本案例
- sql - Detecting changes to a SQL view
- julia - 用以前的非缺失值填充“缺失”值的有效方法是什么?
- android - How to determine user reached the top of a RecyclerView?
- javascript - How to make an object's X and Y positions responsive to HTML Canvas's width and height?
- python - 如何将嵌套的整数列表拆分为 aa 列表
- python - Why doesn't my function exit if the game is played more than once?
- java - 如何正确存储到哈希图,然后复制到树图以循环并显示键和值