小编Anj*_*nju的帖子

Ansible的yum模块中有两个"状态"选项值"present"和"installed"有什么区别?

我的ansible剧本中有以下任务:

- name: Install EPEL repo.
  yum:
    name: "{{ epel_repo_url }}"
    state: present
    register: result
    until: '"failed" not in result'
    retries: 5
    delay: 10
Run Code Online (Sandbox Code Playgroud)

我可以传递给州的另一个值是"已安装".两者有什么区别?这里提供了一些文档:http://docs.ansible.com/ansible/yum_module.html

centos yum ansible epel

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

mongodb中的日期比较

我想在特定日期之后检索所有文档.我的数据库的日期为 - DateAdded:"2014-12-17 10:03:46.000Z"

我写了以下查询 -

db.collection.find({DateAdded:{"$lte":new Date("2015-06-17 10:03:46.000Z")}})
Run Code Online (Sandbox Code Playgroud)

但即使有最新的日期记录,结果也不会取任何记录2015-06-24.

date mongodb

13
推荐指数
3
解决办法
3万
查看次数

如何使用Scala从Spark中的List或Array创建Row

我正在尝试org.apache.spark.sql.catalyst.expressions.Row根据用户输入创建一个Row().我无法随机创建一行.

是否有任何功能可以从List或创建一个行Array.

例如,如果我有一个.csv格式如下的文件,

"91xxxxxxxxxx,21.31,15,0,0"
Run Code Online (Sandbox Code Playgroud)

如果用户输入[1, 2]那么我只需要第二列和第三列以及customer_id第一列

我尝试用代码解析它:

val l3 = sc.textFile("/SparkTest/abc.csv").map(_.split(" ")).map(r => (foo(input,r(0)))) `
Run Code Online (Sandbox Code Playgroud)

其中foo定义为

def f(n: List[Int], s: String) : Row = {
    val n = input.length
    var out = new Array[Any](n+1)
    var r = s.split(",")
    out(0) = r(0)
    for (i <- 1 to n)
        out(i) = r(input(i-1)).toDouble
    Row(out)
}
Run Code Online (Sandbox Code Playgroud)

和输入是一个List说

val input = List(1,2)
Run Code Online (Sandbox Code Playgroud)

执行此代码我得到l3:

Array[org.apache.spark.sql.Row] = Array([[Ljava.lang.Object;@234d2916])
Run Code Online (Sandbox Code Playgroud)

但我想要的是:

Array[org.apache.spark.sql.catalyst.expressions.Row] = Array([9xxxxxxxxxx,21.31,15])`
Run Code Online (Sandbox Code Playgroud)

必须传递此内容才能在Spark SQL中创建模式

scala apache-spark apache-spark-sql

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

Swift playground - 如何将带逗号的字符串转换为带小数的字符串

我是斯威夫特世界的新手.

如何将带逗号的String转换为带小数的String?

代码工作正常,带点(.)

问题是当我使用逗号(,)...时:var price

问题的起源是Decimal法语键盘使用逗号(,)而不是点(.)

如果它是密钥,不知道如何使用NSNumberFormattergenerateDecimalNumbers.有不止一个选择.

//The answer change if "2,25" or "2.25" is used.

var price      : String = "2,25"
var priceFloat = (price as NSString).floatValue

//I need to have 2.25 as answer.

var costString = String(format:"%.2f", priceFloat)
Run Code Online (Sandbox Code Playgroud)

感谢您的时间和帮助!

string comma swift-playground

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

如何在Spark Scala shell中列出HDFS位置中的所有csv文件?

这样做的目的是为了在HDFS中的第二个位置操作和保存每个数据文件的副本.我会用的

RddName.coalesce(1).saveAsTextFile(pathName)
Run Code Online (Sandbox Code Playgroud)

将结果保存到HDFS.

这就是为什么我想单独写每个文件,即使我确信性能不会那么高效.但是,我还没有确定如何将CSV文件路径列表存储到字符串数组中,然后使用单独的RDD循环遍历每个字符串.

让我们使用以下匿名示例作为HDFS源位置:

/data/email/click/date=2015-01-01/sent_20150101.csv
/data/email/click/date=2015-01-02/sent_20150102.csv
/data/email/click/date=2015-01-03/sent_20150103.csv
Run Code Online (Sandbox Code Playgroud)

我知道如何使用Hadoop FS Shell列出文件路径:

HDFS DFS -ls /data/email/click/*/*.csv
Run Code Online (Sandbox Code Playgroud)

我知道如何为所有数据创建一个RDD:

val sentRdd = sc.textFile( "/data/email/click/*/*.csv" )
Run Code Online (Sandbox Code Playgroud)

hadoop scala hdfs apache-spark

7
推荐指数
1
解决办法
4358
查看次数

春天的queryparm支持,用于提供宁静的Web服务

如何queryparam以真正宁静的方式获得春天的宁静网络服务支持......

for example i have url like following

localhost:8080/myapp/booksearch/title/{title}/author/{author}?sortby=relevance&year=2013

title and author I can get by @PathVariable .....

where i want sortby and year optional..

java rest spring query-parameters

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

断开连接时终止远程 ssh 命令

我正在使用 Mina SSHD 客户端在 OpenSSH 服务器上运行远程命令。我正在远程服务器上执行一个长时间运行的命令,并希望它在客户端会话关闭时终止。

当我从 PC 终端运行此命令时:

\#ssh -t user@server sleep 12345
Run Code Online (Sandbox Code Playgroud)

这是我在远程机器上找到的:

\# ps -axf

---- Omitted for clarity

12158 ?        Ss     0:29 /usr/sbin/sshd -4
22708 ?        Ss     0:11  \\_ sshd: user@pts/3,pts/4
16894 pts/3    Ss     0:00  |   \\_ -bash
17750 pts/3    R+     0:00  |   |   \\_ ps -axf
17606 pts/4    Ss+    0:00  |   \\_ sleep 12345

---- Omitted for clarity
Run Code Online (Sandbox Code Playgroud)

当我终止计算机上的 ssh 客户端时,“睡眠 12345”将在远程计算机上终止。

然而,当我使用 Mina Java SSH 客户端运行完全相同的内容时,我看到了这样的结果。

    SshClient client = SshClient.setUpDefaultClient();
    client.start();
    ConnectFuture connect = …
Run Code Online (Sandbox Code Playgroud)

ssh mina

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

如何返回对象列表以及Exception

我的Java程序有一个返回List的方法.它使用各种SQL查询填充列表.在某些情况下,数据可能不存在.在那种情况下,我要抛出异常.由于它是一个列表,列表可能包含有效数据.是否可以获取列表以及捕获例外?

public List<Student> getStudentInfo(){
    //Contains some static info like name, dob of a Student
    List<Student> students = getStudentStaticInfo();
    try{
        for (Student student: students){
            student.setTotalMarks(getStudentMark(student.getId()));
            ...
        }
    catch(FailedToFetchDataException e) {
        throw new Exception("Failed to fetch data");
    } finally {
        return students;
    }

}
Run Code Online (Sandbox Code Playgroud)

在这种情况下,该方法返回有效学生信息的列表.但是在例外的情况下,我无法找到答案.

有没有办法处理两者,获取有效信息以及获得特殊情况.

java

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