package streaming
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- class DistributedHTTPSink extends Sink with Logging with Serializable
- class DistributedHTTPSinkProvider extends StreamSinkProvider with DataSourceRegister
- class DistributedHTTPSource extends Source with Logging with Serializable
- class DistributedHTTPSourceProvider extends StreamSourceProvider with DataSourceRegister with Logging
- class HTTPSink extends Sink with Logging
- class HTTPSinkProvider extends StreamSinkProvider with DataSourceRegister
-
class
HTTPSource extends Source with Logging
A source that reads text lines through a TCP socket, designed only for tutorials and debugging.
A source that reads text lines through a TCP socket, designed only for tutorials and debugging. This source will *not* work in production applications due to multiple reasons, including no support for fault recovery and keeping all of the text read in memory forever.
- class HTTPSourceProvider extends StreamSourceProvider with DataSourceRegister with Logging
- class JVMSharedServer extends Logging
- class MultiChannelMap[K, V] extends AnyRef
Value Members
- object DistributedHTTPSink extends Serializable
- object HTTPServerUtils
- object HTTPSource
- object ServingUDFs