15 nov 2014 kl. 20:26 skrev Michael Frank syntaxjoc...@gmail.com:
I'm investigating algorithms for cluster sharding, and i was curious what
algorithm(s) the akka.contrib.pattern.ClusterSharding module was based on?
are there any associated research papers or texts?
Pat Helland's Life
Hello!
I've been messing around with akka-streams lately and ran into some
problems. I'm not sure where to go from this point.
I have a TCP connection to an external data feed, in which I can subscribe
to a wide variety of real-time data. What exactly will be subscribed to
changes during
Hi AKKA experts!
We are building an OLTP gateway, were this gateway has the following
(partly) requirements:
High-throughput and low latency, no single point of failure, and fully
scalable solution with initial capability for 500 tps per instance and
scalable to 5000 tps.
(but of courseJ)
I think the reason is not the java serialization. all IO worked by an
endpointerWriter actor, which is associated with one connection. so all IO
operation is dealed by sequence
在 2014年2月12日星期三UTC+8下午5时04分23秒，chen ke写道：
hi,all:
my project use one client to send message to a server with
Hi
(I apologize in advance for all the screenshots, just the easiest way to
relay information here)
To be more precise, the problem appears to be happening inside the removed
experimental Pipeline code. I understand this was removed and isn't
supported but just putting this out there in hope
Hi,
I'm currently trying to build a real-time geo-indexing application with
akka streams.
In order to index my location updates I have to buffer them in a
Transformer and
map them to a new value when enough events where received.
My current implementation is like this
val geoSource:
On Thursday, November 13, 2014 12:49:40 PM UTC, Martynas Mickevičius wrote
Hi Stu,
it seems that FlowGraphbuilder.connect needs to be refactored to two
parameter lists so Scala is able to infer both type parameters before using
them.
I have experimented with that a bit here
geoSource ~ Flow[LocationUpdate].transform(gridcell, () =
GridCellTransformer(…)).transform(compress, () = new Compressor(…))
Does that help? :-)
On Sun, Nov 16, 2014 at 8:44 PM, Muki nepomuk.sei...@gmail.com wrote:
Hi,
I'm currently trying to build a real-time geo-indexing application with
Yes, that's the only way I've found to do it for now.
On Saturday, November 15, 2014 11:06:05 AM UTC-7, Martynas Mickevičius
wrote:
Hi Curtis,
when debugging concurrent systems I find that extensive debug logging is
really helpful. :)
On Fri, Nov 14, 2014 at 1:53 AM, Curtis Stanford
Thanks! That did the trick. I was digging down the implementation, but
wasn't able to find
out the correct usage :)
Am Sonntag, 16. November 2014 21:32:02 UTC+1 schrieb √:
geoSource ~ Flow[LocationUpdate].transform(gridcell, () =
GridCellTransformer(…)).transform(compress, () = new
Hi I am new to using akka and I am running into the following issue
I have an actor written in a funcrtional style that roughly looks like this
:
class MyActor extends Actor {
def awaitCompletion(writer: writer) = {
case Add(message) = {
writer.write(message)
One way to do it would be to have a supervisor actor be responsible for
opening and closing the actor, and instantiating MyActor. Then, the
supervisor actor can deathwatch for the actor and close the writer, or
close the writer through the supervisorStrategy on exception.
Will Sargent
12 matches
Mail list logo
