Packages

package streaming

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class DistributedHTTPSink extends Sink with Logging with Serializable
  2. class DistributedHTTPSinkProvider extends StreamSinkProvider with DataSourceRegister
  3. class DistributedHTTPSource extends Source with Logging with Serializable
  4. class DistributedHTTPSourceProvider extends StreamSourceProvider with DataSourceRegister with Logging
  5. class HTTPSink extends Sink with Logging
  6. class HTTPSinkProvider extends StreamSinkProvider with DataSourceRegister
  7. 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.

  8. class HTTPSourceProvider extends StreamSourceProvider with DataSourceRegister with Logging
  9. class JVMSharedServer extends Logging
  10. class MultiChannelMap[K, V] extends AnyRef

Value Members

  1. object DistributedHTTPSink extends Serializable
  2. object HTTPServerUtils
  3. object HTTPSource
  4. object ServingUDFs

Ungrouped