Package

com.krux.hyperion

datanode

Permalink

package datanode

Visibility
  1. Public
  2. All

Type Members

  1. trait Copyable extends DataNode

    Permalink

    The data node that can be used as input and output in CopyActivity

  2. trait DataNode extends NamedPipelineObject

    Permalink
  3. case class DataNodeFields(preconditions: Seq[Precondition] = Seq.empty, onFailAlarms: Seq[SnsAlarm] = Seq.empty, onSuccessAlarms: Seq[SnsAlarm] = Seq.empty) extends Product with Serializable

    Permalink
  4. case class InsertTableQuery(table: String, columns: List[String]) extends TableQuery with Product with Serializable

    Permalink
  5. case class RedshiftDataNode extends DataNode with Product with Serializable

    Permalink

    The abstracted RedshiftDataNode

  6. sealed trait S3DataNode extends Copyable

    Permalink
  7. case class S3DataNodeFields(dataFormat: Option[DataFormat] = None, manifestFilePath: Option[HS3Uri] = None, isEncrypted: HBoolean = HBoolean.True, isCompressed: HBoolean = HBoolean.False) extends Product with Serializable

    Permalink
  8. case class S3File extends S3DataNode with Product with Serializable

    Permalink

    Defines data from s3

  9. case class S3Folder extends S3DataNode with Product with Serializable

    Permalink

    Defines data from s3 directory

  10. case class SelectTableQuery(table: String, columns: List[String], whereClause: Option[String], distinct: Boolean = false) extends TableQuery with Product with Serializable

    Permalink
  11. case class SqlDataNode(baseFields: BaseFields, dataNodeFields: DataNodeFields, tableQuery: TableQuery, database: Database) extends Copyable with Product with Serializable

    Permalink

    Note

    that the AWS Datapipeline SqlDataNode does not require a JdbcDatabase parameter, but requires specify the username, password, etc. within the object, we require a JdbcDatabase object for consistency with other database data node objects.

  12. sealed trait TableQuery extends AnyRef

    Permalink

Value Members

  1. object RedshiftDataNode extends Serializable

    Permalink
  2. object S3DataNode

    Permalink
  3. object S3File extends Serializable

    Permalink
  4. object S3Folder extends Serializable

    Permalink
  5. object SqlDataNode extends Serializable

    Permalink

Ungrouped