java - 从 Airflow 调用 Java 类或方法

Question

我想从 Airflow 任务中调用几个 java 方法，因为我已经有很多用 java 编写的代码，包括验证、清理、一些业务逻辑，我不想再次用 Python 重写它。

我正在使用气流 2.1.0

我知道有一种方法可以使用 BashOperator 调用 jar

jar_task = BashOperator(
    task_id='java',
    bash_command='java -jar somejar.jar',
    dag=dag
) 

但是有什么方法可以让我直接从任务本身调用任何特定的java类或方法，否则我必须为我的每个逻辑创建许多小罐子。
提前致谢。

Answer 1

You could use java -cp somejar.jar SomeClass to run a different main method.