Tag: scala

播放框架会话和cookie如何工作?

游戏如何validationcookie? 我注意到,在我重新启动服务器后,我仍然登录,即使我没有在数据库中预先存在任何会话数据。 我还注意到我可以将服务器上的日期设置为大于cookie的exipry日期,但我仍然登录了。 我注销了(将cookie保存到文本文件中),浏览器丢失了cookie。 然后我从文本文件中重新创建了cookie,然后我再次登录。 cookie看起来像这样: PLAY_SESSION = e6443c88da7xxxxxxxxxxxxxxxxxxxxxxxxxxxxx-的userid%3A1 // My logout code def logout() = Action { Ok(“”).withNewSession } 从文档中 丢弃整个会话 有特殊操作丢弃整个会话: Ok(“Bye”).withNewSession

Elasticsearch:在测试类路径中发现jar地狱

我想在Elasticsearch中执行unit testing,因为我正在使用Java-test-framework 我正在使用Elasticsearch-1.6.0并参考这些链接以获取帮助https://www.elastic.co/guide/en/elasticsearch/reference/1.6/using-elasticsearch-test-classes.html https:// github。 COM /弹性/ elasticsearch / BLOB /主/核心/ src目录/测试/ JAVA /组织/ elasticsearch /动作/搜索/ SearchRequestBuilderTests.java 这是代码 class CampaignESTest extends ESTestCase { def getCLient():MockTransportClient={ val settings = Settings.builder() .put(Environment.PATH_HOME_SETTING.getKey(), Files.createTempDir().toString()) .build(); val client = new MockTransportClient(settings); client } } class CampaignTestSearch extends PlaySpec{ val client=new CampaignESTest val response = client.prepareSearch(“dbtest”) .setTypes(CAMPAIGN_COLLECTION_NAME) .setSearchType(SearchType.DFS_QUERY_THEN_FETCH) .addFields(“uuid”,”campaignName”,”artworkID”,”activationDate”,”_source”) .setQuery(query) […]

如何关闭Netty库调试输出?

我正在使用Netty(通过Ning异步HTTP 库 )通过HTTP检索文档。 这会在控制台上产生大量的调试输出,如下面列出的单个文档请求。 任何人都知道如何关闭它? 我真的不需要看到这个输出。 我打电话给Scala,如果这有任何区别的话。 15:07:14.273 [run-main] DEBUG cnhcpnNettyAsyncHttpProvider – Non cached request DefaultHttpRequest(chunked: false) GET /api/search.json?q=foo HTTP/1.1 Host: www.documentcloud.org Connection: keep-alive Accept: */* User-Agent: NING/1.0 using Channel [id: 0x2839ca40] 15:07:14.930 [New I/O client worker #1-1] DEBUG cnhcpnNettyAsyncHttpProvider – Request DefaultHttpRequest(chunked: false) GET /api/search.json?q=foo HTTP/1.1 Host: www.documentcloud.org Connection: keep-alive Accept: */* User-Agent: NING/1.0 […]

我在Scala中同步什么对象?

在C#中它非常简单: class Class1{ private static readonly object locker = new object(); void Method1(){ lock(locker) { …. } } } 我绝对不应该对此进行同步,因为它可能会导致死锁。 同样,在Scala中,我看到了一些示例,无法理解同步的基本原理和我应该用于进行同步的对象(字段): #1 def add(user: User) { // tokenizeName was measured to be the most expensive operation. val tokens = tokenizeName(user.name) tokens.foreach { term => userMap.synchronized { add(term, user) } } } #2 class Person(var name: […]

从Java Play Framework调用Scala,它接受ClassTag

我正在尝试从Play Java类调用Scala方法,该方法将ClassTag作为参数 我失败的尝试是 Option localUser = Cache.getAs(userId.userId(), app, new ClassTag() ); API方法如下所示 Cache.getAs(String key, Application app, ClassTag ct );

什么是实现这个Java“byte 到Hex”类的Scala方式

我特别感兴趣的是Scala(2.8)技术用于构建具有格式的字符串以及有用的方法,以便在有用的情况下轻松访问这些function(字节列表,字符串,……?)。 public class Hex { public static String valueOf (final byte buf[]) { if (null == buf) { return null; } final StringBuilder sb = new StringBuilder(buf.length * 2); for (final byte b : buf) { sb.append(String.format(“%02X”, b & 0xff)); } return sb.toString(); } public static String valueOf (final Byteable o) { return valueOf(o.toByteArray()); } […]

在Spark 0.9.0上运行作业会引发错误

我安装了Apache Spark 0.9.0群集,我正在尝试部署从HDFS读取文件的代码。 这段代码会发出警告,最终失败。 这是代码 /** * running the code would fail * with a warning * Initial job has not accepted any resources; check your cluster UI to ensure that * workers are registered and have sufficient memory */ object Main extends App { val sconf = new SparkConf() .setMaster(“spark://labscs1:7077”) .setAppName(“spark scala”) val sctx […]

为什么不提供运营商? :在scala中

有一个运营商? : ? :在Java中,可用于根据布尔表达式选择值。 例如,表达式3 > 2 ? “true” : false 3 > 2 ? “true” : false将返回一个字符串”true” 。 我知道我们可以使用if表达式来做到这一点,但我更喜欢这种风格,因为它简洁而优雅。

java.lang.IllegalArgumentException:可能无法回收废弃或附加的视图。 isScrap:false isAttached:true

当使用IllegalArgumentExceptionexception向回收器视图添加多个项目时,应用程序崩溃 java.lang.IllegalArgumentException: Scrapped or attached views may not be recycled. isScrap:false isAttached:true 这是exception的完整堆栈跟踪 java.lang.IllegalArgumentException: Scrapped or attached views may not be recycled. isScrap:false isAttached:true at android.support.v7.widget.RecyclerView$Recycler.recycleViewHolderInternal(RecyclerView.java:4624) at android.support.v7.widget.RecyclerView$Recycler.quickRecycleScrapView(RecyclerView.java:4697) at android.support.v7.widget.RecyclerView$LayoutManager.removeAndRecycleScrapInt(RecyclerView.java:6811) at android.support.v7.widget.RecyclerView.dispatchLayout(RecyclerView.java:2934) at android.support.v7.widget.RecyclerView.onLayout(RecyclerView.java:3071) at android.view.View.layout(View.java:14849) at android.view.ViewGroup.layout(ViewGroup.java:4631) at android.widget.FrameLayout.layoutChildren(FrameLayout.java:453) at android.widget.FrameLayout.onLayout(FrameLayout.java:388) at android.view.View.layout(View.java:14849) at android.view.ViewGroup.layout(ViewGroup.java:4631) at android.support.v4.view.ViewPager.onLayout(ViewPager.java:1627) at android.view.View.layout(View.java:14849) at android.view.ViewGroup.layout(ViewGroup.java:4631) at android.widget.LinearLayout.setChildFrame(LinearLayout.java:1671) at […]

使用java api在Elasticsearch中创建索引和添加映射会丢失分析器错误

代码在Scala中。 它与Java代码非常相似。 我们的地图索引器用于创建索引的代码: https : //gist.github.com/a16e5946b67c​​6d12b2b8 上述代码用于创建索引和映射的实用程序: https : //gist.github.com/4f88033204cd761abec0 java给出的错误: https : //gist.github.com/d6c835233e2b606a7074 运行代码并获取错误后对http://elasticsearch.domain/maps/_settings的响应: https ://gist.github.com/06ca7112ce1b01de3944 JSON文件: https : //gist.github.com/bbab15d699137f04ad87 https://gist.github.com/73222e300be9fffd6380 附件是我正在加载的json文件。我已经确认它正在加载正确的json文件并正确地将它作为字符串输出到.loadFromSource和.setSource。 任何想法为什么即使它们在设置中也找不到分析仪? 如果我通过curl运行这些json文件,它们工作正常并正确设置映射。