glue

package
v0.18.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 5, 2019 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CatalogDatabase 

type CatalogDatabase struct {
	// contains filtered or unexported fields
}

Provides a Glue Catalog Database Resource. You can refer to the [Glue Developer Guide](http://docs.aws.amazon.com/glue/latest/dg/populate-data-catalog.html) for a full explanation of the Glue Data Catalog functionality

func GetCatalogDatabase 

func GetCatalogDatabase(ctx *pulumi.Context,
	name string, id pulumi.ID, state *CatalogDatabaseState, opts ...pulumi.ResourceOpt) (*CatalogDatabase, error)

GetCatalogDatabase gets an existing CatalogDatabase resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewCatalogDatabase 

func NewCatalogDatabase(ctx *pulumi.Context,
	name string, args *CatalogDatabaseArgs, opts ...pulumi.ResourceOpt) (*CatalogDatabase, error)

NewCatalogDatabase registers a new resource with the given unique name, arguments, and options.

func (*CatalogDatabase) CatalogId 

func (r *CatalogDatabase) CatalogId() *pulumi.StringOutput

ID of the Glue Catalog to create the database in. If omitted, this defaults to the AWS Account ID.

func (*CatalogDatabase) Description 

func (r *CatalogDatabase) Description() *pulumi.StringOutput

Description of the database.

func (*CatalogDatabase) ID 

func (r *CatalogDatabase) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*CatalogDatabase) LocationUri 

func (r *CatalogDatabase) LocationUri() *pulumi.StringOutput

The location of the database (for example, an HDFS path).

func (*CatalogDatabase) Name 

func (r *CatalogDatabase) Name() *pulumi.StringOutput

The name of the database.

func (*CatalogDatabase) Parameters 

func (r *CatalogDatabase) Parameters() *pulumi.MapOutput

A list of key-value pairs that define parameters and properties of the database.

func (*CatalogDatabase) URN 

func (r *CatalogDatabase) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type CatalogDatabaseArgs 

type CatalogDatabaseArgs struct {
	// ID of the Glue Catalog to create the database in. If omitted, this defaults to the AWS Account ID.
	CatalogId interface{}
	// Description of the database.
	Description interface{}
	// The location of the database (for example, an HDFS path).
	LocationUri interface{}
	// The name of the database.
	Name interface{}
	// A list of key-value pairs that define parameters and properties of the database.
	Parameters interface{}
}

The set of arguments for constructing a CatalogDatabase resource.

type CatalogDatabaseState 

type CatalogDatabaseState struct {
	// ID of the Glue Catalog to create the database in. If omitted, this defaults to the AWS Account ID.
	CatalogId interface{}
	// Description of the database.
	Description interface{}
	// The location of the database (for example, an HDFS path).
	LocationUri interface{}
	// The name of the database.
	Name interface{}
	// A list of key-value pairs that define parameters and properties of the database.
	Parameters interface{}
}

Input properties used for looking up and filtering CatalogDatabase resources.

type CatalogTable 

type CatalogTable struct {
	// contains filtered or unexported fields
}

Provides a Glue Catalog Table Resource. You can refer to the [Glue Developer Guide](http://docs.aws.amazon.com/glue/latest/dg/populate-data-catalog.html) for a full explanation of the Glue Data Catalog functionality.

func GetCatalogTable 

func GetCatalogTable(ctx *pulumi.Context,
	name string, id pulumi.ID, state *CatalogTableState, opts ...pulumi.ResourceOpt) (*CatalogTable, error)

GetCatalogTable gets an existing CatalogTable resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewCatalogTable 

func NewCatalogTable(ctx *pulumi.Context,
	name string, args *CatalogTableArgs, opts ...pulumi.ResourceOpt) (*CatalogTable, error)

NewCatalogTable registers a new resource with the given unique name, arguments, and options.

func (*CatalogTable) CatalogId 

func (r *CatalogTable) CatalogId() *pulumi.StringOutput

ID of the Glue Catalog and database to create the table in. If omitted, this defaults to the AWS Account ID plus the database name.

func (*CatalogTable) DatabaseName 

func (r *CatalogTable) DatabaseName() *pulumi.StringOutput

Name of the metadata database where the table metadata resides. For Hive compatibility, this must be all lowercase.

func (*CatalogTable) Description 

func (r *CatalogTable) Description() *pulumi.StringOutput

Description of the table.

func (*CatalogTable) ID 

func (r *CatalogTable) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*CatalogTable) Name 

func (r *CatalogTable) Name() *pulumi.StringOutput

Name of the SerDe.

func (*CatalogTable) Owner 

func (r *CatalogTable) Owner() *pulumi.StringOutput

Owner of the table.

func (*CatalogTable) Parameters 

func (r *CatalogTable) Parameters() *pulumi.MapOutput

A map of initialization parameters for the SerDe, in key-value form.

func (*CatalogTable) PartitionKeys 

func (r *CatalogTable) PartitionKeys() *pulumi.ArrayOutput

A list of columns by which the table is partitioned. Only primitive types are supported as partition keys.

func (*CatalogTable) Retention 

func (r *CatalogTable) Retention() *pulumi.IntOutput

Retention time for this table.

func (*CatalogTable) StorageDescriptor 

func (r *CatalogTable) StorageDescriptor() *pulumi.Output

A storage descriptor object containing information about the physical storage of this table. You can refer to the [Glue Developer Guide](https://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-catalog-tables.html#aws-glue-api-catalog-tables-StorageDescriptor) for a full explanation of this object.

func (*CatalogTable) TableType 

func (r *CatalogTable) TableType() *pulumi.StringOutput

The type of this table (EXTERNAL_TABLE, VIRTUAL_VIEW, etc.).

func (*CatalogTable) URN 

func (r *CatalogTable) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

func (*CatalogTable) ViewExpandedText 

func (r *CatalogTable) ViewExpandedText() *pulumi.StringOutput

If the table is a view, the expanded text of the view; otherwise null.

func (*CatalogTable) ViewOriginalText 

func (r *CatalogTable) ViewOriginalText() *pulumi.StringOutput

If the table is a view, the original text of the view; otherwise null.

type CatalogTableArgs 

type CatalogTableArgs struct {
	// ID of the Glue Catalog and database to create the table in. If omitted, this defaults to the AWS Account ID plus the database name.
	CatalogId interface{}
	// Name of the metadata database where the table metadata resides. For Hive compatibility, this must be all lowercase.
	DatabaseName interface{}
	// Description of the table.
	Description interface{}
	// Name of the SerDe.
	Name interface{}
	// Owner of the table.
	Owner interface{}
	// A map of initialization parameters for the SerDe, in key-value form.
	Parameters interface{}
	// A list of columns by which the table is partitioned. Only primitive types are supported as partition keys.
	PartitionKeys interface{}
	// Retention time for this table.
	Retention interface{}
	// A storage descriptor object containing information about the physical storage of this table. You can refer to the [Glue Developer Guide](https://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-catalog-tables.html#aws-glue-api-catalog-tables-StorageDescriptor) for a full explanation of this object.
	StorageDescriptor interface{}
	// The type of this table (EXTERNAL_TABLE, VIRTUAL_VIEW, etc.).
	TableType interface{}
	// If the table is a view, the expanded text of the view; otherwise null.
	ViewExpandedText interface{}
	// If the table is a view, the original text of the view; otherwise null.
	ViewOriginalText interface{}
}

The set of arguments for constructing a CatalogTable resource.

type CatalogTableState 

type CatalogTableState struct {
	// ID of the Glue Catalog and database to create the table in. If omitted, this defaults to the AWS Account ID plus the database name.
	CatalogId interface{}
	// Name of the metadata database where the table metadata resides. For Hive compatibility, this must be all lowercase.
	DatabaseName interface{}
	// Description of the table.
	Description interface{}
	// Name of the SerDe.
	Name interface{}
	// Owner of the table.
	Owner interface{}
	// A map of initialization parameters for the SerDe, in key-value form.
	Parameters interface{}
	// A list of columns by which the table is partitioned. Only primitive types are supported as partition keys.
	PartitionKeys interface{}
	// Retention time for this table.
	Retention interface{}
	// A storage descriptor object containing information about the physical storage of this table. You can refer to the [Glue Developer Guide](https://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-catalog-tables.html#aws-glue-api-catalog-tables-StorageDescriptor) for a full explanation of this object.
	StorageDescriptor interface{}
	// The type of this table (EXTERNAL_TABLE, VIRTUAL_VIEW, etc.).
	TableType interface{}
	// If the table is a view, the expanded text of the view; otherwise null.
	ViewExpandedText interface{}
	// If the table is a view, the original text of the view; otherwise null.
	ViewOriginalText interface{}
}

Input properties used for looking up and filtering CatalogTable resources.

type Classifier 

type Classifier struct {
	// contains filtered or unexported fields
}

Provides a Glue Classifier resource.

> **NOTE:** It is only valid to create one type of classifier (grok, JSON, or XML). Changing classifier types will recreate the classifier.

func GetClassifier 

func GetClassifier(ctx *pulumi.Context,
	name string, id pulumi.ID, state *ClassifierState, opts ...pulumi.ResourceOpt) (*Classifier, error)

GetClassifier gets an existing Classifier resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewClassifier 

func NewClassifier(ctx *pulumi.Context,
	name string, args *ClassifierArgs, opts ...pulumi.ResourceOpt) (*Classifier, error)

NewClassifier registers a new resource with the given unique name, arguments, and options.

func (*Classifier) GrokClassifier 

func (r *Classifier) GrokClassifier() *pulumi.Output

A classifier that uses grok patterns. Defined below.

func (*Classifier) ID 

func (r *Classifier) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Classifier) JsonClassifier 

func (r *Classifier) JsonClassifier() *pulumi.Output

A classifier for JSON content. Defined below.

func (*Classifier) Name 

func (r *Classifier) Name() *pulumi.StringOutput

The name of the classifier.

func (*Classifier) URN 

func (r *Classifier) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

func (*Classifier) XmlClassifier 

func (r *Classifier) XmlClassifier() *pulumi.Output

A classifier for XML content. Defined below.

type ClassifierArgs 

type ClassifierArgs struct {
	// A classifier that uses grok patterns. Defined below.
	GrokClassifier interface{}
	// A classifier for JSON content. Defined below.
	JsonClassifier interface{}
	// The name of the classifier.
	Name interface{}
	// A classifier for XML content. Defined below.
	XmlClassifier interface{}
}

The set of arguments for constructing a Classifier resource.

type ClassifierState 

type ClassifierState struct {
	// A classifier that uses grok patterns. Defined below.
	GrokClassifier interface{}
	// A classifier for JSON content. Defined below.
	JsonClassifier interface{}
	// The name of the classifier.
	Name interface{}
	// A classifier for XML content. Defined below.
	XmlClassifier interface{}
}

Input properties used for looking up and filtering Classifier resources.

type Connection 

type Connection struct {
	// contains filtered or unexported fields
}

Provides a Glue Connection resource.

func GetConnection 

func GetConnection(ctx *pulumi.Context,
	name string, id pulumi.ID, state *ConnectionState, opts ...pulumi.ResourceOpt) (*Connection, error)

GetConnection gets an existing Connection resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewConnection 

func NewConnection(ctx *pulumi.Context,
	name string, args *ConnectionArgs, opts ...pulumi.ResourceOpt) (*Connection, error)

NewConnection registers a new resource with the given unique name, arguments, and options.

func (*Connection) CatalogId 

func (r *Connection) CatalogId() *pulumi.StringOutput

The ID of the Data Catalog in which to create the connection. If none is supplied, the AWS account ID is used by default.

func (*Connection) ConnectionProperties 

func (r *Connection) ConnectionProperties() *pulumi.MapOutput

A map of key-value pairs used as parameters for this connection.

func (*Connection) ConnectionType 

func (r *Connection) ConnectionType() *pulumi.StringOutput

The type of the connection. Defaults to `JBDC`.

func (*Connection) Description 

func (r *Connection) Description() *pulumi.StringOutput

Description of the connection.

func (*Connection) ID 

func (r *Connection) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Connection) MatchCriterias 

func (r *Connection) MatchCriterias() *pulumi.ArrayOutput

A list of criteria that can be used in selecting this connection.

func (*Connection) Name 

func (r *Connection) Name() *pulumi.StringOutput

The name of the connection.

func (*Connection) PhysicalConnectionRequirements 

func (r *Connection) PhysicalConnectionRequirements() *pulumi.Output

A map of physical connection requirements, such as VPC and SecurityGroup. Defined below.

func (*Connection) URN 

func (r *Connection) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type ConnectionArgs 

type ConnectionArgs struct {
	// The ID of the Data Catalog in which to create the connection. If none is supplied, the AWS account ID is used by default.
	CatalogId interface{}
	// A map of key-value pairs used as parameters for this connection.
	ConnectionProperties interface{}
	// The type of the connection. Defaults to `JBDC`.
	ConnectionType interface{}
	// Description of the connection.
	Description interface{}
	// A list of criteria that can be used in selecting this connection.
	MatchCriterias interface{}
	// The name of the connection.
	Name interface{}
	// A map of physical connection requirements, such as VPC and SecurityGroup. Defined below.
	PhysicalConnectionRequirements interface{}
}

The set of arguments for constructing a Connection resource.

type ConnectionState 

type ConnectionState struct {
	// The ID of the Data Catalog in which to create the connection. If none is supplied, the AWS account ID is used by default.
	CatalogId interface{}
	// A map of key-value pairs used as parameters for this connection.
	ConnectionProperties interface{}
	// The type of the connection. Defaults to `JBDC`.
	ConnectionType interface{}
	// Description of the connection.
	Description interface{}
	// A list of criteria that can be used in selecting this connection.
	MatchCriterias interface{}
	// The name of the connection.
	Name interface{}
	// A map of physical connection requirements, such as VPC and SecurityGroup. Defined below.
	PhysicalConnectionRequirements interface{}
}

Input properties used for looking up and filtering Connection resources.

type Crawler added in v0.14.2 

type Crawler struct {
	// contains filtered or unexported fields
}

Manages a Glue Crawler. More information can be found in the [AWS Glue Developer Guide](https://docs.aws.amazon.com/glue/latest/dg/add-crawler.html)

func GetCrawler added in v0.14.2 

func GetCrawler(ctx *pulumi.Context,
	name string, id pulumi.ID, state *CrawlerState, opts ...pulumi.ResourceOpt) (*Crawler, error)

GetCrawler gets an existing Crawler resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewCrawler added in v0.14.2 

func NewCrawler(ctx *pulumi.Context,
	name string, args *CrawlerArgs, opts ...pulumi.ResourceOpt) (*Crawler, error)

NewCrawler registers a new resource with the given unique name, arguments, and options.

func (*Crawler) Arn added in v0.18.0 

func (r *Crawler) Arn() *pulumi.StringOutput

The ARN of the crawler

func (*Crawler) Classifiers added in v0.14.2 

func (r *Crawler) Classifiers() *pulumi.ArrayOutput

List of custom classifiers. By default, all AWS classifiers are included in a crawl, but these custom classifiers always override the default classifiers for a given classification.

func (*Crawler) Configuration added in v0.14.2 

func (r *Crawler) Configuration() *pulumi.StringOutput

JSON string of configuration information.

func (*Crawler) DatabaseName added in v0.14.2 

func (r *Crawler) DatabaseName() *pulumi.StringOutput

Glue database where results are written.

func (*Crawler) Description added in v0.14.2 

func (r *Crawler) Description() *pulumi.StringOutput

Description of the crawler.

func (*Crawler) DynamodbTargets added in v0.15.1 

func (r *Crawler) DynamodbTargets() *pulumi.ArrayOutput

List of nested DynamoDB target arguments. See below.

func (*Crawler) ID added in v0.14.2 

func (r *Crawler) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Crawler) JdbcTargets added in v0.14.2 

func (r *Crawler) JdbcTargets() *pulumi.ArrayOutput

List of nested JBDC target arguments. See below.

func (*Crawler) Name added in v0.14.2 

func (r *Crawler) Name() *pulumi.StringOutput

Name of the crawler.

func (*Crawler) Role added in v0.14.2 

func (r *Crawler) Role() *pulumi.StringOutput

The IAM role friendly name (including path without leading slash), or ARN of an IAM role, used by the crawler to access other resources.

func (*Crawler) S3Targets added in v0.14.2 

func (r *Crawler) S3Targets() *pulumi.ArrayOutput

List nested Amazon S3 target arguments. See below.

func (*Crawler) Schedule added in v0.14.2 

func (r *Crawler) Schedule() *pulumi.StringOutput

A cron expression used to specify the schedule. For more information, see [Time-Based Schedules for Jobs and Crawlers](https://docs.aws.amazon.com/glue/latest/dg/monitor-data-warehouse-schedule.html). For example, to run something every day at 12:15 UTC, you would specify: `cron(15 12 * * ? *)`.

func (*Crawler) SchemaChangePolicy added in v0.14.2 

func (r *Crawler) SchemaChangePolicy() *pulumi.Output

Policy for the crawler's update and deletion behavior.

func (*Crawler) SecurityConfiguration added in v0.16.4 

func (r *Crawler) SecurityConfiguration() *pulumi.StringOutput

The name of Security Configuration to be used by the crawler

func (*Crawler) TablePrefix added in v0.14.2 

func (r *Crawler) TablePrefix() *pulumi.StringOutput

The table prefix used for catalog tables that are created.

func (*Crawler) URN added in v0.14.2 

func (r *Crawler) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type CrawlerArgs added in v0.14.2 

type CrawlerArgs struct {
	// List of custom classifiers. By default, all AWS classifiers are included in a crawl, but these custom classifiers always override the default classifiers for a given classification.
	Classifiers interface{}
	// JSON string of configuration information.
	Configuration interface{}
	// Glue database where results are written.
	DatabaseName interface{}
	// Description of the crawler.
	Description interface{}
	// List of nested DynamoDB target arguments. See below.
	DynamodbTargets interface{}
	// List of nested JBDC target arguments. See below.
	JdbcTargets interface{}
	// Name of the crawler.
	Name interface{}
	// The IAM role friendly name (including path without leading slash), or ARN of an IAM role, used by the crawler to access other resources.
	Role interface{}
	// List nested Amazon S3 target arguments. See below.
	S3Targets interface{}
	// A cron expression used to specify the schedule. For more information, see [Time-Based Schedules for Jobs and Crawlers](https://docs.aws.amazon.com/glue/latest/dg/monitor-data-warehouse-schedule.html). For example, to run something every day at 12:15 UTC, you would specify: `cron(15 12 * * ? *)`.
	Schedule interface{}
	// Policy for the crawler's update and deletion behavior.
	SchemaChangePolicy interface{}
	// The name of Security Configuration to be used by the crawler
	SecurityConfiguration interface{}
	// The table prefix used for catalog tables that are created.
	TablePrefix interface{}
}

The set of arguments for constructing a Crawler resource.

type CrawlerState added in v0.14.2 

type CrawlerState struct {
	// The ARN of the crawler
	Arn interface{}
	// List of custom classifiers. By default, all AWS classifiers are included in a crawl, but these custom classifiers always override the default classifiers for a given classification.
	Classifiers interface{}
	// JSON string of configuration information.
	Configuration interface{}
	// Glue database where results are written.
	DatabaseName interface{}
	// Description of the crawler.
	Description interface{}
	// List of nested DynamoDB target arguments. See below.
	DynamodbTargets interface{}
	// List of nested JBDC target arguments. See below.
	JdbcTargets interface{}
	// Name of the crawler.
	Name interface{}
	// The IAM role friendly name (including path without leading slash), or ARN of an IAM role, used by the crawler to access other resources.
	Role interface{}
	// List nested Amazon S3 target arguments. See below.
	S3Targets interface{}
	// A cron expression used to specify the schedule. For more information, see [Time-Based Schedules for Jobs and Crawlers](https://docs.aws.amazon.com/glue/latest/dg/monitor-data-warehouse-schedule.html). For example, to run something every day at 12:15 UTC, you would specify: `cron(15 12 * * ? *)`.
	Schedule interface{}
	// Policy for the crawler's update and deletion behavior.
	SchemaChangePolicy interface{}
	// The name of Security Configuration to be used by the crawler
	SecurityConfiguration interface{}
	// The table prefix used for catalog tables that are created.
	TablePrefix interface{}
}

Input properties used for looking up and filtering Crawler resources.

type GetScriptArgs 

type GetScriptArgs struct {
	// A list of the edges in the DAG. Defined below.
	DagEdges interface{}
	// A list of the nodes in the DAG. Defined below.
	DagNodes interface{}
	// The programming language of the resulting code from the DAG. Defaults to `PYTHON`. Valid values are `PYTHON` and `SCALA`.
	Language interface{}
}

A collection of arguments for invoking getScript.

type GetScriptResult 

type GetScriptResult struct {
	// The Python script generated from the DAG when the `language` argument is set to `PYTHON`.
	PythonScript interface{}
	// The Scala code generated from the DAG when the `language` argument is set to `SCALA`.
	ScalaCode interface{}
	// id is the provider-assigned unique ID for this managed resource.
	Id interface{}
}

A collection of values returned by getScript.

func LookupScript 

func LookupScript(ctx *pulumi.Context, args *GetScriptArgs) (*GetScriptResult, error)

Use this data source to generate a Glue script from a Directed Acyclic Graph (DAG).

type Job 

type Job struct {
	// contains filtered or unexported fields
}

Provides a Glue Job resource.

func GetJob 

func GetJob(ctx *pulumi.Context,
	name string, id pulumi.ID, state *JobState, opts ...pulumi.ResourceOpt) (*Job, error)

GetJob gets an existing Job resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewJob 

func NewJob(ctx *pulumi.Context,
	name string, args *JobArgs, opts ...pulumi.ResourceOpt) (*Job, error)

NewJob registers a new resource with the given unique name, arguments, and options.

func (*Job) AllocatedCapacity 

func (r *Job) AllocatedCapacity() *pulumi.IntOutput

The number of AWS Glue data processing units (DPUs) to allocate to this Job. At least 2 DPUs need to be allocated; the default is 10. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory.

func (*Job) Command 

func (r *Job) Command() *pulumi.Output

The command of the job. Defined below.

func (*Job) Connections 

func (r *Job) Connections() *pulumi.ArrayOutput

The list of connections used for this job.

func (*Job) DefaultArguments 

func (r *Job) DefaultArguments() *pulumi.MapOutput

The map of default arguments for this job. You can specify arguments here that your own job-execution script consumes, as well as arguments that AWS Glue itself consumes. For information about how to specify and consume your own Job arguments, see the [Calling AWS Glue APIs in Python](http://docs.aws.amazon.com/glue/latest/dg/aws-glue-programming-python-calling.html) topic in the developer guide. For information about the key-value pairs that AWS Glue consumes to set up your job, see the [Special Parameters Used by AWS Glue](http://docs.aws.amazon.com/glue/latest/dg/aws-glue-programming-python-glue-arguments.html) topic in the developer guide.

func (*Job) Description 

func (r *Job) Description() *pulumi.StringOutput

Description of the job.

func (*Job) ExecutionProperty 

func (r *Job) ExecutionProperty() *pulumi.Output

Execution property of the job. Defined below.

func (*Job) ID 

func (r *Job) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Job) MaxRetries 

func (r *Job) MaxRetries() *pulumi.IntOutput

The maximum number of times to retry this job if it fails.

func (*Job) Name 

func (r *Job) Name() *pulumi.StringOutput

The name of the job command. Defaults to `glueetl`

func (*Job) RoleArn 

func (r *Job) RoleArn() *pulumi.StringOutput

The ARN of the IAM role associated with this job.

func (*Job) SecurityConfiguration added in v0.16.2 

func (r *Job) SecurityConfiguration() *pulumi.StringOutput

The name of the Security Configuration to be associated with the job.

func (*Job) Timeout 

func (r *Job) Timeout() *pulumi.IntOutput

The job timeout in minutes. The default is 2880 minutes (48 hours).

func (*Job) URN 

func (r *Job) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type JobArgs 

type JobArgs struct {
	// The number of AWS Glue data processing units (DPUs) to allocate to this Job. At least 2 DPUs need to be allocated; the default is 10. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory.
	AllocatedCapacity interface{}
	// The command of the job. Defined below.
	Command interface{}
	// The list of connections used for this job.
	Connections interface{}
	// The map of default arguments for this job. You can specify arguments here that your own job-execution script consumes, as well as arguments that AWS Glue itself consumes. For information about how to specify and consume your own Job arguments, see the [Calling AWS Glue APIs in Python](http://docs.aws.amazon.com/glue/latest/dg/aws-glue-programming-python-calling.html) topic in the developer guide. For information about the key-value pairs that AWS Glue consumes to set up your job, see the [Special Parameters Used by AWS Glue](http://docs.aws.amazon.com/glue/latest/dg/aws-glue-programming-python-glue-arguments.html) topic in the developer guide.
	DefaultArguments interface{}
	// Description of the job.
	Description interface{}
	// Execution property of the job. Defined below.
	ExecutionProperty interface{}
	// The maximum number of times to retry this job if it fails.
	MaxRetries interface{}
	// The name of the job command. Defaults to `glueetl`
	Name interface{}
	// The ARN of the IAM role associated with this job.
	RoleArn interface{}
	// The name of the Security Configuration to be associated with the job.
	SecurityConfiguration interface{}
	// The job timeout in minutes. The default is 2880 minutes (48 hours).
	Timeout interface{}
}

The set of arguments for constructing a Job resource.

type JobState 

type JobState struct {
	// The number of AWS Glue data processing units (DPUs) to allocate to this Job. At least 2 DPUs need to be allocated; the default is 10. A DPU is a relative measure of processing power that consists of 4 vCPUs of compute capacity and 16 GB of memory.
	AllocatedCapacity interface{}
	// The command of the job. Defined below.
	Command interface{}
	// The list of connections used for this job.
	Connections interface{}
	// The map of default arguments for this job. You can specify arguments here that your own job-execution script consumes, as well as arguments that AWS Glue itself consumes. For information about how to specify and consume your own Job arguments, see the [Calling AWS Glue APIs in Python](http://docs.aws.amazon.com/glue/latest/dg/aws-glue-programming-python-calling.html) topic in the developer guide. For information about the key-value pairs that AWS Glue consumes to set up your job, see the [Special Parameters Used by AWS Glue](http://docs.aws.amazon.com/glue/latest/dg/aws-glue-programming-python-glue-arguments.html) topic in the developer guide.
	DefaultArguments interface{}
	// Description of the job.
	Description interface{}
	// Execution property of the job. Defined below.
	ExecutionProperty interface{}
	// The maximum number of times to retry this job if it fails.
	MaxRetries interface{}
	// The name of the job command. Defaults to `glueetl`
	Name interface{}
	// The ARN of the IAM role associated with this job.
	RoleArn interface{}
	// The name of the Security Configuration to be associated with the job.
	SecurityConfiguration interface{}
	// The job timeout in minutes. The default is 2880 minutes (48 hours).
	Timeout interface{}
}

Input properties used for looking up and filtering Job resources.

type SecurityConfiguration added in v0.16.2 

type SecurityConfiguration struct {
	// contains filtered or unexported fields
}

Manages a Glue Security Configuration.

func GetSecurityConfiguration added in v0.16.2 

func GetSecurityConfiguration(ctx *pulumi.Context,
	name string, id pulumi.ID, state *SecurityConfigurationState, opts ...pulumi.ResourceOpt) (*SecurityConfiguration, error)

GetSecurityConfiguration gets an existing SecurityConfiguration resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewSecurityConfiguration added in v0.16.2 

func NewSecurityConfiguration(ctx *pulumi.Context,
	name string, args *SecurityConfigurationArgs, opts ...pulumi.ResourceOpt) (*SecurityConfiguration, error)

NewSecurityConfiguration registers a new resource with the given unique name, arguments, and options.

func (*SecurityConfiguration) EncryptionConfiguration added in v0.16.2 

func (r *SecurityConfiguration) EncryptionConfiguration() *pulumi.Output

Configuration block containing encryption configuration. Detailed below.

func (*SecurityConfiguration) ID added in v0.16.2 

func (r *SecurityConfiguration) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*SecurityConfiguration) Name added in v0.16.2 

func (r *SecurityConfiguration) Name() *pulumi.StringOutput

Name of the security configuration.

func (*SecurityConfiguration) URN added in v0.16.2 

func (r *SecurityConfiguration) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type SecurityConfigurationArgs added in v0.16.2 

type SecurityConfigurationArgs struct {
	// Configuration block containing encryption configuration. Detailed below.
	EncryptionConfiguration interface{}
	// Name of the security configuration.
	Name interface{}
}

The set of arguments for constructing a SecurityConfiguration resource.

type SecurityConfigurationState added in v0.16.2 

type SecurityConfigurationState struct {
	// Configuration block containing encryption configuration. Detailed below.
	EncryptionConfiguration interface{}
	// Name of the security configuration.
	Name interface{}
}

Input properties used for looking up and filtering SecurityConfiguration resources.

type Trigger 

type Trigger struct {
	// contains filtered or unexported fields
}

Manages a Glue Trigger resource.

func GetTrigger 

func GetTrigger(ctx *pulumi.Context,
	name string, id pulumi.ID, state *TriggerState, opts ...pulumi.ResourceOpt) (*Trigger, error)

GetTrigger gets an existing Trigger resource's state with the given name, ID, and optional state properties that are used to uniquely qualify the lookup (nil if not required).

func NewTrigger 

func NewTrigger(ctx *pulumi.Context,
	name string, args *TriggerArgs, opts ...pulumi.ResourceOpt) (*Trigger, error)

NewTrigger registers a new resource with the given unique name, arguments, and options.

func (*Trigger) Actions 

func (r *Trigger) Actions() *pulumi.ArrayOutput

List of actions initiated by this trigger when it fires. Defined below.

func (*Trigger) Description 

func (r *Trigger) Description() *pulumi.StringOutput

A description of the new trigger.

func (*Trigger) Enabled 

func (r *Trigger) Enabled() *pulumi.BoolOutput

Start the trigger. Defaults to `true`. Not valid to disable for `ON_DEMAND` type.

func (*Trigger) ID 

func (r *Trigger) ID() *pulumi.IDOutput

ID is this resource's unique identifier assigned by its provider.

func (*Trigger) Name 

func (r *Trigger) Name() *pulumi.StringOutput

The name of the trigger.

func (*Trigger) Predicate 

func (r *Trigger) Predicate() *pulumi.Output

A predicate to specify when the new trigger should fire. Required when trigger type is `CONDITIONAL`. Defined below.

func (*Trigger) Schedule 

func (r *Trigger) Schedule() *pulumi.StringOutput

A cron expression used to specify the schedule. [Time-Based Schedules for Jobs and Crawlers](https://docs.aws.amazon.com/glue/latest/dg/monitor-data-warehouse-schedule.html)

func (*Trigger) Type 

func (r *Trigger) Type() *pulumi.StringOutput

The type of trigger. Valid values are `CONDITIONAL`, `ON_DEMAND`, and `SCHEDULED`.

func (*Trigger) URN 

func (r *Trigger) URN() *pulumi.URNOutput

URN is this resource's unique name assigned by Pulumi.

type TriggerArgs 

type TriggerArgs struct {
	// List of actions initiated by this trigger when it fires. Defined below.
	Actions interface{}
	// A description of the new trigger.
	Description interface{}
	// Start the trigger. Defaults to `true`. Not valid to disable for `ON_DEMAND` type.
	Enabled interface{}
	// The name of the trigger.
	Name interface{}
	// A predicate to specify when the new trigger should fire. Required when trigger type is `CONDITIONAL`. Defined below.
	Predicate interface{}
	// A cron expression used to specify the schedule. [Time-Based Schedules for Jobs and Crawlers](https://docs.aws.amazon.com/glue/latest/dg/monitor-data-warehouse-schedule.html)
	Schedule interface{}
	// The type of trigger. Valid values are `CONDITIONAL`, `ON_DEMAND`, and `SCHEDULED`.
	Type interface{}
}

The set of arguments for constructing a Trigger resource.

type TriggerState 

type TriggerState struct {
	// List of actions initiated by this trigger when it fires. Defined below.
	Actions interface{}
	// A description of the new trigger.
	Description interface{}
	// Start the trigger. Defaults to `true`. Not valid to disable for `ON_DEMAND` type.
	Enabled interface{}
	// The name of the trigger.
	Name interface{}
	// A predicate to specify when the new trigger should fire. Required when trigger type is `CONDITIONAL`. Defined below.
	Predicate interface{}
	// A cron expression used to specify the schedule. [Time-Based Schedules for Jobs and Crawlers](https://docs.aws.amazon.com/glue/latest/dg/monitor-data-warehouse-schedule.html)
	Schedule interface{}
	// The type of trigger. Valid values are `CONDITIONAL`, `ON_DEMAND`, and `SCHEDULED`.
	Type interface{}
}

Input properties used for looking up and filtering Trigger resources.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.