http

Type Members

1. abstract class AsyncClient extends BaseClient

   

2. class AsyncHTTPClient extends AsyncClient with HTTPClient

   

3. class Consolidator[T] extends AnyRef

   

4. class CustomInputParser extends HTTPInputParser with ComplexParamsWritable

   

5. class CustomOutputParser extends HTTPOutputParser with ComplexParamsWritable

   

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

   

8. abstract class HTTPOutputParser extends Transformer with HasInputCol with HasOutputCol

   

9. trait HTTPParams extends Wrappable

   

10. case class HTTPRequestData(requestLine: RequestLineData, headers: Array[HeaderData], entity: Option[EntityData]) extends Product with Serializable

    

11. case class HTTPResponseData(headers: Array[HeaderData], entity: Option[EntityData], statusLine: StatusLineData, locale: String) extends Product with Serializable

    

12. class HTTPTransformer extends Transformer with HTTPParams with HasInputCol with HasOutputCol with HasHandler with ComplexParamsWritable

    

13. trait Handler extends AnyRef

    

14. trait HasErrorCol extends Params

    

15. trait HasHandler extends Params

    

16. trait HasURL extends Wrappable

    

17. case class HeaderData(name: String, value: String) extends Product with Serializable

    

18. class JSONInputParser extends HTTPInputParser with HasURL with ComplexParamsWritable

    

19. class JSONOutputParser extends HTTPOutputParser with ComplexParamsWritable

    

    Annotations

    @InternalWrapper()

20. class PartitionConsolidator extends Transformer with HTTPParams with HasInputCol with HasOutputCol with ComplexParamsWritable

    

21. case class ProtocolVersionData(protocol: String, major: Int, minor: Int) extends Product with Serializable

    

22. case class RequestLineData(method: String, uri: String, protocolVersion: Option[ProtocolVersionData]) extends Product with Serializable

    

23. 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.

24. 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/

25. class SimpleHTTPTransformer extends Transformer with HTTPParams with HasMiniBatcher with HasHandler with HasInputCol with HasOutputCol with ComplexParamsWritable with HasErrorCol

    

    Annotations

    @InternalWrapper()

26. class SingleThreadedHTTPClient extends HTTPClient with SingleThreadedClient

    

27. case class StatusLineData(protocolVersion: ProtocolVersionData, statusCode: Int, reasonPhrase: String) extends Product with Serializable

    

28. class StringOutputParser extends HTTPOutputParser with ComplexParamsWritable