Module Values_0.AmazonRedshiftNodeDataSource

Specifies an Amazon Redshift node.

Sourcetype nonrec t = {
  1. accessType : GenericLimitedString.t option;
    (*

    The access type for the Redshift connection. Can be a direct connection or catalog connections.

    *)
  2. sourceType : GenericLimitedString.t option;
    (*

    The source type to specify whether a specific table is the source or a custom query.

    *)
  3. connection : Option_.t option;
    (*

    The Glue connection to the Redshift cluster.

    *)
  4. schema : Option_.t option;
    (*

    The Redshift schema name when working with a direct connection.

    *)
  5. table : Option_.t option;
    (*

    The Redshift table name when working with a direct connection.

    *)
  6. catalogDatabase : Option_.t option;
    (*

    The name of the Glue Data Catalog database when working with a data catalog.

    *)
  7. catalogTable : Option_.t option;
    (*

    The Glue Data Catalog table name when working with a data catalog.

    *)
  8. catalogRedshiftSchema : GenericString.t option;
    (*

    The Redshift schema name when working with a data catalog.

    *)
  9. catalogRedshiftTable : GenericString.t option;
    (*

    The database table to read from.

    *)
  10. tempDir : EnclosedInStringProperty.t option;
    (*

    The Amazon S3 path where temporary data can be staged when copying out of the database.

    *)
  11. iamRole : Option_.t option;
    (*

    Optional. The role name use when connection to S3. The IAM role ill default to the role on the job when left blank.

    *)
  12. advancedOptions : AmazonRedshiftAdvancedOptions.t option;
    (*

    Optional values when connecting to the Redshift cluster.

    *)
  13. sampleQuery : GenericString.t option;
    (*

    The SQL used to fetch the data from a Redshift sources when the SourceType is 'query'.

    *)
  14. preAction : GenericString.t option;
    (*

    The SQL used before a MERGE or APPEND with upsert is run.

    *)
  15. postAction : GenericString.t option;
    (*

    The SQL used before a MERGE or APPEND with upsert is run.

    *)
  16. action : GenericString.t option;
    (*

    Specifies how writing to a Redshift cluser will occur.

    *)
  17. tablePrefix : GenericLimitedString.t option;
    (*

    Specifies the prefix to a table.

    *)
  18. upsert : BooleanValue.t option;
    (*

    The action used on Redshift sinks when doing an APPEND.

    *)
  19. mergeAction : GenericLimitedString.t option;
    (*

    The action used when to detemine how a MERGE in a Redshift sink will be handled.

    *)
  20. mergeWhenMatched : GenericLimitedString.t option;
    (*

    The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record matches a new record.

    *)
  21. mergeWhenNotMatched : GenericLimitedString.t option;
    (*

    The action used when to detemine how a MERGE in a Redshift sink will be handled when an existing record doesn't match a new record.

    *)
  22. mergeClause : GenericString.t option;
    (*

    The SQL used in a custom merge to deal with matching records.

    *)
  23. crawlerConnection : GenericString.t option;
    (*

    Specifies the name of the connection that is associated with the catalog table used.

    *)
  24. tableSchema : OptionList.t option;
    (*

    The array of schema output for a given node.

    *)
  25. stagingTable : GenericString.t option;
    (*

    The name of the temporary staging table that is used when doing a MERGE or APPEND with upsert.

    *)
  26. selectedColumns : OptionList.t option;
    (*

    The list of column names used to determine a matching record when doing a MERGE or APPEND with upsert.

    *)
}
Sourceval make : ?accessType:??? -> ?sourceType:??? -> ?connection:??? -> ?schema:??? -> ?table:??? -> ?catalogDatabase:??? -> ?catalogTable:??? -> ?catalogRedshiftSchema:??? -> ?catalogRedshiftTable:??? -> ?tempDir:??? -> ?iamRole:??? -> ?advancedOptions:??? -> ?sampleQuery:??? -> ?preAction:??? -> ?postAction:??? -> ?action:??? -> ?tablePrefix:??? -> ?upsert:??? -> ?mergeAction:??? -> ?mergeWhenMatched:??? -> ?mergeWhenNotMatched:??? -> ?mergeClause:??? -> ?crawlerConnection:??? -> ?tableSchema:??? -> ?stagingTable:??? -> ?selectedColumns:??? -> unit -> t
Sourceval to_value : t -> [> `Structure of (string * [> `Boolean of BooleanValue.t | `List of [> `Structure of (string * [> `String of GenericString.t ]) list ] list | `String of GenericLimitedString.t | `Structure of (string * [> `String of EnclosedInStringProperty.t ]) list ]) list ]
Sourceval to_query : t -> Awso.Client.Query.t
Sourceval of_xml : Awso.Xml.t -> t
Sourceval of_string : string -> t
Sourceval of_json : Yojson.Safe.t -> t
Sourceval to_json : t -> Yojson.Safe.t