如果在代码或函数中使用.jar等资源文件,那么需要先将资源上传至该项目的项目空间下,然后在函数中进行引用。
资源管理通常使用在UDF等自定义函数的场景中,因此可以将资源管理理解为函数管理的一个步骤。
一、上传资源
上传资源:可上传jar类型的资源,上传后资源会同步至实时计算Streaming中。
1. 资源名称:需输入英文字母、数字、下划线组成,不超过20个字符。
2. 资源类型:目前仅支持jar或Python类型的资源,不支持其他类型资源。
3. 存储位置:此资源在页面左侧的资源管理存储结构中的位置。
4. 描述:此资源的描述,可输入长度不超过200个的任意字符。
实时计算不支持批量上传资源,同时也请您注意上传资源的大小,超过100M的文件,无法上传。
二、在函数中引用资源
如果现有的系统内置函数无法满足您的需求,实时计算支持创建自定义函数,实现个性化处理逻辑。将实现逻辑的Jar包上传至项目空间下,便可在创建自定义函数的时候进行引用。详细操作请参见https://dtstack.yuque.com/pd2/doc_streamworks/wi3wse[函数管理]。
三、在Flink任务中引用资源
实时计算支持通过引用资源创建Flink任务,用户手动配置资源、mainclass、参数、选择储存位置,可快速完成实时计算任务的创建。详细操作请参考 任务管理中的新建Flink任务。
四、不支持在代码中引用资源
实时计算不支持在代码中引用资源,只支持在函数和FLink jar包任务中引用资源。
五、删除资源
如果需要删除一个资源,在资源管理中右键单击该资源,选择删除即可。
删除资源后,引用该资源的函数或代码在运行时会报错,故请慎重操作。如有改动,尽量通知到依赖该资源的其他对象的负责人。