package http
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- abstract class AsyncClient extends BaseClient
- class AsyncHTTPClient extends AsyncClient with HTTPClient
- trait ConcurrencyParams extends Wrappable
- class CustomInputParser extends HTTPInputParser with ComplexParamsWritable with BasicLogging
- class CustomOutputParser extends HTTPOutputParser with ComplexParamsWritable with BasicLogging
- 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
- abstract class HTTPInputParser extends Transformer with HasOutputCol with HasInputCol with Wrappable
- abstract class HTTPOutputParser extends Transformer with HasInputCol with HasOutputCol with Wrappable
- case class HTTPRequestData(requestLine: RequestLineData, headers: Array[HeaderData], entity: Option[EntityData]) extends Product with Serializable
- case class HTTPResponseData(headers: Array[HeaderData], entity: Option[EntityData], statusLine: StatusLineData, locale: String) extends Product with Serializable
- class HTTPTransformer extends Transformer with ConcurrencyParams with HasInputCol with HasOutputCol with HasHandler with ComplexParamsWritable with BasicLogging
- trait Handler extends AnyRef
- trait HasErrorCol extends Params
- trait HasHandler extends Params
- trait HasURL extends Params
- case class HeaderData(name: String, value: String) extends Product with Serializable
- class JSONInputParser extends HTTPInputParser with HasURL with ComplexParamsWritable with BasicLogging
- class JSONOutputParser extends HTTPOutputParser with ComplexParamsWritable with BasicLogging
- case class ProtocolVersionData(protocol: String, major: Int, minor: Int) extends Product with Serializable
- case class RequestLineData(method: String, uri: String, protocolVersion: Option[ProtocolVersionData]) extends Product with Serializable
-
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.
-
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/
- class SimpleHTTPTransformer extends Transformer with ConcurrencyParams with HasMiniBatcher with HasHandler with HasInputCol with HasOutputCol with ComplexParamsWritable with HasErrorCol with BasicLogging
- class SingleThreadedHTTPClient extends HTTPClient with SingleThreadedClient
- case class StatusLineData(protocolVersion: ProtocolVersionData, statusCode: Int, reasonPhrase: String) extends Product with Serializable
- class StringOutputParser extends HTTPOutputParser with ComplexParamsWritable with BasicLogging
Value Members
- object CustomInputParser extends ComplexParamsReadable[CustomInputParser] with Serializable
- object CustomOutputParser extends ComplexParamsReadable[CustomOutputParser] with Serializable
- object EntityData extends SparkBindings[EntityData]
- object ErrorUtils extends Serializable
- object HTTPRequestData extends SparkBindings[HTTPRequestData]
- object HTTPResponseData extends SparkBindings[HTTPResponseData] with Logging
- object HTTPSchema
- object HTTPTransformer extends ComplexParamsReadable[HTTPTransformer] with Serializable
- object HandlingUtils extends Logging
- object HeaderData extends SparkBindings[HeaderData]
- object HeaderValues
- object JSONInputParser extends ComplexParamsReadable[JSONInputParser] with Serializable
- object JSONOutputParser extends ComplexParamsReadable[JSONOutputParser] with Serializable
- object PortForwarding
- object ProtocolVersionData extends SparkBindings[ProtocolVersionData]
- object RequestLineData extends SparkBindings[RequestLineData]
- object SharedSingleton extends Serializable
- object SharedVariable extends Serializable
- object SimpleHTTPTransformer extends ComplexParamsReadable[SimpleHTTPTransformer] with Serializable
- object StatusLineData extends SparkBindings[StatusLineData]
- object StringOutputParser extends ComplexParamsReadable[StringOutputParser] with Serializable