我有一份和Cassandra谈话的工作。批处理作业完成后,我需要验证cassandra中的几个条目,并且循环将持续2-3次。如何知道批处理作业何时结束?我不想通过在db中添加条目来跟踪批处理作业的状态。如何在spark中编写功能测试?
目前还没有任何答案,快来回答吧!
暂无答案!
目前还没有任何答案,快来回答吧!