小编Adr*_*ian的帖子

我正在尝试调试存储过程(Oracle).我想打印一些变量.

我不知道要打印的命令是什么(或在哪里找到它).谁能告诉我它是什么？

谢谢

编辑:

这是我的触发器:

create or replace
procedure bns_saa_confs_update_state (
  theID in varchar2
)
AS
begin
  UPDATE BNS_SAA_CONFIRMATIONS SET SentToWssStatus='T' WHERE ID=theID;
  commit;
end;

我想打印ID

是否可以从PriorityQueue中删除元素？

文件:
http://www.scala-lang.org/api/current/index.html#scala.collection.mutable.PriorityQueue
http://www.scala-lang.org/api/current/index.html#scala .collection.Iterator

我有一个PQ w各种双值(一些重复) - 我用它作为一个堆来跟踪流媒体环境中的滚动中位数.我想从PQ中删除值,但无法弄清楚如何.
我试图使用迭代器来找到PQ的一个元素并放在那里,但它没有用.我想知道它是否可能？

val maxHeapLeft= new mutable.PriorityQueue[Double]()(Ordering[Double])
maxHeapLeft.enqueue(5)
maxHeapLeft.enqueue(55)
maxHeapLeft.enqueue(25)
maxHeapLeft.enqueue(15)
maxHeapLeft.enqueue(15)
val it= maxHeapLeft.iterator
var p1=it.next
p1=it.next

println("size before " +maxHeapLeft.size)
it.drop(1)
println("size AFTER " +maxHeapLeft.size)

PQ的大小不会改变.

编辑1:到目前为止,我用来maxHeapLeft= new mutable.PriorityQueue[Double]()(Ordering[Double]) ++ (maxHeapLeft.toList diff List(15))从PQ中删除15.当然,太可怕了.

编辑2:自定义优先级队列失败的测试用例(对于@Nate):

 "PQ" should "produce correct values " in {
    val testOperations = List[String]("8114.0", "9233.0", "dequeue", "10176.0", "10136.0", "dequeue", "10041.0", "9900.0", "10787.0", "10476.0", "10439.0", "dequeue", "10722.0", "9900.0", "11028.0", "10764.0", "dequeue", "10698.0", "10374.0", "dequeue", …

hashCode()是如何实现的？

我的假设是它使用对象内存位置作为运行哈希函数的初始数(种子).然而,这种情况并非如此.

我也看过Hash:它在内部如何运作？但它没有回答我的问题.

是的我可以下载SDK,但在我这样做并查看代码之前,也许其他人已经了解它.

谢谢 :)

编辑: 我知道它应该被覆盖等等,所以请尽量保持主题:)

我希望从Kafka消费数据并将数据保存到Hadoop和Elasticsearch中。我目前已经看到了两种方法：使用Filebeat从Kafka消费并将其发送到ES，以及使用Kafka-Connect框架。有一个Kafka-Connect-HDFS和Kafka-Connect-Elasticsearch模块。

我不确定要使用哪个发送流数据。虽然我认为如果我想在某个时候从Kafka中获取数据并将其放入Cassandra中，我可以为此使用Kafka-Connect模块，但是Filebeat没有这样的功能。

我有一个表,其列名为DATE类型的STREAM_TIME.
我正在尝试将该列的所有行更新为今天的日期.使用的数据库是oracle.

我的查询:

update bns_bess_messages SET stream_time=getDate();

Oracle回来时出现此错误:

SQL Error: ORA-00904: "GETDATE": invalid identifier
00904. 00000 -  "%s: invalid identifier"

如何将STREAM_TIME更新到今天的日期？

谢谢

我有一个Cassandra的模式文件.我正在使用Windows 7机器(Cassandra也在这个机器上 - 1个节点).我想用cqssh加载模式.到目前为止,我还没有找到如何.我希望能够将文件传递给cqlsh : cqlsh mySchemaFile. 但是因为我在windows中运行,要启动cqlsh,我会执行以下操作

python "C:\Program Files (x86)\DataStax Community\apache-cassandra\bin\cqlsh" localhost 9160

即使我在我的路径中有csqsh,当从python这样调用它时,它需要完整的路径.

我试图在那里添加文件名但到目前为止没有运气.这甚至可能吗？

是否可以在方法中定义参数x,以便x的类型T是实现给定函数签名的通用类型(让我们说def apply() : Double),而不引入新类型？

[示例]目标是定义类似的东西(我只是为了说明而使用adhoc语法):

def foo(x : T with def apply() : Double) = { ... }

目前,我可以引入一种新类型ApplyDouble,但这需要我将实例为合法参数的所有可能类型扩展为'foo',然后将foo的签名转换为

def foo(x : ApplyDouble) = { ... }

有没有办法命名参数.map函数需要？请参阅Scala示例中的以下内容:

aggregated.map( (kv: ((String, Int, Int), (Int, Int))) =>("some stuff"))

我想把它们命名为

aggregated.map( (kv: ((name:String, score:Int, anInt:Int), (age:Int, count:Int))) =>("some stuff"))

这样可以在映射完成时更容易引用参数.例如,而不是使用kv._1._2我可以说score或kv.score.使代码更易读,更容易调试.

我无法将来自JSON的org.joda.time.DateTime字段反序列化为案例类.

JSON:
val ajson=parse(""" { "creationDate": "2013-01-02T10:48:41.000-05:00" }""")

我还设置了这些序列化选项:
implicit val formats = Serialization.formats(NoTypeHints) ++ net.liftweb.json.ext.JodaTimeSerializers.all

和反序列化:
val val1=ajson.extract[Post]

帖子是:
case class Post(creationDate: DateTime){ ... }

我得到的例外是:

 net.liftweb.json.MappingException: No usable value for creationDate
    Invalid date format 2013-01-02T10:48:41.000-05:00

如何将该日期字符串反序列化为DateTime对象？

编辑:
这工作:val date3= new DateTime("2013-01-05T06:24:53.000-05:00") 它使用与反序列化中的JSON相同的日期字符串.这里发生了什么事？

我有一个问题是将我的docker镜像推向神器[Artifactory Pro Power Pack 3.5.2.1(rev.30160)](用作docker注册表).

我有泊坞版:

$ sudo docker version
Client version: 1.5.0  
Client API version: 1.17  
Go version (client): go1.3.3  
Git commit (client): a8a31ef/1.5.0  
OS/Arch (client): linux/amd64  
Server version: 1.5.0  
Server API version: 1.17  
Go version (server): go1.3.3  
Git commit (server): a8a31ef/1.5.0  

我已经关注了这个链接http://www.jfrog.com/confluence/display/RTF/Docker+Repositories和这个神器作为docker注册表 我创建了一个名为docker的docker注册表docker-local并启用了docker支持.我的神器没有选项,我可以说像本文档中的 docker v1或v2,所以我假设它使用docker v1.

Artifactory为我生成了这些:

<distributionManagement>
    <repository>
        <id>sdpvvrwm812</id>
        <name>sdpvvrwm812-releases</name>
        <url>http://sdpvvrwm812.ib.tor.company.com:8081/artifactory/docker-local</url>
    </repository>
    <snapshotRepository>
        <id>sdpvvrwm812</id>
        <name>sdpvvrwm812-snapshots</name>
        <url>http://sdpvvrwm812.ib.tor.company.com:8081/artifactory/docker-local</url>
    </snapshotRepository>
</distributionManagement>

虽然有些东西不适合这些设置.

我安装了反向代理nginx并将这些设置复制到其中/etc/nginx/nginx.conf:

http {

##
# Basic Settings
## …

Run Code Online (Sandbox Code Playgroud)