| AbstractMeasuredStream<T,V extends Stats> |
|
| AbstractStream<T> |
Skeleton implementation of the Stream interface
|
| CloseHandler |
|
| ForwardingMeasuredStream<T,V extends Stats> |
|
| ForwardingStream<T> |
|
| FunctionAdapter |
Created by dgomezferro on 6/1/16.
|
| KryoDecoder |
|
| KryoEncoder |
|
| MeasuredStreams |
|
| MeasuredStreams.FilteredMeasuredStream<T,V extends Stats> |
|
| MeasuredStreams.LimitedStream<T,V extends Stats> |
|
| MeasuredStreams.TransformingMeasuredStream<E,R,V extends Stats> |
|
| PartitionState |
|
| QueryJob |
|
| QueryResult |
Created by dgomezferro on 5/25/16.
|
| RemoteQueryClientImpl |
Created by dgomezferro on 5/20/16.
|
| RemoteQueryJob |
Created by dgomezferro on 5/20/16.
|
| ResultStreamer<T> |
Created by dgomezferro on 5/25/16.
|
| SparkCompactionContext |
|
| StreamableRDD<T> |
Created by dgomezferro on 6/1/16.
|
| StreamIterator<T> |
Abstraction for using a Stream as an Iterator.
|
| StreamListener<T> |
This class handles connections from Spark tasks streaming data to the query client.
|
| StreamListenerServer<T> |
Created by dgomezferro on 5/20/16.
|
| StreamProtocol |
Created by dgomezferro on 6/3/16.
|
| StreamProtocol.ConfirmClose |
|
| StreamProtocol.Continue |
|
| StreamProtocol.Init |
|
| StreamProtocol.Limit |
|
| StreamProtocol.RequestClose |
|
| StreamProtocol.Skip |
|
| StreamProtocol.Skipped |
|
| Streams |
Utility classes around Streams.
|
| Streams.FilteredStream<T> |
|
| Streams.LimitedStream<T> |
|
| TransformingStream<T,V> |
|