Type Members

1.  trait DataLocation extends AnyRef

   An InputLocation is a data source definition, it can either be HDFS files or a JDBC database connection

   An InputLocation is a data source definition, it can either be HDFS files or a JDBC database connection

   Annotations

   @JsonTypeInfo() @JsonSubTypes()

2.  case class GenericLocation(format: String, mode: Option[String] = None) extends DataLocation with Product with Serializable

   Annotations

   @CaseClassDeserialize()

3.  case class Jdbc(url: String, dbtable: String, user: String = "", password: String = "", token: String = "") extends DataLocation with Product with Serializable

   Annotations

   @CaseClassDeserialize() @JsonIgnoreProperties()

4.  case class KafkaEndpoint(brokers: List[String], topics: List[String], schema: KafkaSchema) extends DataLocation with Product with Serializable

   Annotations

   @CaseClassDeserialize()

5.  case class KafkaSchema(type: String, avroJson: String) extends Product with Serializable

   Kafka source config.

   Kafka source config. Example: kafkaStreamingSource: { type: KAFKA config: { brokers: ["feathrazureci.servicebus.windows.net:9093"] topics: [feathrcieventhub] schema: { type = "avro" avroJson:"......" } } }

   Annotations

   @CaseClassDeserialize()

6.  case class PathList(paths: List[String]) extends DataLocation with Product with Serializable
7.  case class SimplePath(path: String) extends DataLocation with Product with Serializable

   Annotations

   @CaseClassDeserialize()