小编whb*_*whb的帖子

如何初始化元组列表并在scala中添加项目

为什么这不是有效的?

    var a = List[(String,String)]
    a = a :: ("x","y")
Run Code Online (Sandbox Code Playgroud)

基本上我想初始化一个元组列表并在列表中添加一个元组.

scala

10
推荐指数
2
解决办法
2万
查看次数

Apache Airflow 忽略失败的任务

有没有办法忽略失败的任务并在假设 2 次重试后继续下一步?

例子;

t1= SomeOperator(...)
t2= SomeOperator(...)

t2.set_upstream(t1)


# if t1 fails re-try 2 times and proceed to t2

# else if t1 success then proceed to t2 as usual 
Run Code Online (Sandbox Code Playgroud)

airflow

4
推荐指数
1
解决办法
5117
查看次数

使用jaydebeapi获取列名

我如何在jaydebeapi中执行以下操作?

#In Java
ResultSet rs = stmt.executeQuery("SELECT a, b, c FROM TABLE2");
ResultSetMetaData rsmd = rs.getMetaData();
String columnName = rsmd.getColumnName(0) ## basically i am interested with this part
Run Code Online (Sandbox Code Playgroud)

python jaydebeapi

3
推荐指数
1
解决办法
2386
查看次数

Akka:如何让演员在主管上引起异常

我怎样才能让哪位儿童演员在主管上有例外.基本上我想在停止失败的演员之前处理其他事情,比如将数据库记录失败等等.但为此我必须确切地知道哪个演员有例外.

我的supervisor战略代码块就像

/* stop task actor on unhandled exception */
private static SupervisorStrategy strategy = new OneForOneStrategy(
        1,
        Duration.create(1, TimeUnit.MINUTES),
        new Function<Throwable, SupervisorStrategy.Directive>() {
            @Override
            public SupervisorStrategy.Directive apply(Throwable t) throws Exception {
                return SupervisorStrategy.stop();
            }
        }
);

@Override
public SupervisorStrategy supervisorStrategy() {
    return strategy;
}
Run Code Online (Sandbox Code Playgroud)

java akka

2
推荐指数
1
解决办法
1272
查看次数

标签 统计

airflow ×1

akka ×1

java ×1

jaydebeapi ×1

python ×1

scala ×1