package http

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. abstract class AsyncClient extends BaseClient
  2. class AsyncHTTPClient extends AsyncClient with HTTPClient
  3. trait ConcurrencyParams extends Wrappable
  4. class CustomInputParser extends HTTPInputParser with ComplexParamsWritable with BasicLogging
  5. class CustomOutputParser extends HTTPOutputParser with ComplexParamsWritable with BasicLogging
  6. case class EntityData(content: Array[Byte], contentEncoding: Option[HeaderData], contentLength: Option[Long], contentType: Option[HeaderData], isChunked: Boolean, isRepeatable: Boolean, isStreaming: Boolean) extends Product with Serializable
  7. abstract class HTTPInputParser extends Transformer with HasOutputCol with HasInputCol with Wrappable
  8. abstract class HTTPOutputParser extends Transformer with HasInputCol with HasOutputCol with Wrappable
  9. case class HTTPRequestData(requestLine: RequestLineData, headers: Array[HeaderData], entity: Option[EntityData]) extends Product with Serializable
  10. case class HTTPResponseData(headers: Array[HeaderData], entity: Option[EntityData], statusLine: StatusLineData, locale: String) extends Product with Serializable
  11. class HTTPTransformer extends Transformer with ConcurrencyParams with HasInputCol with HasOutputCol with HasHandler with ComplexParamsWritable with BasicLogging
  12. trait Handler extends AnyRef
  13. trait HasErrorCol extends Params
  14. trait HasHandler extends Params
  15. trait HasURL extends Params
  16. case class HeaderData(name: String, value: String) extends Product with Serializable
  17. class JSONInputParser extends HTTPInputParser with HasURL with ComplexParamsWritable with BasicLogging
  18. class JSONOutputParser extends HTTPOutputParser with ComplexParamsWritable with BasicLogging
  19. case class ProtocolVersionData(protocol: String, major: Int, minor: Int) extends Product with Serializable
  20. case class RequestLineData(method: String, uri: String, protocolVersion: Option[ProtocolVersionData]) extends Product with Serializable
  21. class SharedSingleton[T] extends Serializable

    Holds a variable shared among all workers that behaves like a local singleton.

    Holds a variable shared among all workers that behaves like a local singleton. Useful to use non-serializable objects in Spark closures that maintain state across tasks.

  22. class SharedVariable[T] extends Serializable

    Holds a variable shared among all workers.

    Holds a variable shared among all workers. Useful to use non-serializable objects in Spark closures.

    Note this code has been borrowed from: https://www.nicolaferraro.me/2016/02/22/using-non-serializable-objects-in-apache-spark/

  23. class SimpleHTTPTransformer extends Transformer with ConcurrencyParams with HasMiniBatcher with HasHandler with HasInputCol with HasOutputCol with ComplexParamsWritable with HasErrorCol with BasicLogging
  24. class SingleThreadedHTTPClient extends HTTPClient with SingleThreadedClient
  25. case class StatusLineData(protocolVersion: ProtocolVersionData, statusCode: Int, reasonPhrase: String) extends Product with Serializable
  26. class StringOutputParser extends HTTPOutputParser with ComplexParamsWritable with BasicLogging

Value Members

  1. object CustomInputParser extends ComplexParamsReadable[CustomInputParser] with Serializable
  2. object CustomOutputParser extends ComplexParamsReadable[CustomOutputParser] with Serializable
  3. object EntityData extends SparkBindings[EntityData]
  4. object ErrorUtils extends Serializable
  5. object HTTPRequestData extends SparkBindings[HTTPRequestData]
  6. object HTTPResponseData extends SparkBindings[HTTPResponseData] with Logging
  7. object HTTPSchema
  8. object HTTPTransformer extends ComplexParamsReadable[HTTPTransformer] with Serializable
  9. object HandlingUtils extends Logging
  10. object HeaderData extends SparkBindings[HeaderData]
  11. object HeaderValues
  12. object JSONInputParser extends ComplexParamsReadable[JSONInputParser] with Serializable
  13. object JSONOutputParser extends ComplexParamsReadable[JSONOutputParser] with Serializable
  14. object PortForwarding
  15. object ProtocolVersionData extends SparkBindings[ProtocolVersionData]
  16. object RESTHelpers
  17. object RequestLineData extends SparkBindings[RequestLineData]
  18. object SharedSingleton extends Serializable
  19. object SharedVariable extends Serializable
  20. object SimpleHTTPTransformer extends ComplexParamsReadable[SimpleHTTPTransformer] with Serializable
  21. object StatusLineData extends SparkBindings[StatusLineData]
  22. object StringOutputParser extends ComplexParamsReadable[StringOutputParser] with Serializable

Ungrouped