glue

package

Go to main page

Versions in this module

v1

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

+ var ErrConcurrentRunsExceeded = awserr.New("ConcurrentRunsExceededException", awserr.ErrConflict)

+ var ErrConflict = awserr.New("ConflictException", awserr.ErrConflict)

+ var ErrIllegalSessionState = awserr.New("IllegalSessionStateException", awserr.ErrConflict)

+ type Asset struct

+ AssetTypeID string

+ Attachments map[string]AssetFormEntry

+ CreatedAt float64

+ Description string

+ Forms map[string]AssetFormEntry

+ GlossaryTerms []string

+ ID string

+ IterableForms map[string]IterableFormEntry

+ Name string

+ UpdatedAt float64

+ type AssetFormEntry struct

+ Content string

+ FormTypeID string

+ type AssetType struct

+ Forms map[string]AssetTypeFormReference

+ ID string

+ Name string

+ type AssetTypeFormReference struct

+ FormTypeIdentifier string

+ type AssetTypeItem struct

+ ID string

+ Name string

type Blueprint

+ BlueprintLocation string

+ BlueprintServiceLocation string

+ CreatedOn float64

+ Description string

+ ErrorMessage string

+ LastModifiedOn float64

+ ParameterSpec string

+ Tags map[string]string

type Connection

+ Description string

+ MatchCriteria []string

+ PhysicalConnectionRequirements *PhysicalConnectionRequirements

+ type ConnectionOptions struct

+ Description string

+ MatchCriteria []string

+ PhysicalConnectionRequirements *PhysicalConnectionRequirements

type Crawler

+ CrawlerSecurityConfiguration string

+ LakeFormationConfiguration *LakeFormationConfiguration

+ LineageConfiguration *LineageConfiguration

+ RecrawlPolicy *RecrawlPolicy

+ SchemaChangePolicy *SchemaChangePolicy

type CrawlerOptions

+ CrawlerSecurityConfiguration string

+ LakeFormationConfiguration *LakeFormationConfiguration

+ LineageConfiguration *LineageConfiguration

+ RecrawlPolicy *RecrawlPolicy

+ SchemaChangePolicy *SchemaChangePolicy

type CrawlerTarget

+ DeltaTargets []DeltaTarget

+ DynamoDBTargets []DynamoDBTarget

+ HudiTargets []HudiTarget

+ IcebergTargets []IcebergTarget

+ MongoDBTargets []MongoDBTarget

+ type DataLakePrincipal struct

+ DataLakePrincipalIdentifier string

+ type DataQualityEncryption struct

+ DataQualityEncryptionMode string

+ KMSKeyARN string

type DataQualityRuleset

+ DataQualitySecurityConfiguration string

+ TargetTable *DataQualityTargetTable

+ type DataQualityRulesetOptions struct

+ DataQualitySecurityConfiguration string

+ Description string

+ TargetTable *DataQualityTargetTable

+ type DataQualityTargetTable struct

+ CatalogID string

+ DatabaseName string

+ TableName string

type Database

+ CreateTableDefaultPermissions []PrincipalPermissions

+ LocationURI string

+ Parameters map[string]string

+ TargetDatabase *DatabaseIdentifier

+ type DatabaseIdentifier struct

+ CatalogID string

+ DatabaseName string

+ Region string

type DatabaseInput

+ CreateTableDefaultPermissions []PrincipalPermissions

+ LocationURI string

+ Parameters map[string]string

+ TargetDatabase *DatabaseIdentifier

+ type DeltaTarget struct

+ ConnectionName string

+ CreateNativeDeltaTable bool

+ DeltaTables []string

+ WriteManifest bool

type DevEndpoint

+ ARN string

+ AvailabilityZone string

+ CreatedTimestamp float64

+ ExtraJarsS3Path string

+ ExtraPythonLibsS3Path string

+ FailureReason string

+ GlueVersion string

+ LastModifiedTimestamp float64

+ LastUpdateStatus string

+ NumberOfNodes int

+ NumberOfWorkers int

+ PrivateAddress string

+ PublicAddress string

+ PublicKey string

+ PublicKeys []string

+ RoleArn string

+ SecurityConfiguration string

+ SecurityGroupIDs []string

+ SubnetID string

+ Tags map[string]string

+ VpcID string

+ WorkerType string

+ YarnEndpointAddress string

+ ZeppelinRemoteSparkInterpreterPort int

+ type DevEndpointInput struct

+ Arguments map[string]string

+ ExtraJarsS3Path string

+ ExtraPythonLibsS3Path string

+ GlueVersion string

+ NumberOfNodes int

+ NumberOfWorkers int

+ PublicKey string

+ PublicKeys []string

+ SecurityConfiguration string

+ SecurityGroupIDs []string

+ SubnetID string

+ WorkerType string

+ type DynamoDBTarget struct

+ Path string

+ ScanAll bool

+ ScanRate float64

type EncryptionConfiguration

+ DataQualityEncryption *DataQualityEncryption

+ type FormType struct

+ ID string

+ Name string

+ Schema string

+ type FormTypeItem struct

+ ID string

+ Name string

+ type Glossary struct

+ Description string

+ ID string

+ Name string

+ type GlossaryTerm struct

+ GlossaryID string

+ ID string

+ LongDescription string

+ Name string

+ ShortDescription string

+ type GlossaryTermItem struct

+ ID string

+ Name string

+ ShortDescription string

+ type HudiTarget struct

+ ConnectionName string

+ Exclusions []string

+ MaximumTraversalDepth int32

+ Paths []string

+ type IcebergTarget struct

+ ConnectionName string

+ Exclusions []string

+ MaximumTraversalDepth int32

+ Paths []string

type InMemoryBackend

+ func (b *InMemoryBackend) AssociateGlossaryTerms(assetID string, termIDs []string) ([]string, error)

+ func (b *InMemoryBackend) BatchGetIterableForms(assetID, iterableFormName string, itemIDs []string) ([]*IterableFormItem, []ItemErrorDetail, error)

+ func (b *InMemoryBackend) CreateConnectionWithOptions(name, connType string, props map[string]string, tags map[string]string, ...) (*Connection, error)

+ func (b *InMemoryBackend) CreateDataQualityRulesetWithOptions(name, ruleset string, tags map[string]string, opts DataQualityRulesetOptions) (*DataQualityRuleset, error)

+ func (b *InMemoryBackend) CreateGlossary(name, description string) (*Glossary, error)

+ func (b *InMemoryBackend) CreateGlossaryTerm(glossaryID, name, shortDesc, longDesc string) (*GlossaryTerm, error)

+ func (b *InMemoryBackend) CreateMLTransformWithOptions(name, description, role string, tables []GlueTable, ...) (*MLTransform, error)

+ func (b *InMemoryBackend) DeleteAsset(id string) error

+ func (b *InMemoryBackend) DeleteAssetType(id string) error

+ func (b *InMemoryBackend) DeleteAttachment(assetID, attachmentName, iterableFormName, itemIdentifier string) error

+ func (b *InMemoryBackend) DeleteFormType(id string) error

+ func (b *InMemoryBackend) DeleteGlossary(id string) error

+ func (b *InMemoryBackend) DeleteGlossaryTerm(id string) error

+ func (b *InMemoryBackend) DisassociateGlossaryTerms(assetID string, termIDs []string) ([]string, error)

+ func (b *InMemoryBackend) GetAsset(id string) (*Asset, error)

+ func (b *InMemoryBackend) GetAssetType(id string) (*AssetType, error)

+ func (b *InMemoryBackend) GetDashboardURL(resourceID, resourceType, requestOrigin string) (string, error)

+ func (b *InMemoryBackend) GetFormType(id string) (*FormType, error)

+ func (b *InMemoryBackend) GetGlossary(id string) (*Glossary, error)

+ func (b *InMemoryBackend) GetGlossaryTerm(id string) (*GlossaryTerm, error)

+ func (b *InMemoryBackend) GetSessionEndpoint(sessionID string) (*SessionEndpoint, error)

+ func (b *InMemoryBackend) ListAssetTypes() []*AssetType

+ func (b *InMemoryBackend) ListFormTypes() []*FormType

+ func (b *InMemoryBackend) ListGlossaries() []*Glossary

+ func (b *InMemoryBackend) ListGlossaryTerms(glossaryID string) ([]*GlossaryTerm, error)

+ func (b *InMemoryBackend) ListIterableForms(assetID, iterableFormName string) ([]*IterableFormListItem, error)

+ func (b *InMemoryBackend) PutAsset(id, name, description, assetTypeID string, forms map[string]AssetFormEntry) (*Asset, error)

+ func (b *InMemoryBackend) PutAssetType(name string, forms map[string]AssetTypeFormReference) (*AssetType, error)

+ func (b *InMemoryBackend) PutAttachment(...) error

+ func (b *InMemoryBackend) PutFormType(name, schema string) (*FormType, error)

+ func (b *InMemoryBackend) SearchAssets(searchText string, filter *searchFilterClause, sortAttr string, sortDesc bool) []*Asset

+ func (b *InMemoryBackend) StartJobRunWithOptions(jobName string, arguments map[string]string, opts StartJobRunOptions) (*JobRun, error)

+ func (b *InMemoryBackend) TaggedResources() []TaggedEntry

+ func (b *InMemoryBackend) UpdateAsset(id string, name, description *string) (*Asset, error)

+ func (b *InMemoryBackend) UpdateConnectionWithOptions(name, connType string, props map[string]string, opts ConnectionOptions) error

+ func (b *InMemoryBackend) UpdateGlossary(id string, name, description *string) (*Glossary, error)

+ func (b *InMemoryBackend) UpdateGlossaryTerm(id string, name, shortDesc, longDesc *string) (*GlossaryTerm, error)

+ type ItemErrorDetail struct

+ Code string

+ ItemIdentifier string

+ Message string

+ type IterableFormEntry struct

+ FormTypeID string

+ type IterableFormItem struct

+ Attachments map[string]AssetFormEntry

+ Forms map[string]AssetFormEntry

+ GlossaryTerms []string

+ ItemID string

+ ItemName string

+ type IterableFormListItem struct

+ Description string

+ GlossaryTerms []string

+ ItemID string

+ ItemName string

type JobRun

+ NotificationProperty NotificationProperty

+ SecurityConfiguration string

+ type LakeFormationConfiguration struct

+ AccountID string

+ UseLakeFormationCredentials bool

+ type LineageConfiguration struct

+ CrawlerLineageSettings string

type MLTransform

+ LabelCount int

+ MaxRetries int

+ Schema []SchemaColumnEntry

+ Timeout int

+ TransformEncryption *TransformEncryption

+ type MLTransformOptions struct

+ GlueVersion string

+ MaxCapacity float64

+ MaxRetries int

+ NumberOfWorkers int32

+ Schema []SchemaColumnEntry

+ Timeout int

+ TransformEncryption *TransformEncryption

+ WorkerType string

+ type MLUserDataEncryption struct

+ KMSKeyID string

+ MLUserDataEncryptionMode string

+ type MongoDBTarget struct

+ ConnectionName string

+ Path string

+ ScanAll bool

+ type PhysicalConnectionRequirements struct

+ AvailabilityZone string

+ SecurityGroupIDList []string

+ SubnetID string

+ type PrincipalPermissions struct

+ Permissions []string

+ Principal *DataLakePrincipal

+ type RecrawlPolicy struct

+ RecrawlBehavior string

+ type SchemaChangePolicy struct

+ DeleteBehavior string

+ UpdateBehavior string

+ type SchemaColumnEntry struct

+ DataType string

+ Name string

+ type SearchResultItem struct

+ AssetDescription string

+ AssetName string

+ AssetTypeID string

+ ID string

+ UpdatedAt float64

+ type SessionEndpoint struct

+ AuthToken string

+ AuthTokenExpirationTime float64

+ URL string

+ type StartJobRunOptions struct

+ MaxCapacity float64

+ NotificationProperty *NotificationProperty

+ NumberOfWorkers int

+ SecurityConfiguration string

+ Timeout int

+ WorkerType string

type StorageBackend

+ AssociateGlossaryTerms func(assetID string, termIDs []string) ([]string, error)

+ BatchGetIterableForms func(assetID, iterableFormName string, itemIDs []string) ([]*IterableFormItem, []ItemErrorDetail, error)

+ CreateConnectionWithOptions func(name, connType string, props map[string]string, tags map[string]string, ...) (*Connection, error)

+ CreateDataQualityRulesetWithOptions func(name, ruleset string, tags map[string]string, opts DataQualityRulesetOptions) (*DataQualityRuleset, error)

+ CreateGlossary func(name, description string) (*Glossary, error)

+ CreateGlossaryTerm func(glossaryID, name, shortDesc, longDesc string) (*GlossaryTerm, error)

+ CreateMLTransformWithOptions func(name, description, role string, tables []GlueTable, ...) (*MLTransform, error)

+ DeleteAsset func(id string) error

+ DeleteAssetType func(id string) error

+ DeleteAttachment func(assetID, attachmentName, iterableFormName, itemIdentifier string) error

+ DeleteFormType func(id string) error

+ DeleteGlossary func(id string) error

+ DeleteGlossaryTerm func(id string) error

+ DisassociateGlossaryTerms func(assetID string, termIDs []string) ([]string, error)

+ GetAsset func(id string) (*Asset, error)

+ GetAssetType func(id string) (*AssetType, error)

+ GetDashboardURL func(resourceID, resourceType, requestOrigin string) (string, error)

+ GetFormType func(id string) (*FormType, error)

+ GetGlossary func(id string) (*Glossary, error)

+ GetGlossaryTerm func(id string) (*GlossaryTerm, error)

+ GetSessionEndpoint func(sessionID string) (*SessionEndpoint, error)

+ ListAssetTypes func() []*AssetType

+ ListFormTypes func() []*FormType

+ ListGlossaries func() []*Glossary

+ ListGlossaryTerms func(glossaryID string) ([]*GlossaryTerm, error)

+ ListIterableForms func(assetID, iterableFormName string) ([]*IterableFormListItem, error)

+ PutAsset func(id, name, description, assetTypeID string, forms map[string]AssetFormEntry) (*Asset, error)

+ PutAssetType func(name string, forms map[string]AssetTypeFormReference) (*AssetType, error)

+ PutAttachment func(...) error

+ PutFormType func(name, schema string) (*FormType, error)

+ SearchAssets func(searchText string, filter *searchFilterClause, sortAttr string, sortDesc bool) []*Asset

+ StartJobRunWithOptions func(jobName string, arguments map[string]string, opts StartJobRunOptions) (*JobRun, error)

+ UpdateAsset func(id string, name, description *string) (*Asset, error)

+ UpdateConnectionWithOptions func(name, connType string, props map[string]string, opts ConnectionOptions) error

+ UpdateGlossary func(id string, name, description *string) (*Glossary, error)

+ UpdateGlossaryTerm func(id string, name, shortDesc, longDesc *string) (*GlossaryTerm, error)

+ type TaggedEntry struct

+ ARN string

+ Tags map[string]string

+ type TransformEncryption struct

+ MLUserDataEncryption *MLUserDataEncryption

+ TaskRunSecurityConfigurationName string

type Trigger

+ Description string

+ EventBatchingCondition *TriggerEventBatchingCondition

+ WorkflowName string

type TriggerAction

+ NotificationProperty *NotificationProperty

+ SecurityConfiguration string

+ Timeout int

type TriggerCondition

+ CrawlState string

+ CrawlerName string

+ type TriggerEventBatchingCondition struct

+ BatchSize int

+ BatchWindow int

+ type UpdateDevEndpointOptions struct

+ AddPublicKeys []string

+ DeletePublicKeys []string

+ PublicKey string

type UserDefinedFunction

+ CatalogID string

+ FunctionType string

type Workflow

+ MaxConcurrentRuns int

v1.1.4

Jul 20, 2026

v1.1.3

Jul 20, 2026

v1.1.2

Jul 20, 2026

v1.1.1

Jul 20, 2026

v1.1.0

Jul 19, 2026

Changes in this version

+ var ErrAlreadyExists = awserr.New("AlreadyExistsException", awserr.ErrAlreadyExists)

+ var ErrBlueprintRunNotFound = fmt.Errorf("blueprint run not found: %w", ErrNotFound)

+ var ErrColumnStatTaskRunNotFound = fmt.Errorf("column statistics task run not found: %w", ErrNotFound)

+ var ErrConnectionTypeBuiltIn = awserr.New("connection type is a built-in AWS-managed type and cannot be deleted", ...)

+ var ErrCrawlerNotRunning = awserr.New("CrawlerNotRunningException", awserr.ErrInvalidParameter)

+ var ErrCrawlerRunning = awserr.New("CrawlerRunningException", awserr.ErrInvalidParameter)

+ var ErrDQRecommendationRunNotFound = fmt.Errorf("data quality recommendation run not found: %w", ErrNotFound)

+ var ErrIntegrationNotFound = fmt.Errorf("integration not found: %w", ErrNotFound)

+ var ErrMLTaskRunNotFound = fmt.Errorf("ML task run not found: %w", ErrNotFound)

+ var ErrMaterializedViewRunNotFound = fmt.Errorf("materialized view refresh run not found: %w", ErrNotFound)

+ var ErrNilAppContext = errors.New("glue provider: nil AppContext")

+ var ErrNotFound = awserr.New("EntityNotFoundException", awserr.ErrNotFound)

+ var ErrResourcePolicyConditionFailed = awserr.New("ConditionCheckFailureException", awserr.ErrConflict)

+ var ErrUsageProfileNotFound = fmt.Errorf("usage profile not found: %w", ErrNotFound)

+ var ErrValidation = awserr.New("InvalidInputException", awserr.ErrInvalidParameter)

+ type BatchGetTableOptimizerEntry struct

+ CatalogID string

+ DatabaseName string

+ TableName string

+ Type string

+ type BatchGetTableOptimizerError struct

+ CatalogID string

+ DatabaseName string

+ Error ErrorDetail

+ TableName string

+ Type string

+ type BatchStopJobRunError struct

+ ErrorDetail ErrorDetail

+ JobName string

+ JobRunID string

+ type Blueprint struct

+ Name string

+ Status string

+ type BlueprintRun struct

+ BlueprintName string

+ RunID string

+ StartedOn time.Time

+ State string

+ WorkflowName string

+ type CatalogEntry struct

+ CatalogID string

+ CreateTime float64

+ Description string

+ Name string

+ Parameters map[string]string

+ type CatalogImportStatus struct

+ ImportCompleted bool

+ ImportTime float64

+ ImportedBy string

+ type CatalogTarget struct

+ DatabaseName string

+ Tables []string

+ type Classifier struct

+ CsvClassifier *CsvClassifier

+ GrokClassifier *GrokClassifier

+ JSONClassifier *JSONClassifier

+ XMLClassifier *XMLClassifier

+ type CloudWatchEncryption struct

+ CloudWatchEncryptionMode string

+ KMSKeyARN string

+ type Column struct

+ Comment string

+ Name string

+ Parameters map[string]string

+ Type string

+ type ColumnStatistics struct

+ AnalyzedTime float64

+ ColumnName string

+ ColumnType string

+ StatisticsData ColumnStatisticsData

+ type ColumnStatisticsData struct

+ BinaryColumnStatisticsData any

+ BooleanColumnStatisticsData any

+ DateColumnStatisticsData any

+ DecimalColumnStatisticsData any

+ DoubleColumnStatisticsData any

+ LongColumnStatisticsData any

+ StringColumnStatisticsData any

+ Type string

+ type ColumnStatisticsTaskRun struct

+ ColumnStatisticsTaskRunID string

+ DatabaseName string

+ StartedOn time.Time

+ Status string

+ TableName string

+ type ColumnStatisticsTaskSettings struct

+ ColumnNameList []string

+ DatabaseName string

+ RoleArn string

+ Schedule CrawlerSchedule

+ TableName string

+ type Connection struct

+ ARN string

+ ConnectionProperties map[string]string

+ ConnectionType string

+ CreationTime float64

+ LastUpdatedTime float64

+ Name string

+ Tags map[string]string

+ type ConnectionPasswordEncryption struct

+ AwsKmsKeyID string

+ ReturnConnectionPasswordEncrypted bool

+ type ConnectionTypeInfo struct

+ BuiltIn bool

+ Capabilities []string

+ Category string

+ ConnectionType string

+ Description string

+ type ConnectionsList struct

+ Connections []string

+ type CrawlHistoryEntry struct

+ CrawlID string

+ EndTime float64

+ StartTime float64

+ State string

+ Summary string

+ type Crawler struct

+ ARN string

+ Classifiers []string

+ Configuration string

+ CreationTime float64

+ DatabaseName string

+ Description string

+ LastUpdated float64

+ Name string

+ Role string

+ Schedule CrawlerSchedule

+ State string

+ TablePrefix string

+ Tags map[string]string

+ Targets CrawlerTarget

+ type CrawlerMetrics struct

+ CrawlerName string

+ LastRuntimeSeconds float64

+ MedianRuntimeSeconds float64

+ StillEstimating bool

+ TablesCreated int

+ TablesDeleted int

+ TablesUpdated int

+ TimeLeftSeconds float64

+ type CrawlerOptions struct

+ Classifiers []string

+ Configuration string

+ Description string

+ Schedule string

+ TablePrefix string

+ type CrawlerSchedule struct

+ ScheduleExpression string

+ State string

+ type CrawlerTarget struct

+ CatalogTargets []CatalogTarget

+ JdbcTargets []JDBCTarget

+ S3Targets []S3Target

+ type CsvClassifier struct

+ Delimiter string

+ Header []string

+ Name string

+ QuoteSymbol string

+ type CustomEntityType struct

+ ContextWords []string

+ Name string

+ RegexString string

+ type DQRuleRecommendationRun struct

+ DataSourceS3Path string

+ RecommendationRunID string

+ StartedOn time.Time

+ Status string

+ type DataCatalogEncryptionSettings struct

+ ConnectionPasswordEncryption *ConnectionPasswordEncryption

+ EncryptionAtRest *EncryptionAtRest

+ type DataQualityEvaluationRun struct

+ CompletedOn float64

+ ErrorString string

+ RulesetNames []string

+ RunID string

+ StartedOn float64

+ Status string

+ type DataQualityResult struct

+ ResultID string

+ Score float64

+ type DataQualityRuleset struct

+ ARN string

+ CreatedOn float64

+ Description string

+ LastModifiedOn float64

+ Name string

+ Ruleset string

+ Tags map[string]string

+ type Database struct

+ ARN string

+ CatalogID string

+ CreateTime float64

+ Description string

+ Name string

+ Tags map[string]string

+ type DatabaseInput struct

+ Description string

+ Name string

+ type DevEndpoint struct

+ Arguments map[string]string

+ EndpointName string

+ Status string

+ type EncryptionAtRest struct

+ CatalogEncryptionMode string

+ CatalogEncryptionServiceRole string

+ SseAwsKmsKeyID string

+ type EncryptionConfiguration struct

+ CloudWatchEncryption *CloudWatchEncryption

+ JobBookmarksEncryption *JobBookmarksEncryption

+ S3Encryption []S3EncryptionEntry

+ type EntityDescriptor struct

+ Category string

+ EntityName string

+ IsParentEntity bool

+ Label string

+ type EntityField struct

+ Description string

+ FieldName string

+ FieldType string

+ IsCreateable bool

+ IsFilterable bool

+ IsNullable bool

+ IsPartitionable bool

+ IsRetrievable bool

+ IsUpdateable bool

+ IsUpsertable bool

+ Label string

+ NativeDataType string

+ SupportedFilterOperators []string

+ type ErrorDetail struct

+ ErrorCode string

+ ErrorMessage string

+ type ExecutionProperty struct

+ MaxConcurrentRuns int

+ type GlueTable struct

+ CatalogID string

+ ConnectionName string

+ DatabaseName string

+ TableName string

+ type GrokClassifier struct

+ Classification string

+ CustomPatterns string

+ GrokPattern string

+ Name string

+ type Handler struct

+ Backend StorageBackend

+ func NewHandler(backend StorageBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(c *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) Shutdown(_ context.Context)

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ func (h *Handler) StartWorker(ctx context.Context) error

+ type IdentityCenterConfig struct

+ InstanceARN string

+ Status string

+ type InMemoryBackend struct

+ func NewInMemoryBackend(accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) AccountID() string

+ func (b *InMemoryBackend) AddBlueprintInternal(bp *Blueprint)

+ func (b *InMemoryBackend) AddConnectionInternal(conn *Connection)

+ func (b *InMemoryBackend) AddCustomEntityTypeInternal(cet *CustomEntityType)

+ func (b *InMemoryBackend) AddDataQualityEvalRunInternal(run *DataQualityEvaluationRun)

+ func (b *InMemoryBackend) AddDataQualityResultInternal(dqr *DataQualityResult)

+ func (b *InMemoryBackend) AddDataQualityRulesetInternal(r *DataQualityRuleset)

+ func (b *InMemoryBackend) AddDevEndpointInternal(dep *DevEndpoint)

+ func (b *InMemoryBackend) AddJobRunInternal(run *JobRun)

+ func (b *InMemoryBackend) AddPartitionInternal(dbName, tableName string, p *Partition)

+ func (b *InMemoryBackend) AddTableVersionInternal(dbName, tableName string, tv *TableVersion)

+ func (b *InMemoryBackend) BatchCreatePartition(dbName, tableName string, inputs []PartitionInput) ([]*Partition, []PartitionError)

+ func (b *InMemoryBackend) BatchDeleteConnection(names []string) ([]string, []ErrorDetail)

+ func (b *InMemoryBackend) BatchDeletePartition(dbName, tableName string, values []PartitionValueList) []PartitionError

+ func (b *InMemoryBackend) BatchDeleteTable(dbName string, tableNames []string) []TableError

+ func (b *InMemoryBackend) BatchDeleteTableVersion(dbName, tableName string, versionIDs []string) []TableVersionError

+ func (b *InMemoryBackend) BatchGetBlueprints(names []string) ([]*Blueprint, []string)

+ func (b *InMemoryBackend) BatchGetCrawlers(names []string) ([]*Crawler, []string)

+ func (b *InMemoryBackend) BatchGetCustomEntityTypes(names []string) ([]*CustomEntityType, []string)

+ func (b *InMemoryBackend) BatchGetDataQualityResult(resultIDs []string) ([]*DataQualityResult, []ErrorDetail)

+ func (b *InMemoryBackend) BatchGetDevEndpoints(names []string) ([]*DevEndpoint, []string)

+ func (b *InMemoryBackend) BatchGetTableOptimizer(entries []BatchGetTableOptimizerEntry) ([]*TableOptimizer, []BatchGetTableOptimizerError)

+ func (b *InMemoryBackend) BatchGetTriggers(names []string) ([]*Trigger, []string)

+ func (b *InMemoryBackend) BatchGetWorkflows(names []string) ([]*Workflow, []string)

+ func (b *InMemoryBackend) BatchStopJobRun(jobName string, runIDs []string) []BatchStopJobRunError

+ func (b *InMemoryBackend) CancelDataQualityRuleRecommendationRun(runID string) error

+ func (b *InMemoryBackend) CancelDataQualityRulesetEvaluationRun(runID string) error

+ func (b *InMemoryBackend) CancelMLTaskRun(transformID, taskRunID string) error

+ func (b *InMemoryBackend) CancelStatement(sessionID string, statementID int32) error

+ func (b *InMemoryBackend) Close()

+ func (b *InMemoryBackend) CreateBlueprint(name string) error

+ func (b *InMemoryBackend) CreateCatalog(catalogID, name, description string, params map[string]string) error

+ func (b *InMemoryBackend) CreateClassifier(c Classifier) error

+ func (b *InMemoryBackend) CreateColumnStatisticsTaskSettings(dbName, tableName, roleArn string, columns []string) (*ColumnStatisticsTaskSettings, error)

+ func (b *InMemoryBackend) CreateConnection(name, connType string, props map[string]string, tags map[string]string) (*Connection, error)

+ func (b *InMemoryBackend) CreateCrawler(name, role, dbName string, targets CrawlerTarget, tags map[string]string) (*Crawler, error)

+ func (b *InMemoryBackend) CreateCrawlerWithOptions(name, role, dbName string, targets CrawlerTarget, tags map[string]string, ...) (*Crawler, error)

+ func (b *InMemoryBackend) CreateCustomEntityType(name, regexString string, contextWords []string) (*CustomEntityType, error)

+ func (b *InMemoryBackend) CreateDataQualityRuleset(name, ruleset string, tags map[string]string) (*DataQualityRuleset, error)

+ func (b *InMemoryBackend) CreateDatabase(input DatabaseInput, tags map[string]string) (*Database, error)

+ func (b *InMemoryBackend) CreateDevEndpoint(name string) (*DevEndpoint, error)

+ func (b *InMemoryBackend) CreateGlueIdentityCenterConfiguration(instanceARN string) error

+ func (b *InMemoryBackend) CreateIntegration(name string, tags map[string]string) (*Integration, error)

+ func (b *InMemoryBackend) CreateIntegrationResourceProperty(resourceArn string, sourceProps, targetProps map[string]string) (*IntegrationResourceProperty, error)

+ func (b *InMemoryBackend) CreateIntegrationTableProperties(resourceArn, tableName string, sourceConfig, targetConfig map[string]any) error

+ func (b *InMemoryBackend) CreateJob(input Job) (*Job, error)

+ func (b *InMemoryBackend) CreateMLTransform(name, description, role string, tables []GlueTable, ...) (*MLTransform, error)

+ func (b *InMemoryBackend) CreatePartitionIndex(dbName, tableName string, input PartitionIndex) error

+ func (b *InMemoryBackend) CreateRegistry(name, description string, tags map[string]string) (*Registry, error)

+ func (b *InMemoryBackend) CreateSchema(registryName, schemaName, dataFormat, compatibility, description string, ...) (*Schema, error)

+ func (b *InMemoryBackend) CreateSecurityConfiguration(name string, enc EncryptionConfiguration) (*SecurityConfiguration, error)

+ func (b *InMemoryBackend) CreateSession(id, role string, cmd SessionCommand, opts Session) (*Session, error)

+ func (b *InMemoryBackend) CreateTable(dbName string, input TableInput) (*Table, error)

+ func (b *InMemoryBackend) CreateTableOptimizer(catalogID, dbName, tableName, optimizerType string, ...) error

+ func (b *InMemoryBackend) CreateTrigger(t Trigger, tags map[string]string) (*Trigger, error)

+ func (b *InMemoryBackend) CreateUsageProfile(name, description string, tags map[string]string) (*UsageProfile, error)

+ func (b *InMemoryBackend) CreateUserDefinedFunction(dbName string, input UserDefinedFunction, tags map[string]string) (*UserDefinedFunction, error)

+ func (b *InMemoryBackend) CreateWorkflow(w Workflow, tags map[string]string) (*Workflow, error)

+ func (b *InMemoryBackend) DeleteBlueprint(name string) error

+ func (b *InMemoryBackend) DeleteCatalog(catalogID string) error

+ func (b *InMemoryBackend) DeleteClassifier(name string) error

+ func (b *InMemoryBackend) DeleteColumnStatisticsForPartition(dbName, tableName string, partitionValues []string, columnName string) error

+ func (b *InMemoryBackend) DeleteColumnStatisticsForTable(dbName, tableName, columnName string) error

+ func (b *InMemoryBackend) DeleteColumnStatisticsTaskSettings(dbName, tableName string) error

+ func (b *InMemoryBackend) DeleteConnection(name string) error

+ func (b *InMemoryBackend) DeleteConnectionType(name string) error

+ func (b *InMemoryBackend) DeleteCrawler(name string) error

+ func (b *InMemoryBackend) DeleteCustomEntityType(name string) error

+ func (b *InMemoryBackend) DeleteDataQualityRuleset(name string) error

+ func (b *InMemoryBackend) DeleteDatabase(name string) error

+ func (b *InMemoryBackend) DeleteDevEndpoint(name string) error

+ func (b *InMemoryBackend) DeleteGlueIdentityCenterConfiguration() error

+ func (b *InMemoryBackend) DeleteIntegration(name string) error

+ func (b *InMemoryBackend) DeleteIntegrationResourceProperty(resourceArn string) error

+ func (b *InMemoryBackend) DeleteIntegrationTableProperties(resourceArn, tableName string) error

+ func (b *InMemoryBackend) DeleteJob(name string) error

+ func (b *InMemoryBackend) DeleteMLTransform(id string) error

+ func (b *InMemoryBackend) DeletePartitionIndex(dbName, tableName, indexName string) error

+ func (b *InMemoryBackend) DeleteRegistry(name string) error

+ func (b *InMemoryBackend) DeleteResourcePolicy(resourceARN, policyHash string) error

+ func (b *InMemoryBackend) DeleteSchema(registryName, schemaName string) error

+ func (b *InMemoryBackend) DeleteSchemaVersion(registryName, schemaName string, versionNumber int64) error

+ func (b *InMemoryBackend) DeleteSecurityConfiguration(name string) error

+ func (b *InMemoryBackend) DeleteSession(id string) error

+ func (b *InMemoryBackend) DeleteTable(dbName, tableName string) error

+ func (b *InMemoryBackend) DeleteTableOptimizer(dbName, tableName, optimizerType string) error

+ func (b *InMemoryBackend) DeleteTableVersion(dbName, tableName, versionID string) error

+ func (b *InMemoryBackend) DeleteTrigger(name string) error

+ func (b *InMemoryBackend) DeleteUsageProfile(name string) error

+ func (b *InMemoryBackend) DeleteUserDefinedFunction(dbName, name string) error

+ func (b *InMemoryBackend) DeleteWorkflow(name string) error

+ func (b *InMemoryBackend) DescribeConnectionType(name string) (*ConnectionTypeInfo, error)

+ func (b *InMemoryBackend) DescribeEntity(connectionName, entityName string) ([]EntityField, error)

+ func (b *InMemoryBackend) DescribeRegistry(name string) (*Registry, error)

+ func (b *InMemoryBackend) DescribeSchema(registryName, schemaName string) (*Schema, error)

+ func (b *InMemoryBackend) GetAllDevEndpoints() []*DevEndpoint

+ func (b *InMemoryBackend) GetBlueprintRun(blueprintName, runID string) (*BlueprintRun, error)

+ func (b *InMemoryBackend) GetBlueprintRuns(blueprintName string) []*BlueprintRun

+ func (b *InMemoryBackend) GetCatalog(catalogID string) (*CatalogEntry, error)

+ func (b *InMemoryBackend) GetCatalogImportStatus(catalogID string) *CatalogImportStatus

+ func (b *InMemoryBackend) GetCatalogs() []*CatalogEntry

+ func (b *InMemoryBackend) GetClassifier(name string) (*Classifier, error)

+ func (b *InMemoryBackend) GetClassifiers() []*Classifier

+ func (b *InMemoryBackend) GetColumnStatisticsForPartition(dbName, tableName string, partitionValues []string, columnNames []string) ([]*ColumnStatistics, error)

+ func (b *InMemoryBackend) GetColumnStatisticsForTable(dbName, tableName string, columnNames []string) ([]*ColumnStatistics, error)

+ func (b *InMemoryBackend) GetColumnStatisticsTaskRun(runID string) (*ColumnStatisticsTaskRun, error)

+ func (b *InMemoryBackend) GetColumnStatisticsTaskRuns() []*ColumnStatisticsTaskRun

+ func (b *InMemoryBackend) GetColumnStatisticsTaskSettings(dbName, tableName string) (*ColumnStatisticsTaskSettings, error)

+ func (b *InMemoryBackend) GetConnection(name string) (*Connection, error)

+ func (b *InMemoryBackend) GetConnections() []*Connection

+ func (b *InMemoryBackend) GetCrawler(name string) (*Crawler, error)

+ func (b *InMemoryBackend) GetCrawlerMetrics(crawlerNames []string) []*CrawlerMetrics

+ func (b *InMemoryBackend) GetCrawlers() []*Crawler

+ func (b *InMemoryBackend) GetCustomEntityType(name string) (*CustomEntityType, error)

+ func (b *InMemoryBackend) GetDataCatalogEncryptionSettings(catalogID string) (*DataCatalogEncryptionSettings, error)

+ func (b *InMemoryBackend) GetDataQualityRuleRecommendationRun(runID string) (*DQRuleRecommendationRun, error)

+ func (b *InMemoryBackend) GetDataQualityRuleset(name string) (*DataQualityRuleset, error)

+ func (b *InMemoryBackend) GetDataQualityRulesetEvaluationRun(runID string) (*DataQualityEvaluationRun, error)

+ func (b *InMemoryBackend) GetDatabase(name string) (*Database, error)

+ func (b *InMemoryBackend) GetDatabases() []*Database

+ func (b *InMemoryBackend) GetDevEndpoint(name string) (*DevEndpoint, error)

+ func (b *InMemoryBackend) GetEntityRecords(connectionName, entityName string, limit int, nextToken string) ([]map[string]any, string, error)

+ func (b *InMemoryBackend) GetGlueIdentityCenterConfiguration() (*IdentityCenterConfig, error)

+ func (b *InMemoryBackend) GetIntegrationResourceProperty(resourceArn string) (*IntegrationResourceProperty, error)

+ func (b *InMemoryBackend) GetIntegrationTableProperties(resourceArn, tableName string) (*IntegrationTableProperties, error)

+ func (b *InMemoryBackend) GetJob(name string) (*Job, error)

+ func (b *InMemoryBackend) GetJobBookmark(jobName string) (*JobBookmark, error)

+ func (b *InMemoryBackend) GetJobRun(jobName, runID string) (*JobRun, error)

+ func (b *InMemoryBackend) GetJobRuns(jobName string) ([]*JobRun, error)

+ func (b *InMemoryBackend) GetJobs() []*Job

+ func (b *InMemoryBackend) GetMLTaskRun(transformID, taskRunID string) (*MLTaskRun, error)

+ func (b *InMemoryBackend) GetMLTaskRuns(transformID string) ([]*MLTaskRun, error)

+ func (b *InMemoryBackend) GetMLTransform(id string) (*MLTransform, error)

+ func (b *InMemoryBackend) GetMLTransforms() []*MLTransform

+ func (b *InMemoryBackend) GetMaterializedViewRefreshTaskRun(taskRunID string) (*MaterializedViewRefreshRun, error)

+ func (b *InMemoryBackend) GetPartition(dbName, tableName string, values []string) (*Partition, error)

+ func (b *InMemoryBackend) GetPartitionIndexes(dbName, tableName string) ([]*PartitionIndex, error)

+ func (b *InMemoryBackend) GetPartitions(dbName, tableName string) ([]*Partition, error)

+ func (b *InMemoryBackend) GetPlan(language string) (string, string)

+ func (b *InMemoryBackend) GetResourcePolicy(resourceARN string) (string, string, error)

+ func (b *InMemoryBackend) GetSchemaByDefinition(registryName, schemaName, definition string) (*SchemaVersion, error)

+ func (b *InMemoryBackend) GetSchemaVersion(registryName, schemaName string, versionNumber int64) (*SchemaVersion, error)

+ func (b *InMemoryBackend) GetSchemaVersionsDiff(registryName, schemaName string, v1, v2 int64) (string, error)

+ func (b *InMemoryBackend) GetSecurityConfiguration(name string) (*SecurityConfiguration, error)

+ func (b *InMemoryBackend) GetSession(id string) (*Session, error)

+ func (b *InMemoryBackend) GetStatement(sessionID string, statementID int32) (*Statement, error)

+ func (b *InMemoryBackend) GetStatements(sessionID string) ([]*Statement, error)

+ func (b *InMemoryBackend) GetTable(dbName, tableName string) (*Table, error)

+ func (b *InMemoryBackend) GetTableOptimizer(dbName, tableName, optimizerType string) (*TableOptimizer, error)

+ func (b *InMemoryBackend) GetTableVersion(dbName, tableName, versionID string) (*TableVersion, error)

+ func (b *InMemoryBackend) GetTableVersions(dbName, tableName string) []*TableVersion

+ func (b *InMemoryBackend) GetTables(dbName string) ([]*Table, error)

+ func (b *InMemoryBackend) GetTags(resourceARN string) (map[string]string, error)

+ func (b *InMemoryBackend) GetTrigger(name string) (*Trigger, error)

+ func (b *InMemoryBackend) GetTriggers() []*Trigger

+ func (b *InMemoryBackend) GetUsageProfile(name string) (*UsageProfile, error)

+ func (b *InMemoryBackend) GetUserDefinedFunction(dbName, name string) (*UserDefinedFunction, error)

+ func (b *InMemoryBackend) GetUserDefinedFunctions(dbName string) []*UserDefinedFunction

+ func (b *InMemoryBackend) GetWorkflow(name string) (*Workflow, error)

+ func (b *InMemoryBackend) GetWorkflowRun(workflowName, runID string) (*WorkflowRun, error)

+ func (b *InMemoryBackend) GetWorkflowRuns(workflowName string) ([]*WorkflowRun, error)

+ func (b *InMemoryBackend) GetWorkflows() []string

+ func (b *InMemoryBackend) ImportCatalogToGlue(catalogID string) error

+ func (b *InMemoryBackend) ListBlueprints() []string

+ func (b *InMemoryBackend) ListColumnStatisticsTaskRuns() []*ColumnStatisticsTaskRun

+ func (b *InMemoryBackend) ListConnectionTypes() []*ConnectionTypeInfo

+ func (b *InMemoryBackend) ListCrawlers() []string

+ func (b *InMemoryBackend) ListCrawls(crawlerName string) ([]*CrawlHistoryEntry, error)

+ func (b *InMemoryBackend) ListCustomEntityTypes() []*CustomEntityType

+ func (b *InMemoryBackend) ListDataQualityEvaluationRuns() []*DataQualityEvaluationRun

+ func (b *InMemoryBackend) ListDataQualityResults() []*DataQualityResult

+ func (b *InMemoryBackend) ListDataQualityRuleRecommendationRuns() []*DQRuleRecommendationRun

+ func (b *InMemoryBackend) ListDataQualityRulesets() []*DataQualityRuleset

+ func (b *InMemoryBackend) ListDataQualityStatisticAnnotations(profileID, statisticID string) []*StatisticAnnotation

+ func (b *InMemoryBackend) ListEntities(connectionName string) ([]EntityDescriptor, error)

+ func (b *InMemoryBackend) ListIntegrationResourceProperties() []*IntegrationResourceProperty

+ func (b *InMemoryBackend) ListIntegrations() []*Integration

+ func (b *InMemoryBackend) ListMaterializedViewRefreshTaskRuns() []*MaterializedViewRefreshRun

+ func (b *InMemoryBackend) ListRegistries() []*Registry

+ func (b *InMemoryBackend) ListResourcePolicies() []*resourcePolicyEntry

+ func (b *InMemoryBackend) ListSchemaVersions(registryName, schemaName string) []*SchemaVersion

+ func (b *InMemoryBackend) ListSchemas(registryName string) []*Schema

+ func (b *InMemoryBackend) ListSecurityConfigurations() []*SecurityConfiguration

+ func (b *InMemoryBackend) ListSessions() []*Session

+ func (b *InMemoryBackend) ListUsageProfiles() []*UsageProfile

+ func (b *InMemoryBackend) ModifyIntegration(name string) error

+ func (b *InMemoryBackend) PutDataCatalogEncryptionSettings(catalogID string, settings DataCatalogEncryptionSettings) error

+ func (b *InMemoryBackend) PutDataQualityStatisticAnnotation(profileID, statisticID, inclusion string)

+ func (b *InMemoryBackend) PutResourcePolicy(policy, resourceARN, existsCondition, hashCondition string) (string, error)

+ func (b *InMemoryBackend) PutSchemaVersionMetadata(schemaVersionID, key, value string) error

+ func (b *InMemoryBackend) PutWorkflowRunProperties(workflowName, runID string, props map[string]string) error

+ func (b *InMemoryBackend) QuerySchemaVersionMetadata(schemaVersionID string) map[string]string

+ func (b *InMemoryBackend) Region() string

+ func (b *InMemoryBackend) RegisterConnectionType(name, description string) (*ConnectionTypeInfo, error)

+ func (b *InMemoryBackend) RegisterSchemaVersion(registryName, schemaName, schemaDefinition string) (*SchemaVersion, error)

+ func (b *InMemoryBackend) RemoveSchemaVersionMetadata(schemaVersionID, key string) error

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) ResetJobBookmark(jobName string) error

+ func (b *InMemoryBackend) ResetJobBookmarkWithResult(jobName string) (*JobBookmark, error)

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) ResumeWorkflowRun(workflowName, runID string) (string, []string, error)

+ func (b *InMemoryBackend) RunStatement(sessionID, code string) (*Statement, error)

+ func (b *InMemoryBackend) SFNStartJobRun(_ context.Context, jobName string, arguments map[string]string) (string, error)

+ func (b *InMemoryBackend) SearchTables(searchText string) []*Table

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) StartBlueprintRun(blueprintName string) (*BlueprintRun, error)

+ func (b *InMemoryBackend) StartColumnStatisticsTaskRun(dbName, tableName string) (*ColumnStatisticsTaskRun, error)

+ func (b *InMemoryBackend) StartColumnStatisticsTaskRunSchedule(dbName, tableName string) error

+ func (b *InMemoryBackend) StartCrawler(name string) error

+ func (b *InMemoryBackend) StartCrawlerSchedule(name string) error

+ func (b *InMemoryBackend) StartDataQualityRuleRecommendationRun(s3Path string) (*DQRuleRecommendationRun, error)

+ func (b *InMemoryBackend) StartDataQualityRulesetEvaluationRun(rulesetNames []string) (*DataQualityEvaluationRun, error)

+ func (b *InMemoryBackend) StartExportLabelsTaskRun(transformID, _ string) (*MLTaskRun, error)

+ func (b *InMemoryBackend) StartImportLabelsTaskRun(transformID, _ string) (*MLTaskRun, error)

+ func (b *InMemoryBackend) StartJobRun(jobName string, arguments map[string]string) (*JobRun, error)

+ func (b *InMemoryBackend) StartMLEvaluationTaskRun(transformID string) (*MLTaskRun, error)

+ func (b *InMemoryBackend) StartMLLabelingSetGenerationTaskRun(transformID string) (*MLTaskRun, error)

+ func (b *InMemoryBackend) StartMaterializedViewRefreshTaskRun(dbName, tableName string) (*MaterializedViewRefreshRun, error)

+ func (b *InMemoryBackend) StartReconciler(ctx context.Context)

+ func (b *InMemoryBackend) StartTrigger(name string) error

+ func (b *InMemoryBackend) StartWorkflowRun(name string) (*WorkflowRun, error)

+ func (b *InMemoryBackend) StopColumnStatisticsTaskRun(runID string) error

+ func (b *InMemoryBackend) StopColumnStatisticsTaskRunSchedule(dbName, tableName string) error

+ func (b *InMemoryBackend) StopCrawler(name string) error

+ func (b *InMemoryBackend) StopCrawlerSchedule(name string) error

+ func (b *InMemoryBackend) StopMaterializedViewRefreshTaskRun(taskRunID string) error

+ func (b *InMemoryBackend) StopReconciler()

+ func (b *InMemoryBackend) StopSession(id string) error

+ func (b *InMemoryBackend) StopTrigger(name string) error

+ func (b *InMemoryBackend) StopWorkflowRun(workflowName, runID string) error

+ func (b *InMemoryBackend) TagResource(resourceARN string, tags map[string]string) error

+ func (b *InMemoryBackend) UntagResource(resourceARN string, tagKeys []string) error

+ func (b *InMemoryBackend) UpdateBlueprint(name string) (*Blueprint, error)

+ func (b *InMemoryBackend) UpdateCatalog(catalogID, description string, params map[string]string) error

+ func (b *InMemoryBackend) UpdateClassifier(c Classifier) error

+ func (b *InMemoryBackend) UpdateColumnStatisticsForPartition(dbName, tableName string, partitionValues []string, stats []*ColumnStatistics) error

+ func (b *InMemoryBackend) UpdateColumnStatisticsForTable(dbName, tableName string, stats []*ColumnStatistics) error

+ func (b *InMemoryBackend) UpdateColumnStatisticsTaskSettings(dbName, tableName, roleArn string) error

+ func (b *InMemoryBackend) UpdateConnection(name string, connType string, props map[string]string) error

+ func (b *InMemoryBackend) UpdateCrawler(name, role, dbName string, targets CrawlerTarget) error

+ func (b *InMemoryBackend) UpdateCrawlerSchedule(name, scheduleExpression string) error

+ func (b *InMemoryBackend) UpdateCrawlerWithOptions(name, role, dbName string, targets CrawlerTarget, opts CrawlerOptions) error

+ func (b *InMemoryBackend) UpdateDataQualityRuleset(name, ruleset string) error

+ func (b *InMemoryBackend) UpdateDatabase(name string, input DatabaseInput) error

+ func (b *InMemoryBackend) UpdateDevEndpoint(name string, args map[string]string) error

+ func (b *InMemoryBackend) UpdateGlueIdentityCenterConfiguration(instanceARN string) error

+ func (b *InMemoryBackend) UpdateIntegrationResourceProperty(resourceArn string, sourceProps, targetProps map[string]string) (*IntegrationResourceProperty, error)

+ func (b *InMemoryBackend) UpdateIntegrationTableProperties(resourceArn, tableName string, sourceConfig, targetConfig map[string]any) error

+ func (b *InMemoryBackend) UpdateJob(name string, input Job) error

+ func (b *InMemoryBackend) UpdateJobFromSourceControl(jobName string, details SourceControlDetails) error

+ func (b *InMemoryBackend) UpdateMLTransform(id string, update MLTransform) error

+ func (b *InMemoryBackend) UpdatePartition(dbName, tableName string, partitionValues []string, input PartitionInput) error

+ func (b *InMemoryBackend) UpdateRegistry(name, description string) error

+ func (b *InMemoryBackend) UpdateSchema(registryName, schemaName, compatibility, description string) error

+ func (b *InMemoryBackend) UpdateSourceControlFromJob(jobName string, details SourceControlDetails) error

+ func (b *InMemoryBackend) UpdateTable(dbName string, input TableInput) error

+ func (b *InMemoryBackend) UpdateTableOptimizer(dbName, tableName, optimizerType string, config TableOptimizerConfiguration) error

+ func (b *InMemoryBackend) UpdateTrigger(name string, update Trigger) error

+ func (b *InMemoryBackend) UpdateUsageProfile(name, description string) (*UsageProfile, error)

+ func (b *InMemoryBackend) UpdateUserDefinedFunction(dbName, name string, input UserDefinedFunction) error

+ func (b *InMemoryBackend) UpdateWorkflow(name string, update Workflow) error

+ type Integration struct

+ CreatedAt time.Time

+ IntegrationName string

+ Status string

+ Tags map[string]string

+ type IntegrationResourceProperty struct

+ CreatedAt time.Time

+ ResourceArn string

+ SourceProperties map[string]string

+ TargetProperties map[string]string

+ type IntegrationTableProperties struct

+ ResourceArn string

+ SourceTableConfig map[string]any

+ TableName string

+ TargetTableConfig map[string]any

+ type JDBCTarget struct

+ ConnectionName string

+ Exclusions []string

+ Path string

+ type JSONClassifier struct

+ JSONPath string

+ Name string

+ type Job struct

+ ARN string

+ Command JobCommand

+ Connections ConnectionsList

+ CreatedOn float64

+ DefaultArguments map[string]string

+ Description string

+ ExecutionProperty ExecutionProperty

+ GlueVersion string

+ LastModifiedOn float64

+ MaxCapacity float64

+ MaxRetries int

+ Name string

+ NotificationProperty NotificationProperty

+ NumberOfWorkers int

+ Role string

+ SourceControlDetails *SourceControlDetails

+ Tags map[string]string

+ Timeout int

+ WorkerType string

+ type JobBookmark struct

+ ActiveRun string

+ Attempt int

+ JobName string

+ Run string

+ Version int

+ type JobBookmarksEncryption struct

+ JobBookmarksEncryptionMode string

+ KMSKeyARN string

+ type JobCommand struct

+ Name string

+ PythonVersion string

+ ScriptLocation string

+ type JobRun struct

+ Arguments map[string]string

+ CompletedOn float64

+ ErrorMessage string

+ ExecutionTime int

+ GlueVersion string

+ ID string

+ JobName string

+ JobRunState string

+ MaxCapacity float64

+ NumberOfWorkers int

+ StartedOn float64

+ Timeout int

+ WorkerType string

+ type MLTaskRun struct

+ CompletedOn float64

+ ErrorString string

+ ExecutionTime int

+ LogGroupName string

+ Properties map[string]string

+ StartedOn float64

+ Status string

+ TaskRunID string

+ TaskType string

+ TransformID string

+ type MLTaskType string

+ type MLTransform struct

+ CreatedOn float64

+ Description string

+ GlueVersion string

+ InputRecordTables []GlueTable

+ LastModifiedOn float64

+ MaxCapacity float64

+ Name string

+ NumberOfWorkers int32

+ Parameters MLTransformParameter

+ Role string

+ Status string

+ TransformID string

+ WorkerType string

+ type MLTransformParameter struct

+ FindMatchesParameters any

+ TransformType string

+ type MappingEntry struct

+ SourcePath string

+ SourceTable string

+ SourceType string

+ TargetPath string

+ TargetTable string

+ TargetType string

+ type MaterializedViewRefreshRun struct

+ DatabaseName string

+ StartedOn time.Time

+ Status string

+ TableName string

+ TaskRunID string

+ type NotificationProperty struct

+ NotifyDelayAfter int

+ type Order struct

+ Column string

+ SortOrder int

+ type Partition struct

+ CatalogID string

+ CreationTime float64

+ DatabaseName string

+ Parameters map[string]string

+ StorageDescriptor StorageDescriptor

+ TableName string

+ Values []string

+ type PartitionError struct

+ ErrorDetail ErrorDetail

+ PartitionValues []string

+ type PartitionIndex struct

+ IndexName string

+ IndexStatus string

+ Keys []string

+ type PartitionInput struct

+ Parameters map[string]string

+ StorageDescriptor StorageDescriptor

+ Values []string

+ type PartitionValueList struct

+ Values []string

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type Registry struct

+ ARN string

+ CreatedTime float64

+ Description string

+ Name string

+ Status string

+ Tags map[string]string

+ UpdatedTime float64

+ type ResourceURI struct

+ ResourceType string

+ URI string

+ type S3EncryptionEntry struct

+ KMSKeyARN string

+ S3EncryptionMode string

+ type S3Target struct

+ Exclusions []string

+ Path string

+ type Schema struct

+ CheckpointVersion int64

+ Compatibility string

+ CreatedTime float64

+ DataFormat string

+ Description string

+ LatestSchemaVersion int64

+ NextSchemaVersion int64

+ RegistryARN string

+ RegistryName string

+ SchemaARN string

+ SchemaName string

+ SchemaStatus string

+ Tags map[string]string

+ UpdatedTime float64

+ type SchemaVersion struct

+ CreatedTime float64

+ DataFormat string

+ SchemaARN string

+ SchemaDefinition string

+ SchemaVersionID string

+ Status string

+ VersionNumber int64

+ type SecurityConfiguration struct

+ CreatedTimeStamp float64

+ EncryptionConfiguration EncryptionConfiguration

+ Name string

+ type SerDeInfo struct

+ Name string

+ Parameters map[string]string

+ SerializationLibrary string

+ type Session struct

+ Command SessionCommand

+ CreatedOn float64

+ DefaultArguments map[string]string

+ Description string

+ MaxCapacity float64

+ Role string

+ SessionID string

+ Status string

+ Timeout int32

+ type SessionCommand struct

+ Name string

+ PythonVersion string

+ type Snapshottable interface

+ Restore func(ctx context.Context, data []byte) error

+ Snapshot func(ctx context.Context) []byte

+ type SourceControlDetails struct

+ AuthStrategy string

+ AuthToken string

+ Branch string

+ Folder string

+ LastCommitID string

+ Owner string

+ Provider string

+ Repository string

+ type Statement struct

+ Code string

+ CompletedOn float64

+ Id int32

+ Output any

+ Progress float64

+ SessionId string

+ StartedOn float64

+ State string

+ type StatisticAnnotation struct

+ Inclusion string

+ LastModifiedOn float64

+ ProfileID string

+ RecordedOn float64

+ StatisticID string

+ type StorageBackend interface

+ AccountID func() string

+ AddBlueprintInternal func(bp *Blueprint)

+ AddConnectionInternal func(conn *Connection)

+ AddCustomEntityTypeInternal func(cet *CustomEntityType)

+ AddDataQualityEvalRunInternal func(run *DataQualityEvaluationRun)

+ AddDataQualityResultInternal func(dqr *DataQualityResult)

+ AddDataQualityRulesetInternal func(r *DataQualityRuleset)

+ AddDevEndpointInternal func(dep *DevEndpoint)

+ AddJobRunInternal func(run *JobRun)

+ AddPartitionInternal func(dbName, tableName string, p *Partition)

+ AddTableVersionInternal func(dbName, tableName string, tv *TableVersion)

+ BatchCreatePartition func(dbName, tableName string, inputs []PartitionInput) ([]*Partition, []PartitionError)

+ BatchDeleteConnection func(names []string) ([]string, []ErrorDetail)

+ BatchDeletePartition func(dbName, tableName string, values []PartitionValueList) []PartitionError

+ BatchDeleteTable func(dbName string, tableNames []string) []TableError

+ BatchDeleteTableVersion func(dbName, tableName string, versionIDs []string) []TableVersionError

+ BatchGetBlueprints func(names []string) ([]*Blueprint, []string)

+ BatchGetCrawlers func(names []string) ([]*Crawler, []string)

+ BatchGetCustomEntityTypes func(names []string) ([]*CustomEntityType, []string)

+ BatchGetDataQualityResult func(resultIDs []string) ([]*DataQualityResult, []ErrorDetail)

+ BatchGetDevEndpoints func(names []string) ([]*DevEndpoint, []string)

+ BatchGetTableOptimizer func(entries []BatchGetTableOptimizerEntry) ([]*TableOptimizer, []BatchGetTableOptimizerError)

+ BatchGetTriggers func(names []string) ([]*Trigger, []string)

+ BatchGetWorkflows func(names []string) ([]*Workflow, []string)

+ BatchStopJobRun func(jobName string, runIDs []string) []BatchStopJobRunError

+ CancelDataQualityRuleRecommendationRun func(runID string) error

+ CancelDataQualityRulesetEvaluationRun func(runID string) error

+ CancelMLTaskRun func(transformID, taskRunID string) error

+ CancelStatement func(sessionID string, statementID int32) error

+ CreateBlueprint func(name string) error

+ CreateCatalog func(catalogID, name, description string, params map[string]string) error

+ CreateClassifier func(c Classifier) error

+ CreateColumnStatisticsTaskSettings func(dbName, tableName, roleArn string, columns []string) (*ColumnStatisticsTaskSettings, error)

+ CreateConnection func(name, connType string, props map[string]string, tags map[string]string) (*Connection, error)

+ CreateCrawler func(name, role, dbName string, targets CrawlerTarget, tags map[string]string) (*Crawler, error)

+ CreateCrawlerWithOptions func(name, role, dbName string, targets CrawlerTarget, tags map[string]string, ...) (*Crawler, error)

+ CreateCustomEntityType func(name, regexString string, contextWords []string) (*CustomEntityType, error)

+ CreateDataQualityRuleset func(name, ruleset string, tags map[string]string) (*DataQualityRuleset, error)

+ CreateDatabase func(input DatabaseInput, tags map[string]string) (*Database, error)

+ CreateDevEndpoint func(name string) (*DevEndpoint, error)

+ CreateGlueIdentityCenterConfiguration func(instanceARN string) error

+ CreateIntegration func(name string, tags map[string]string) (*Integration, error)

+ CreateIntegrationResourceProperty func(resourceArn string, sourceProps, targetProps map[string]string) (*IntegrationResourceProperty, error)

+ CreateIntegrationTableProperties func(resourceArn, tableName string, sourceConfig, targetConfig map[string]any) error

+ CreateJob func(input Job) (*Job, error)

+ CreateMLTransform func(name, description, role string, tables []GlueTable, ...) (*MLTransform, error)

+ CreatePartitionIndex func(dbName, tableName string, input PartitionIndex) error

+ CreateRegistry func(name, description string, tags map[string]string) (*Registry, error)

+ CreateSchema func(registryName, schemaName, dataFormat, compatibility, description string, ...) (*Schema, error)

+ CreateSecurityConfiguration func(name string, enc EncryptionConfiguration) (*SecurityConfiguration, error)

+ CreateSession func(id, role string, cmd SessionCommand, opts Session) (*Session, error)

+ CreateTable func(dbName string, input TableInput) (*Table, error)

+ CreateTableOptimizer func(catalogID, dbName, tableName, optimizerType string, ...) error

+ CreateTrigger func(t Trigger, tags map[string]string) (*Trigger, error)

+ CreateUsageProfile func(name, description string, tags map[string]string) (*UsageProfile, error)

+ CreateUserDefinedFunction func(dbName string, input UserDefinedFunction, tags map[string]string) (*UserDefinedFunction, error)

+ CreateWorkflow func(w Workflow, tags map[string]string) (*Workflow, error)

+ DeleteBlueprint func(name string) error

+ DeleteCatalog func(catalogID string) error

+ DeleteClassifier func(name string) error

+ DeleteColumnStatisticsForPartition func(dbName, tableName string, partitionValues []string, columnName string) error

+ DeleteColumnStatisticsForTable func(dbName, tableName, columnName string) error

+ DeleteColumnStatisticsTaskSettings func(dbName, tableName string) error

+ DeleteConnection func(name string) error

+ DeleteConnectionType func(name string) error

+ DeleteCrawler func(name string) error

+ DeleteCustomEntityType func(name string) error

+ DeleteDataQualityRuleset func(name string) error

+ DeleteDatabase func(name string) error

+ DeleteDevEndpoint func(name string) error

+ DeleteGlueIdentityCenterConfiguration func() error

+ DeleteIntegration func(name string) error

+ DeleteIntegrationResourceProperty func(resourceArn string) error

+ DeleteIntegrationTableProperties func(resourceArn, tableName string) error

+ DeleteJob func(name string) error

+ DeleteMLTransform func(id string) error

+ DeletePartitionIndex func(dbName, tableName, indexName string) error

+ DeleteRegistry func(name string) error

+ DeleteResourcePolicy func(resourceARN, policyHash string) error

+ DeleteSchema func(registryName, schemaName string) error

+ DeleteSchemaVersion func(registryName, schemaName string, versionNumber int64) error

+ DeleteSecurityConfiguration func(name string) error

+ DeleteSession func(id string) error

+ DeleteTable func(dbName, tableName string) error

+ DeleteTableOptimizer func(dbName, tableName, optimizerType string) error

+ DeleteTableVersion func(dbName, tableName, versionID string) error

+ DeleteTrigger func(name string) error

+ DeleteUsageProfile func(name string) error

+ DeleteUserDefinedFunction func(dbName, name string) error

+ DeleteWorkflow func(name string) error

+ DescribeConnectionType func(name string) (*ConnectionTypeInfo, error)

+ DescribeEntity func(connectionName, entityName string) ([]EntityField, error)

+ DescribeRegistry func(name string) (*Registry, error)

+ DescribeSchema func(registryName, schemaName string) (*Schema, error)

+ GetAllDevEndpoints func() []*DevEndpoint

+ GetBlueprintRun func(blueprintName, runID string) (*BlueprintRun, error)

+ GetBlueprintRuns func(blueprintName string) []*BlueprintRun

+ GetCatalog func(catalogID string) (*CatalogEntry, error)

+ GetCatalogImportStatus func(catalogID string) *CatalogImportStatus

+ GetCatalogs func() []*CatalogEntry

+ GetClassifier func(name string) (*Classifier, error)

+ GetClassifiers func() []*Classifier

+ GetColumnStatisticsForPartition func(dbName, tableName string, partitionValues []string, columnNames []string) ([]*ColumnStatistics, error)

+ GetColumnStatisticsForTable func(dbName, tableName string, columnNames []string) ([]*ColumnStatistics, error)

+ GetColumnStatisticsTaskRun func(runID string) (*ColumnStatisticsTaskRun, error)

+ GetColumnStatisticsTaskRuns func() []*ColumnStatisticsTaskRun

+ GetColumnStatisticsTaskSettings func(dbName, tableName string) (*ColumnStatisticsTaskSettings, error)

+ GetConnection func(name string) (*Connection, error)

+ GetConnections func() []*Connection

+ GetCrawler func(name string) (*Crawler, error)

+ GetCrawlerMetrics func(crawlerNames []string) []*CrawlerMetrics

+ GetCrawlers func() []*Crawler

+ GetCustomEntityType func(name string) (*CustomEntityType, error)

+ GetDataCatalogEncryptionSettings func(catalogID string) (*DataCatalogEncryptionSettings, error)

+ GetDataQualityRuleRecommendationRun func(runID string) (*DQRuleRecommendationRun, error)

+ GetDataQualityRuleset func(name string) (*DataQualityRuleset, error)

+ GetDataQualityRulesetEvaluationRun func(runID string) (*DataQualityEvaluationRun, error)

+ GetDatabase func(name string) (*Database, error)

+ GetDatabases func() []*Database

+ GetDevEndpoint func(name string) (*DevEndpoint, error)

+ GetEntityRecords func(connectionName, entityName string, limit int, nextToken string) ([]map[string]any, string, error)

+ GetGlueIdentityCenterConfiguration func() (*IdentityCenterConfig, error)

+ GetIntegrationResourceProperty func(resourceArn string) (*IntegrationResourceProperty, error)

+ GetIntegrationTableProperties func(resourceArn, tableName string) (*IntegrationTableProperties, error)

+ GetJob func(name string) (*Job, error)

+ GetJobBookmark func(jobName string) (*JobBookmark, error)

+ GetJobRun func(jobName, runID string) (*JobRun, error)

+ GetJobRuns func(jobName string) ([]*JobRun, error)

+ GetJobs func() []*Job

+ GetMLTaskRun func(transformID, taskRunID string) (*MLTaskRun, error)

+ GetMLTaskRuns func(transformID string) ([]*MLTaskRun, error)

+ GetMLTransform func(id string) (*MLTransform, error)

+ GetMLTransforms func() []*MLTransform

+ GetMaterializedViewRefreshTaskRun func(taskRunID string) (*MaterializedViewRefreshRun, error)

+ GetPartition func(dbName, tableName string, values []string) (*Partition, error)

+ GetPartitionIndexes func(dbName, tableName string) ([]*PartitionIndex, error)

+ GetPartitions func(dbName, tableName string) ([]*Partition, error)

+ GetPlan func(language string) (string, string)

+ GetResourcePolicy func(resourceARN string) (string, string, error)

+ GetSchemaByDefinition func(registryName, schemaName, definition string) (*SchemaVersion, error)

+ GetSchemaVersion func(registryName, schemaName string, versionNumber int64) (*SchemaVersion, error)

+ GetSchemaVersionsDiff func(registryName, schemaName string, v1, v2 int64) (string, error)

+ GetSecurityConfiguration func(name string) (*SecurityConfiguration, error)

+ GetSession func(id string) (*Session, error)

+ GetStatement func(sessionID string, statementID int32) (*Statement, error)

+ GetStatements func(sessionID string) ([]*Statement, error)

+ GetTable func(dbName, tableName string) (*Table, error)

+ GetTableOptimizer func(dbName, tableName, optimizerType string) (*TableOptimizer, error)

+ GetTableVersion func(dbName, tableName, versionID string) (*TableVersion, error)

+ GetTableVersions func(dbName, tableName string) []*TableVersion

+ GetTables func(dbName string) ([]*Table, error)

+ GetTags func(resourceARN string) (map[string]string, error)

+ GetTrigger func(name string) (*Trigger, error)

+ GetTriggers func() []*Trigger

+ GetUsageProfile func(name string) (*UsageProfile, error)

+ GetUserDefinedFunction func(dbName, name string) (*UserDefinedFunction, error)

+ GetUserDefinedFunctions func(dbName string) []*UserDefinedFunction

+ GetWorkflow func(name string) (*Workflow, error)

+ GetWorkflowRun func(workflowName, runID string) (*WorkflowRun, error)

+ GetWorkflowRuns func(workflowName string) ([]*WorkflowRun, error)

+ GetWorkflows func() []string

+ ImportCatalogToGlue func(catalogID string) error

+ ListBlueprints func() []string

+ ListColumnStatisticsTaskRuns func() []*ColumnStatisticsTaskRun

+ ListConnectionTypes func() []*ConnectionTypeInfo

+ ListCrawlers func() []string

+ ListCrawls func(crawlerName string) ([]*CrawlHistoryEntry, error)

+ ListCustomEntityTypes func() []*CustomEntityType

+ ListDataQualityEvaluationRuns func() []*DataQualityEvaluationRun

+ ListDataQualityResults func() []*DataQualityResult

+ ListDataQualityRuleRecommendationRuns func() []*DQRuleRecommendationRun

+ ListDataQualityRulesets func() []*DataQualityRuleset

+ ListDataQualityStatisticAnnotations func(profileID, statisticID string) []*StatisticAnnotation

+ ListEntities func(connectionName string) ([]EntityDescriptor, error)

+ ListIntegrationResourceProperties func() []*IntegrationResourceProperty

+ ListIntegrations func() []*Integration

+ ListMaterializedViewRefreshTaskRuns func() []*MaterializedViewRefreshRun

+ ListRegistries func() []*Registry

+ ListResourcePolicies func() []*resourcePolicyEntry

+ ListSchemaVersions func(registryName, schemaName string) []*SchemaVersion

+ ListSchemas func(registryName string) []*Schema

+ ListSecurityConfigurations func() []*SecurityConfiguration

+ ListSessions func() []*Session

+ ListUsageProfiles func() []*UsageProfile

+ ModifyIntegration func(name string) error

+ PutDataCatalogEncryptionSettings func(catalogID string, settings DataCatalogEncryptionSettings) error

+ PutDataQualityStatisticAnnotation func(profileID, statisticID, inclusion string)

+ PutResourcePolicy func(policy, resourceARN, existsCondition, hashCondition string) (string, error)

+ PutSchemaVersionMetadata func(schemaVersionID, key, value string) error

+ PutWorkflowRunProperties func(workflowName, runID string, props map[string]string) error

+ QuerySchemaVersionMetadata func(schemaVersionID string) map[string]string

+ Region func() string

+ RegisterConnectionType func(name, description string) (*ConnectionTypeInfo, error)

+ RegisterSchemaVersion func(registryName, schemaName, schemaDefinition string) (*SchemaVersion, error)

+ RemoveSchemaVersionMetadata func(schemaVersionID, key string) error

+ Reset func()

+ ResetJobBookmark func(jobName string) error

+ ResetJobBookmarkWithResult func(jobName string) (*JobBookmark, error)

+ ResumeWorkflowRun func(workflowName, runID string) (string, []string, error)

+ RunStatement func(sessionID, code string) (*Statement, error)

+ SearchTables func(searchText string) []*Table

+ StartBlueprintRun func(blueprintName string) (*BlueprintRun, error)

+ StartColumnStatisticsTaskRun func(dbName, tableName string) (*ColumnStatisticsTaskRun, error)

+ StartColumnStatisticsTaskRunSchedule func(dbName, tableName string) error

+ StartCrawler func(name string) error

+ StartCrawlerSchedule func(name string) error

+ StartDataQualityRuleRecommendationRun func(s3Path string) (*DQRuleRecommendationRun, error)

+ StartDataQualityRulesetEvaluationRun func(rulesetNames []string) (*DataQualityEvaluationRun, error)

+ StartExportLabelsTaskRun func(transformID, outputPath string) (*MLTaskRun, error)

+ StartImportLabelsTaskRun func(transformID, inputPath string) (*MLTaskRun, error)

+ StartJobRun func(jobName string, arguments map[string]string) (*JobRun, error)

+ StartMLEvaluationTaskRun func(transformID string) (*MLTaskRun, error)

+ StartMLLabelingSetGenerationTaskRun func(transformID string) (*MLTaskRun, error)

+ StartMaterializedViewRefreshTaskRun func(dbName, tableName string) (*MaterializedViewRefreshRun, error)

+ StartReconciler func(ctx context.Context)

+ StartTrigger func(name string) error

+ StartWorkflowRun func(name string) (*WorkflowRun, error)

+ StopColumnStatisticsTaskRun func(runID string) error

+ StopColumnStatisticsTaskRunSchedule func(dbName, tableName string) error

+ StopCrawler func(name string) error

+ StopCrawlerSchedule func(name string) error

+ StopMaterializedViewRefreshTaskRun func(taskRunID string) error

+ StopReconciler func()

+ StopSession func(id string) error

+ StopTrigger func(name string) error

+ StopWorkflowRun func(workflowName, runID string) error

+ TagResource func(resourceARN string, tags map[string]string) error

+ UntagResource func(resourceARN string, tagKeys []string) error

+ UpdateBlueprint func(name string) (*Blueprint, error)

+ UpdateCatalog func(catalogID, description string, params map[string]string) error

+ UpdateClassifier func(c Classifier) error

+ UpdateColumnStatisticsForPartition func(dbName, tableName string, partitionValues []string, stats []*ColumnStatistics) error

+ UpdateColumnStatisticsForTable func(dbName, tableName string, stats []*ColumnStatistics) error

+ UpdateColumnStatisticsTaskSettings func(dbName, tableName, roleArn string) error

+ UpdateConnection func(name string, connType string, props map[string]string) error

+ UpdateCrawler func(name, role, dbName string, targets CrawlerTarget) error

+ UpdateCrawlerSchedule func(name, scheduleExpression string) error

+ UpdateCrawlerWithOptions func(name, role, dbName string, targets CrawlerTarget, opts CrawlerOptions) error

+ UpdateDataQualityRuleset func(name, ruleset string) error

+ UpdateDatabase func(name string, input DatabaseInput) error

+ UpdateDevEndpoint func(name string, args map[string]string) error

+ UpdateGlueIdentityCenterConfiguration func(instanceARN string) error

+ UpdateIntegrationResourceProperty func(resourceArn string, sourceProps, targetProps map[string]string) (*IntegrationResourceProperty, error)

+ UpdateIntegrationTableProperties func(resourceArn, tableName string, sourceConfig, targetConfig map[string]any) error

+ UpdateJob func(name string, input Job) error

+ UpdateJobFromSourceControl func(jobName string, details SourceControlDetails) error

+ UpdateMLTransform func(id string, update MLTransform) error

+ UpdatePartition func(dbName, tableName string, partitionValues []string, input PartitionInput) error

+ UpdateRegistry func(name, description string) error

+ UpdateSchema func(registryName, schemaName, compatibility, description string) error

+ UpdateSourceControlFromJob func(jobName string, details SourceControlDetails) error

+ UpdateTable func(dbName string, input TableInput) error

+ UpdateTableOptimizer func(dbName, tableName, optimizerType string, config TableOptimizerConfiguration) error

+ UpdateTrigger func(name string, update Trigger) error

+ UpdateUsageProfile func(name, description string) (*UsageProfile, error)

+ UpdateUserDefinedFunction func(dbName, name string, input UserDefinedFunction) error

+ UpdateWorkflow func(name string, update Workflow) error

+ type StorageDescriptor struct

+ BucketColumns []string

+ Columns []Column

+ Compressed bool

+ InputFormat string

+ Location string

+ NumberOfBuckets int

+ OutputFormat string

+ Parameters map[string]string

+ SerdeInfo *SerDeInfo

+ SortColumns []Order

+ StoredAsSubDirectories bool

+ type Table struct

+ CatalogID string

+ CreateTime float64

+ DatabaseName string

+ Description string

+ Name string

+ Owner string

+ Parameters map[string]string

+ PartitionKeys []Column

+ Retention int

+ StorageDescriptor StorageDescriptor

+ TableType string

+ UpdateTime float64

+ type TableError struct

+ ErrorDetail ErrorDetail

+ TableName string

+ type TableInput struct

+ Description string

+ Name string

+ Owner string

+ Parameters map[string]string

+ PartitionKeys []Column

+ Retention int

+ StorageDescriptor StorageDescriptor

+ TableType string

+ type TableOptimizer struct

+ CatalogID string

+ Configuration TableOptimizerConfiguration

+ DatabaseName string

+ LastRun *TableOptimizerRun

+ TableName string

+ Type string

+ type TableOptimizerConfiguration struct

+ Enabled bool

+ RoleARN string

+ type TableOptimizerRun struct

+ EndedAt float64

+ Error string

+ EventType string

+ Metrics any

+ StartedAt float64

+ type TableVersion struct

+ Table *Table

+ VersionID string

+ type TableVersionError struct

+ ErrorDetail ErrorDetail

+ TableName string

+ VersionID string

+ type Trigger struct

+ ARN string

+ Actions []TriggerAction

+ Name string

+ Predicate *TriggerPredicate

+ Schedule string

+ StartOnCreation bool

+ State string

+ Tags map[string]string

+ Type string

+ type TriggerAction struct

+ Arguments map[string]string

+ CrawlerName string

+ JobName string

+ type TriggerCondition struct

+ JobName string

+ LogicalOperator string

+ State string

+ type TriggerPredicate struct

+ Conditions []TriggerCondition

+ Logical string

+ type UsageProfile struct

+ CreatedOn time.Time

+ Description string

+ LastModifiedOn time.Time

+ Name string

+ Tags map[string]string

+ type UserDefinedFunction struct

+ ClassName string

+ CreateTime float64

+ DatabaseName string

+ FunctionARN string

+ FunctionName string

+ OwnerName string

+ OwnerType string

+ ResourceURIs []ResourceURI

+ type Workflow struct

+ ARN string

+ CreatedOn float64

+ DefaultRunProperties map[string]string

+ Description string

+ LastModifiedOn float64

+ Name string

+ Tags map[string]string

+ type WorkflowRun struct

+ CompletedOn float64

+ Properties map[string]string

+ RunID string

+ StartedOn float64

+ Status string

+ WorkflowName string

+ type XMLClassifier struct

+ Classification string

+ Name string

+ RowTag string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL