Serialized Form
-
Package quarks.analytics.math3.json
-
Package quarks.connectors.wsclient.javax.websocket.runtime
-
Class quarks.connectors.wsclient.javax.websocket.runtime.WebSocketClientBinaryReceiver extends WebSocketClientReceiver<T> implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.connectors.wsclient.javax.websocket.runtime.WebSocketClientBinarySender extends WebSocketClientSender<T> implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.connectors.wsclient.javax.websocket.runtime.WebSocketClientConnector extends quarks.connectors.runtime.Connector<javax.websocket.Session> implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
config
java.util.Properties config
-
id
java.lang.String id
-
sid
java.lang.String sid
-
msgReceiver
WebSocketClientReceiver<T> msgReceiver
-
container
javax.websocket.WebSocketContainer container
-
containerFn
Supplier<T> containerFn
-
-
Class quarks.connectors.wsclient.javax.websocket.runtime.WebSocketClientReceiver extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.connectors.wsclient.javax.websocket.runtime.WebSocketClientSender extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
connector
WebSocketClientConnector connector
-
toPayload
Function<T,R> toPayload
-
-
-
Package quarks.function
-
Class quarks.function.WrappedFunction extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
f
java.lang.Object f
-
-
-
Package quarks.metrics.oplets
-
Class quarks.metrics.oplets.CounterOp extends SingleMetricAbstractOplet<T> implements Serializable
- serialVersionUID:
- -6679532037136159885L
-
Serialized Fields
-
counter
com.codahale.metrics.Counter counter
-
-
Class quarks.metrics.oplets.RateMeter extends SingleMetricAbstractOplet<T> implements Serializable
- serialVersionUID:
- 3328912985808062552L
-
Serialized Fields
-
meter
com.codahale.metrics.Meter meter
-
-
Class quarks.metrics.oplets.SingleMetricAbstractOplet extends Peek<T> implements Serializable
- serialVersionUID:
- -6679532037136159885L
-
Serialized Fields
-
shortMetricName
java.lang.String shortMetricName
-
metricName
java.lang.String metricName
-
-
-
Package quarks.oplet.core
-
Class quarks.oplet.core.FanOut extends AbstractOplet<T,T> implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
targets
java.util.List<E> targets
-
n
int n
-
-
Class quarks.oplet.core.Peek extends Pipe<T,T> implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.oplet.core.Pipe extends AbstractOplet<I,O> implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.oplet.core.Split extends AbstractOplet<T,T> implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
splitter
ToIntFunction<T> splitter
-
destinations
java.util.List<E> destinations
-
n
int n
-
-
-
Package quarks.oplet.functional
-
Class quarks.oplet.functional.Events extends Source<T> implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.oplet.functional.Filter extends Pipe<T,T> implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.oplet.functional.FlatMap extends Pipe<I,O> implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.oplet.functional.Map extends Pipe<I,O> implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.oplet.functional.Peek extends Peek<T> implements Serializable
- serialVersionUID:
- 1L
-
-
Package quarks.oplet.plumbing
-
Class quarks.oplet.plumbing.Isolate extends Pipe<T,T> implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
thread
java.lang.Thread thread
-
tuples
java.util.concurrent.LinkedBlockingQueue<E> tuples
-
-
Class quarks.oplet.plumbing.PressureReliever extends Pipe<T,T> implements Serializable
- serialVersionUID:
- 1L
-
Class quarks.oplet.plumbing.UnorderedIsolate extends Pipe<T,T> implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
executor
java.util.concurrent.ScheduledExecutorService executor
-
-
-
Package quarks.oplet.window
-
Package quarks.runtime.etiao
-
Class quarks.runtime.etiao.SettableForwarder extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
-
Package quarks.samples.connectors
-
Class quarks.samples.connectors.MsgSupplier extends java.lang.Object implements Serializable
- serialVersionUID:
- 1L
-
Serialized Fields
-
maxCnt
int maxCnt
-
cnt
int cnt
-
done
boolean done
-
-
-
Package quarks.window