Service for creating and managing Data Fusion instances.
Data Fusion enables ETL developers to build code-free, data integration pipelines via a point-and-click UI.
Equality
Instances of this class created via copy-construction or copy-assignment always compare equal. Instances created with equal std::shared_ptr<*Connection>
objects compare equal. Objects that compare equal share the same underlying resources.
Performance
Creating a new instance of this class is a relatively expensive operation, new objects establish new connections to the service. In contrast, copy-construction, move-construction, and the corresponding assignment operations are relatively efficient as the copies share all underlying resources.
Thread Safety
Concurrent access to different instances of this class, even if they compare equal, is guaranteed to work. Two or more threads operating on the same instance of this class is not guaranteed to work. Since copy-construction and move-construction is a relatively efficient operation, consider using such a copy when using this class from multiple threads.
Constructors
DataFusionClient(DataFusionClient const &)
Copy and move support
Parameter | |
---|---|
Name | Description |
|
DataFusionClient const &
|
DataFusionClient(DataFusionClient &&)
Copy and move support
Parameter | |
---|---|
Name | Description |
|
DataFusionClient &&
|
DataFusionClient(std::shared_ptr< DataFusionConnection >, Options)
Parameters | |
---|---|
Name | Description |
connection |
std::shared_ptr< DataFusionConnection >
|
opts |
Options
|
Operators
operator=(DataFusionClient const &)
Copy and move support
Parameter | |
---|---|
Name | Description |
|
DataFusionClient const &
|
Returns | |
---|---|
Type | Description |
DataFusionClient & |
operator=(DataFusionClient &&)
Copy and move support
Parameter | |
---|---|
Name | Description |
|
DataFusionClient &&
|
Returns | |
---|---|
Type | Description |
DataFusionClient & |
Functions
ListAvailableVersions(std::string const &, Options)
Lists possible versions for Data Fusion instances in the specified project and location.
Parameters | |
---|---|
Name | Description |
parent |
std::string const &
Required. The project and location for which to retrieve instance information in the format projects/{project}/locations/{location}. |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
StreamRange< google::cloud::datafusion::v1::Version > | a StreamRange to iterate of the results. See the documentation of this type for details. In brief, this class has |
ListAvailableVersions(google::cloud::datafusion::v1::ListAvailableVersionsRequest, Options)
Lists possible versions for Data Fusion instances in the specified project and location.
Parameters | |
---|---|
Name | Description |
request |
google::cloud::datafusion::v1::ListAvailableVersionsRequest
Unary RPCs, such as the one wrapped by this function, receive a single |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
StreamRange< google::cloud::datafusion::v1::Version > | a StreamRange to iterate of the results. See the documentation of this type for details. In brief, this class has |
ListInstances(google::cloud::datafusion::v1::ListInstancesRequest, Options)
Lists Data Fusion instances in the specified project and location.
Parameters | |
---|---|
Name | Description |
request |
google::cloud::datafusion::v1::ListInstancesRequest
Unary RPCs, such as the one wrapped by this function, receive a single |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
StreamRange< google::cloud::datafusion::v1::Instance > | a StreamRange to iterate of the results. See the documentation of this type for details. In brief, this class has |
GetInstance(google::cloud::datafusion::v1::GetInstanceRequest const &, Options)
Gets details of a single Data Fusion instance.
Parameters | |
---|---|
Name | Description |
request |
google::cloud::datafusion::v1::GetInstanceRequest const &
Unary RPCs, such as the one wrapped by this function, receive a single |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
StatusOr< google::cloud::datafusion::v1::Instance > | the result of the RPC. The response message type (google.cloud.datafusion.v1.Instance) is mapped to a C++ class using the Protobuf mapping rules. If the request fails, the |
CreateInstance(std::string const &, google::cloud::datafusion::v1::Instance const &, std::string const &, Options)
Creates a new Data Fusion instance in the specified project and location.
Parameters | |
---|---|
Name | Description |
parent |
std::string const &
Required. The instance's project and location in the format projects/{project}/locations/{location}. |
instance |
google::cloud::datafusion::v1::Instance const &
An instance resource. |
instance_id |
std::string const &
Required. The name of the instance to create. |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
future< StatusOr< google::cloud::datafusion::v1::Instance > > | A |
CreateInstance(google::cloud::datafusion::v1::CreateInstanceRequest const &, Options)
Creates a new Data Fusion instance in the specified project and location.
Parameters | |
---|---|
Name | Description |
request |
google::cloud::datafusion::v1::CreateInstanceRequest const &
Unary RPCs, such as the one wrapped by this function, receive a single |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
future< StatusOr< google::cloud::datafusion::v1::Instance > > | A |
DeleteInstance(std::string const &, Options)
Deletes a single Date Fusion instance.
Parameters | |
---|---|
Name | Description |
name |
std::string const &
Required. The instance resource name in the format projects/{project}/locations/{location}/instances/{instance} |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
future< StatusOr< google::cloud::datafusion::v1::OperationMetadata > > | A |
DeleteInstance(google::cloud::datafusion::v1::DeleteInstanceRequest const &, Options)
Deletes a single Date Fusion instance.
Parameters | |
---|---|
Name | Description |
request |
google::cloud::datafusion::v1::DeleteInstanceRequest const &
Unary RPCs, such as the one wrapped by this function, receive a single |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
future< StatusOr< google::cloud::datafusion::v1::OperationMetadata > > | A |
UpdateInstance(google::cloud::datafusion::v1::Instance const &, google::protobuf::FieldMask const &, Options)
Updates a single Data Fusion instance.
Parameters | |
---|---|
Name | Description |
instance |
google::cloud::datafusion::v1::Instance const &
Required. The instance resource that replaces the resource on the server. Currently, Data Fusion only allows replacing labels, options, and stack driver settings. All other fields will be ignored. |
update_mask |
google::protobuf::FieldMask const &
Field mask is used to specify the fields that the update will overwrite in an instance resource. The fields specified in the update_mask are relative to the resource, not the full request. A field will be overwritten if it is in the mask. If the user does not provide a mask, all the supported fields (labels, options, and version currently) will be overwritten. |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
future< StatusOr< google::cloud::datafusion::v1::Instance > > | A |
UpdateInstance(google::cloud::datafusion::v1::UpdateInstanceRequest const &, Options)
Updates a single Data Fusion instance.
Parameters | |
---|---|
Name | Description |
request |
google::cloud::datafusion::v1::UpdateInstanceRequest const &
Unary RPCs, such as the one wrapped by this function, receive a single |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
future< StatusOr< google::cloud::datafusion::v1::Instance > > | A |
RestartInstance(google::cloud::datafusion::v1::RestartInstanceRequest const &, Options)
Restart a single Data Fusion instance.
At the end of an operation instance is fully restarted.
Parameters | |
---|---|
Name | Description |
request |
google::cloud::datafusion::v1::RestartInstanceRequest const &
Unary RPCs, such as the one wrapped by this function, receive a single |
opts |
Options
Optional. Override the class-level options, such as retry and backoff policies. |
Returns | |
---|---|
Type | Description |
future< StatusOr< google::cloud::datafusion::v1::Instance > > | A |