Package

org.apache.spark.sql.execution.streaming

continuous

Permalink

package continuous

Visibility
  1. Public
  2. All

Type Members

  1. case class HTTPCommitMessage(ids: Array[(String, Int)]) extends WriterCommitMessage with Product with Serializable

    Permalink
  2. class HTTPContinuousDataReader extends ContinuousDataReader[Row]

    Permalink
  3. case class HTTPContinuousDataReaderFactory(host: String, port: Int, name: String, startValue: Long, partitionIndex: Int, forwardingOptions: Map[String, String], driverServiceHost: String, driverServicePort: Int) extends DataReaderFactory[Row] with Product with Serializable

    Permalink
  4. class HTTPContinuousReader extends ContinuousReader

    Permalink
  5. class HTTPDataWriter extends DataWriter[Row] with Logging

    Permalink
  6. case class HTTPOffset(partitionToValue: Map[Int, Long]) extends sources.v2.reader.streaming.Offset with Product with Serializable

    Permalink
  7. case class HTTPPartitionOffset(partition: Int, currentValue: Long) extends PartitionOffset with Product with Serializable

    Permalink
  8. case class HTTPReaderInfo(host: String, port: Int, name: String, startValue: Long, partitionIndex: Int) extends Product with Serializable

    Permalink
  9. class HTTPSinkProviderV2 extends DataSourceV2 with StreamWriteSupport with DataSourceRegister

    Permalink
  10. class HTTPSourceProviderV2 extends DataSourceRegister with DataSourceV2 with ContinuousReadSupport

    Permalink
  11. class HTTPWriter extends StreamWriter with Logging

    Permalink

    Common methods used to create writes for the the console sink

  12. case class HTTPWriterFactory(idColIndex: Int, replyColIndex: Int, name: String) extends DataWriterFactory[Row] with Product with Serializable

    Permalink
  13. case class ServiceInfo(host: String, port: Int, name: String, partitionId: Int, localIp: String, publicIp: Option[String]) extends Product with Serializable

    Permalink

Ungrouped