object Outputs
- Alphabetic
- By Inheritance
- Outputs
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
-
final
case class
AvroFileOutputConfig(path: URI) extends FileOutputConfig with AvroFileConfig with Product with Serializable
Avro file output configuration
Avro file output configuration
- path
Path to file
-
final
case class
DelimitedFileOutputConfig(path: URI, delimiter: NonEmptyString = ",", quote: NonEmptyString = "\"", escape: NonEmptyString = "\\", header: Boolean = false) extends FileOutputConfig with DelimitedFileConfig with Product with Serializable
Delimited file output configuration
Delimited file output configuration
- path
Path to file
- delimiter
Column delimiter (default: ,)
- quote
Quotation symbol (default: ")
- escape
Escape symbol (default: \)
- header
Boolean flag indicating whether schema should be read from file header (default: false)
-
trait
EmailOutputConfig extends NotificationOutputConfig
Base trait for targets that are sent via email.
Base trait for targets that are sent via email. Configuration for such targets must contain non-empty sequence of recipients' emails. An optional message template can be provided in form of either an explicit string or an URI to template file location. In addition, email subject can be customized by providing optional subject template.
-
sealed
trait
FileOutputConfig extends OutputConfig with FileConfig
Base class for file outputs.
-
trait
HiveOutputConfig extends OutputConfig
Base trait for targets that are written to Hive table.
Base trait for targets that are written to Hive table. Configuration for such targets must contain Hive schema and Hive table in which target data will be inserted.
-
trait
KafkaOutputConfig extends OutputConfig
Base trait for targets that are sent to Kafka topic.
Base trait for targets that are sent to Kafka topic. Configuration for such targets must contain reference to a connection ID (must be Kafka connection) and topic name to write target data into.
-
trait
MattermostOutputConfig extends NotificationOutputConfig
Base trait for targets that are sent as messages to mattermost (to a channels or to users' as direct messages).
Base trait for targets that are sent as messages to mattermost (to a channels or to users' as direct messages). Configuration for such targets must contain non-empty sequence of recipient: either a channel names prefixed with '#' symbol or usernames prefixed with '@' symbols. In addition an optional message template can be provided in form of either an explicit string or an URI to template file location.
- Note
Mattermost message do not have subjects, therefore, subjectTemplate is set to None
-
trait
NotificationOutputConfig extends OutputConfig
Base trait for target that are send as notifications to end users.
Base trait for target that are send as notifications to end users. Configuration for such targets must contain a list of recipients to receive that notification In addition an optional message template can be provided in form of either an explicit string or an URI to template file location.
-
final
case class
OrcFileOutputConfig(path: URI) extends FileOutputConfig with OrcFileConfig with Product with Serializable
Orc file output configuration
Orc file output configuration
- path
Path to file
-
trait
OutputConfig extends AnyRef
Base class for all outputs configurations
-
final
case class
ParquetFileOutputConfig(path: URI) extends FileOutputConfig with ParquetFileConfig with Product with Serializable
Parquet file output configuration
Parquet file output configuration
- path
Path to file
-
trait
SaveToFileConfig extends OutputConfig
Base class for
save to a file
configurationBase class for
save to a file
configuration- Note
Idea here is that instead of building multiple subclasses for each supported output file format, configuration will contain
save
parameter with FileOutputConfig of specifickind
(format).
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()