Package

com.microsoft.ml.spark.io

http

Permalink

package http

Visibility
  1. Public
  2. All

Type Members

  1. abstract class AsyncClient extends BaseClient

    Permalink
  2. class AsyncHTTPClient extends AsyncClient with HTTPClient

    Permalink
  3. class Consolidator[T] extends AnyRef

    Permalink
  4. class CustomInputParser extends HTTPInputParser with ComplexParamsWritable

    Permalink
  5. class CustomOutputParser extends HTTPOutputParser with ComplexParamsWritable

    Permalink
  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

    Permalink
  7. abstract class HTTPInputParser extends Transformer with HasOutputCol with HasInputCol

    Permalink
  8. abstract class HTTPOutputParser extends Transformer with HasInputCol with HasOutputCol

    Permalink
  9. trait HTTPParams extends Wrappable

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

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

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

    Permalink
  13. trait Handler extends AnyRef

    Permalink
  14. trait HasErrorCol extends Params

    Permalink
  15. trait HasHandler extends Params

    Permalink
  16. trait HasURL extends Wrappable

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

    Permalink
  18. class JSONInputParser extends HTTPInputParser with HasURL with ComplexParamsWritable

    Permalink
  19. class JSONOutputParser extends HTTPOutputParser with ComplexParamsWritable

    Permalink
    Annotations
    @InternalWrapper()
  20. class PartitionConsolidator extends Transformer with HTTPParams with HasInputCol with HasOutputCol with ComplexParamsWritable

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

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

    Permalink
  23. class SharedSingleton[T] extends Serializable

    Permalink

    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

    Permalink

    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

    Permalink
    Annotations
    @InternalWrapper()
  26. class SingleThreadedHTTPClient extends HTTPClient with SingleThreadedClient

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

    Permalink
  28. class StringOutputParser extends HTTPOutputParser with ComplexParamsWritable

    Permalink

Value Members

  1. object CustomInputParser extends ComplexParamsReadable[CustomInputParser] with Serializable

    Permalink
  2. object CustomOutputParser extends ComplexParamsReadable[CustomOutputParser] with Serializable

    Permalink
  3. object EntityData extends SparkBindings[EntityData]

    Permalink
  4. object ErrorUtils extends Serializable

    Permalink
  5. object HTTPRequestData extends SparkBindings[HTTPRequestData]

    Permalink
  6. object HTTPResponseData extends SparkBindings[HTTPResponseData] with Logging

    Permalink
  7. object HTTPSchema

    Permalink
  8. object HTTPTransformer extends ComplexParamsReadable[HTTPTransformer] with Serializable

    Permalink
  9. object HandlingUtils extends Logging

    Permalink
  10. object HeaderData extends SparkBindings[HeaderData]

    Permalink
  11. object JSONInputParser extends ComplexParamsReadable[JSONInputParser] with Serializable

    Permalink
  12. object JSONOutputParser extends ComplexParamsReadable[JSONOutputParser] with Serializable

    Permalink
  13. object PartitionConsolidator extends DefaultParamsReadable[PartitionConsolidator] with Serializable

    Permalink
  14. object PortForwarding

    Permalink
  15. object ProtocolVersionData extends SparkBindings[ProtocolVersionData]

    Permalink
  16. object RequestLineData extends SparkBindings[RequestLineData]

    Permalink
  17. object SharedSingleton extends Serializable

    Permalink
  18. object SharedVariable extends Serializable

    Permalink
  19. object SimpleHTTPTransformer extends ComplexParamsReadable[SimpleHTTPTransformer] with Serializable

    Permalink
  20. object StatusLineData extends SparkBindings[StatusLineData]

    Permalink
  21. object StringOutputParser extends ComplexParamsReadable[StringOutputParser] with Serializable

    Permalink

Ungrouped