用于基于maxTimeuuid和minTimeuuid的查询的Java API

使用maxTimeuuid和minTimeuuid的查询的Java API是什么？我在QueryBuilder或其他任何地方找不到任何内容.我正在使用DataStax客户端

        <artifactId>cassandra-driver-core</artifactId>
        <version>1.0.3</version>

Run Code Online (Sandbox Code Playgroud)

表"a"有2列:1.类型为String的id 2.类型为TimeUuid的LMD

这就是我在做什么,似乎不对,当然不起作用

    Query q = QueryBuilder
    .select()
    .all()
    .from("test","a")
    .where().and(QueryBuilder.gt("LMD", "minTimeUUid('2013-11-03 14:33:50')"))
    .and(QueryBuilder.lt("LMD", "maxTimeUUId('2013-11-03 14:45:50')"));

Run Code Online (Sandbox Code Playgroud)

任何指针都非常感谢

谢谢

java cassandra cql3 datastax-java-driver

Mas*_*sti

2013 11-07

3
推荐指数

1
解决办法

2175
查看次数

汽车停在无限的街道上:找到汽车并计算复杂性

以下是采访中提出的问题:

你被安置在一条很长的街道上.这是你停车的街道.你必须在这条街上找到你的车.

找到你的汽车的算法是什么,复杂性是多少.他们正在寻找的答案是O(nlogn)......但你必须证明为什么它是o(nlogn)...提示:很多数学都涉及到这个答案.

algorithm math complexity-theory

Mas*_*sti

2012 08-30

2
推荐指数

1
解决办法

329
查看次数

由ServiceRegistry阻止的线程

我有一个相对较高的音量/请求系统,我们正在使用OSGi.我们每天接近800M请求.

我们目前看到线程被阻止的一些问题.对于每个进入的请求,我们使用registerService将事件/数据转发到osgi包,以将有效负载/数据传递给正在侦听此服务的OSGi包.

像这样:bundleContext.registerService(Map.class.getName(),dataHolderMap,null);

dataHolderMap只是一个普通的java hashmap

这是使用JStack的threaddump:

================================================== =========================

"RequestThread" PRIO = 10 TID = 0x00000000421ab800 NID = 0x1042可运行的[0x00007fbdd3867000] java.lang.Thread.State中:在RUNNABLE org.apache.felix.framework.ServiceRegistry.getService(ServiceRegistry.java:295) - 锁定<0x0000000700e2c590>(位于org.apache.felix.framework.Felix.getService(Felix.java:3568)的org.apache.felix.framework.BundleContextImpl.getService(BundleContextImpl.java:468)at org.apache.felix.framework.ServiceRegistry)位于org.osgi.util.tracker.ServiceTracker的org.osgi.util.tracker.ServiceTracker $ Tracked.customizerAdding(ServiceTracker.java:932)的org.osgi.util.tracker.ServiceTracker.addingService(ServiceTracker.java:411) Tracked.customizerAdding(ServiceTracker.java:864)org.osgi.util.tracker.AbstractTracked.trackAdding(AbstractTracked.java:256)atg.osgi.util.tracker.AbstractTracked.track(AbstractTracked.java:229)org oros.apache.felix.framework.util.EventDispatcher.invokeServiceListe中的.osgi.util.tracker.ServiceTracker $ Tracked.serviceChanged(ServiceTracker.java:894)nerCallback(EventDispatcher.java:932)在org.apache.felix.framework.util.EventDispatcher.fireEventImmediately(EventDispatcher.java:793)在org.apache.felix.framework.util.EventDispatcher.fireServiceEvent(EventDispatcher.java:543) org.apache.felix.framework.Felix.fireServiceEvent(Felix.java:4419)org.apache.felix.framework.Felix.registerService(Felix.java:3423)at org.apache.felix.framework.BundleContextImpl.registerService (BundleContextImpl.java:346)位于com的com.mypackage.person.bs.processor.Processor.sendEvent(Processor.java:56)的org.apache.felix.framework.BundleContextImpl.registerService(BundleContextImpl.java:320). mypackage.jetMyStream.event.support.AbstractEventSource.fireSendEvent在com.mypackage.jetMyStream.event(AbstractEventSource.java:97)在com.mypackage.jetMyStream.event.channel.messaging.InboundMessagingChannel.fireEvent(InboundMessagingChannel.java:113). com.mypackage.jetMyS上的channel.messaging.InboundMessagingChannel.onMessage(InboundMessagingChannel.java:204)tream.messaging.MessageService.dispatchMessageForContext(MessageService.java:349)在com.mypackage.jetMyStream.messaging.MessageService.dispatch(MessageService.java:259)在com.mypackage.jetMyStream.messaging.MessageServiceRequest.execute(MessageServiceRequest.java: 40)at com.mypackage.jetMyStream.util.RequestThread.run(RequestThread.java:69)

"RequestThread"prio = 10 tid = 0x00000000425f8800 nid = 0x1041正在等待监视器条目[0x00007fbdd3968000] java.lang.Thread.State:BLOCKED(在对象监视器上)org.apache.felix.framework.ServiceRegistry.registerService(ServiceRegistry.java: 109) - 等待在org.apache.felix.framework.BundleContextImpl的org.apache.felix.framework.Felix.registerService(Felix.java:3393)上锁定<0x0000000700e2c590>(一个org.apache.felix.framework.ServiceRegistry)位于org.apache.felix.framework.BundleContextImpl.registerService(BundleContextImpl.java:320)的.registerService(BundleContextImpl.java:346)位于com.mypackage.person.bs.processor.Processor.sendEvent(BullseyeModelProcessor.java:56)at at com.mypackage.jetMyStream.event.support.AbstractEventSource.fireSendEvent在com.mypackage.jetMyStream(AbstractEventSource.java:97)在com.mypackage.jetMyStream.event.channel.messaging.InboundMessagingChannel.fireEvent(InboundMessagingChannel.java:113). event.channel.messaging.InboundMessagingChannel.onMessage(InboundMessag ingChannel.java:204)在com.mypackage.jetMyStream.messaging.MessageService.dispatchMessageForContext(MessageService.java:349)在com.mypackage.jetMyStream.messaging.MessageService.dispatch(MessageService.java:259)在com.mypackage.jetMyStream .messaging.MessageServiceRequest.execute(MessageServiceRequest.java:40)