Package

org.apache.spark.sql.execution

streaming

Permalink

package streaming

Visibility
  1. Public
  2. All

Type Members

  1. class DistributedHTTPSink extends Sink with Logging with Serializable

    Permalink
  2. class DistributedHTTPSinkProvider extends StreamSinkProvider with DataSourceRegister

    Permalink
  3. class DistributedHTTPSource extends Source with Logging with Serializable

    Permalink
  4. class DistributedHTTPSourceProvider extends StreamSourceProvider with DataSourceRegister with Logging

    Permalink
  5. class HTTPSink extends Sink with Logging

    Permalink
  6. class HTTPSinkProvider extends StreamSinkProvider with DataSourceRegister

    Permalink
  7. class HTTPSource extends Source with Logging

    Permalink

    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

    Permalink
  9. class JVMSharedServer extends Logging

    Permalink
  10. class MultiChannelMap[K, V] extends AnyRef

    Permalink

Value Members

  1. object DistributedHTTPSink extends Serializable

    Permalink
  2. object HTTPServerUtils

    Permalink
  3. object HTTPSource

    Permalink
  4. object ServingUDFs

    Permalink
  5. package continuous

    Permalink

Ungrouped