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

Serialized Fields

toTuple

Function<T,R> toTuple

Class quarks.connectors.wsclient.javax.websocket.runtime.WebSocketClientBinarySender extends WebSocketClientSender<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

toPayload

Function<T,R> toPayload

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

Serialized Fields

connector

WebSocketClientConnector connector

toTuple

Function<T,R> toTuple

eventHandler

Consumer<T> eventHandler

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

Serialized Fields

destination

Consumer<T> destination

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

Serialized Fields

eventSetup

Consumer<T> eventSetup

Class quarks.oplet.functional.Filter extends Pipe<T,T> implements Serializable

serialVersionUID:

1L

Serialized Fields

filter

Predicate<T> filter

Class quarks.oplet.functional.FlatMap extends Pipe<I,O> implements Serializable

serialVersionUID:

1L

Serialized Fields

function

Function<T,R> function

Class quarks.oplet.functional.Map extends Pipe<I,O> implements Serializable

serialVersionUID:

1L

Serialized Fields

function

Function<T,R> function

Class quarks.oplet.functional.Peek extends Peek<T> implements Serializable

serialVersionUID:

1L

Serialized Fields

peeker

Consumer<T> peeker

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

Serialized Fields

executor

java.util.concurrent.ScheduledExecutorService executor

window

Window<T,K,L extends java.util.List<T>> window

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

Class quarks.oplet.window.Aggregate extends Pipe<T,U> implements Serializable

serialVersionUID:

1L

Serialized Fields

window

Window<T,K,L extends java.util.List<T>> window

aggregator

BiFunction<T,U,R> aggregator

The aggregator provided by the user.

Package quarks.runtime.etiao

Class quarks.runtime.etiao.SettableForwarder extends java.lang.Object implements Serializable

serialVersionUID:

1L

Serialized Fields

destination

Consumer<T> destination

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