Classes
AvroFileFormat
AVRO file format configuration.
BackfillJob
Represents a backfill job on a specific stream object.
BackfillJob.Types
Container for nested types declared in the BackfillJob message type.
BigQueryDestinationConfig
BigQuery destination configuration
BigQueryDestinationConfig.Types
Container for nested types declared in the BigQueryDestinationConfig message type.
BigQueryDestinationConfig.Types.SingleTargetDataset
A single target dataset to which all data will be streamed.
BigQueryDestinationConfig.Types.SourceHierarchyDatasets
Destination datasets are created so that hierarchy of the destination data objects matches the source hierarchy.
BigQueryDestinationConfig.Types.SourceHierarchyDatasets.Types
Container for nested types declared in the SourceHierarchyDatasets message type.
BigQueryDestinationConfig.Types.SourceHierarchyDatasets.Types.DatasetTemplate
Dataset template used for dynamic dataset creation.
BigQueryProfile
BigQuery warehouse profile.
ConnectionProfile
A set of reusable connection configurations to be used as a source or destination for a stream.
ConnectionProfileName
Resource name for the ConnectionProfile resource.
CreateConnectionProfileRequest
Request message for creating a connection profile.
CreatePrivateConnectionRequest
Request for creating a private connection.
CreateRouteRequest
Route creation request.
CreateStreamRequest
Request message for creating a stream.
Datastream
Datastream service
Datastream.DatastreamBase
Base class for server-side implementations of Datastream
Datastream.DatastreamClient
Client for Datastream
DatastreamClient
Datastream client wrapper, for convenient use.
DatastreamClientBuilder
Builder class for DatastreamClient to provide simple configuration of credentials, endpoint etc.
DatastreamClientImpl
Datastream client wrapper implementation, for convenient use.
DatastreamSettings
Settings for DatastreamClient instances.
DeleteConnectionProfileRequest
Request message for deleting a connection profile.
DeletePrivateConnectionRequest
Request to delete a private connection.
DeleteRouteRequest
Route deletion request.
DeleteStreamRequest
Request message for deleting a stream.
DestinationConfig
The configuration of the stream destination.
DiscoverConnectionProfileRequest
Request message for 'discover' ConnectionProfile request.
DiscoverConnectionProfileResponse
Response from a discover request.
Error
Represent a user-facing Error.
FetchStaticIpsRequest
Request message for 'FetchStaticIps' request.
FetchStaticIpsResponse
Response message for a 'FetchStaticIps' response.
ForwardSshTunnelConnectivity
Forward SSH Tunnel connectivity.
GcsDestinationConfig
Google Cloud Storage destination configuration
GcsProfile
Cloud Storage bucket profile.
GetConnectionProfileRequest
Request message for getting a connection profile.
GetPrivateConnectionRequest
Request to get a private connection configuration.
GetRouteRequest
Route get request.
GetStreamObjectRequest
Request for fetching a specific stream object.
GetStreamRequest
Request message for getting a stream.
JsonFileFormat
JSON file format configuration.
JsonFileFormat.Types
Container for nested types declared in the JsonFileFormat message type.
ListConnectionProfilesRequest
Request message for listing connection profiles.
ListConnectionProfilesResponse
Response message for listing connection profiles.
ListPrivateConnectionsRequest
Request for listing private connections.
ListPrivateConnectionsResponse
Response containing a list of private connection configurations.
ListRoutesRequest
Route list request.
ListRoutesResponse
Route list response.
ListStreamObjectsRequest
Request for listing all objects for a specific stream.
ListStreamObjectsResponse
Response containing the objects for a stream.
ListStreamsRequest
Request message for listing streams.
ListStreamsResponse
Response message for listing streams.
LookupStreamObjectRequest
Request for looking up a specific stream object by its source object identifier.
MysqlColumn
MySQL Column.
MysqlDatabase
MySQL database.
MysqlProfile
MySQL database profile.
MysqlRdbms
MySQL database structure
MysqlSourceConfig
MySQL source configuration
MysqlSslConfig
MySQL SSL configuration information.
MysqlTable
MySQL table.
NetworksName
Resource name for the Networks resource.
OperationMetadata
Represents the metadata of the long-running operation.
OracleColumn
Oracle Column.
OracleProfile
Oracle database profile.
OracleRdbms
Oracle database structure.
OracleSchema
Oracle schema.
OracleSourceConfig
Oracle data source configuration
OracleSourceConfig.Types
Container for nested types declared in the OracleSourceConfig message type.
OracleSourceConfig.Types.DropLargeObjects
Configuration to drop large object values.
OracleSourceConfig.Types.StreamLargeObjects
Configuration to stream large object values.
OracleTable
Oracle table.
PostgresqlColumn
PostgreSQL Column.
PostgresqlProfile
PostgreSQL database profile.
PostgresqlRdbms
PostgreSQL database structure.
PostgresqlSchema
PostgreSQL schema.
PostgresqlSourceConfig
PostgreSQL data source configuration
PostgresqlTable
PostgreSQL table.
PrivateConnection
The PrivateConnection resource is used to establish private connectivity between Datastream and a customer's network.
PrivateConnection.Types
Container for nested types declared in the PrivateConnection message type.
PrivateConnectionName
Resource name for the PrivateConnection resource.
PrivateConnectivity
Private Connectivity
Route
The route resource is the child of the private connection resource, used for defining a route for a private connection.
RouteName
Resource name for the Route resource.
SourceConfig
The configuration of the stream source.
SourceObjectIdentifier
Represents an identifier of an object in the data source.
SourceObjectIdentifier.Types
Container for nested types declared in the SourceObjectIdentifier message type.
SourceObjectIdentifier.Types.MysqlObjectIdentifier
Mysql data source object identifier.
SourceObjectIdentifier.Types.OracleObjectIdentifier
Oracle data source object identifier.
SourceObjectIdentifier.Types.PostgresqlObjectIdentifier
PostgreSQL data source object identifier.
StartBackfillJobRequest
Request for manually initiating a backfill job for a specific stream object.
StartBackfillJobResponse
Response for manually initiating a backfill job for a specific stream object.
StaticServiceIpConnectivity
Static IP address connectivity. Used when the source database is configured to allow incoming connections from the Datastream public IP addresses for the region specified in the connection profile.
StopBackfillJobRequest
Request for manually stopping a running backfill job for a specific stream object.
StopBackfillJobResponse
Response for manually stop a backfill job for a specific stream object.
Stream
A resource representing streaming data from a source to a destination.
Stream.Types
Container for nested types declared in the Stream message type.
Stream.Types.BackfillAllStrategy
Backfill strategy to automatically backfill the Stream's objects. Specific objects can be excluded.
Stream.Types.BackfillNoneStrategy
Backfill strategy to disable automatic backfill for the Stream's objects.
StreamName
Resource name for the Stream resource.
StreamObject
A specific stream object (e.g a specific DB table).
StreamObjectName
Resource name for the StreamObject resource.
UpdateConnectionProfileRequest
Connection profile update message.
UpdateStreamRequest
Request message for updating a stream.
Validation
A validation to perform on a stream.
Validation.Types
Container for nested types declared in the Validation message type.
ValidationMessage
Represent user-facing validation result message.
ValidationMessage.Types
Container for nested types declared in the ValidationMessage message type.
ValidationResult
Contains the current validation results.
VpcPeeringConfig
The VPC Peering configuration is used to create VPC peering between Datastream and the consumer's VPC.
Enums
BackfillJob.Types.State
State of the stream object's backfill job.
BackfillJob.Types.Trigger
Triggering reason for a backfill job.
BigQueryDestinationConfig.DatasetConfigOneofCase
Enum of possible cases for the "dataset_config" oneof.
ConnectionProfile.ConnectivityOneofCase
Enum of possible cases for the "connectivity" oneof.
ConnectionProfile.ProfileOneofCase
Enum of possible cases for the "profile" oneof.
ConnectionProfileName.ResourceNameType
The possible contents of ConnectionProfileName.
DestinationConfig.DestinationStreamConfigOneofCase
Enum of possible cases for the "destination_stream_config" oneof.
DiscoverConnectionProfileRequest.DataObjectOneofCase
Enum of possible cases for the "data_object" oneof.
DiscoverConnectionProfileRequest.HierarchyOneofCase
Enum of possible cases for the "hierarchy" oneof.
DiscoverConnectionProfileRequest.TargetOneofCase
Enum of possible cases for the "target" oneof.
DiscoverConnectionProfileResponse.DataObjectOneofCase
Enum of possible cases for the "data_object" oneof.
ForwardSshTunnelConnectivity.AuthenticationMethodOneofCase
Enum of possible cases for the "authentication_method" oneof.
GcsDestinationConfig.FileFormatOneofCase
Enum of possible cases for the "file_format" oneof.
JsonFileFormat.Types.JsonCompression
Json file compression.
JsonFileFormat.Types.SchemaFileFormat
Schema file format.
NetworksName.ResourceNameType
The possible contents of NetworksName.
OracleSourceConfig.LargeObjectsHandlingOneofCase
Enum of possible cases for the "large_objects_handling" oneof.
PrivateConnection.Types.State
Private Connection state.
PrivateConnectionName.ResourceNameType
The possible contents of PrivateConnectionName.
RouteName.ResourceNameType
The possible contents of RouteName.
SourceConfig.SourceStreamConfigOneofCase
Enum of possible cases for the "source_stream_config" oneof.
SourceObjectIdentifier.SourceIdentifierOneofCase
Enum of possible cases for the "source_identifier" oneof.
Stream.BackfillStrategyOneofCase
Enum of possible cases for the "backfill_strategy" oneof.
Stream.Types.BackfillAllStrategy.ExcludedObjectsOneofCase
Enum of possible cases for the "excluded_objects" oneof.
Stream.Types.State
Stream state.
StreamName.ResourceNameType
The possible contents of StreamName.
StreamObjectName.ResourceNameType
The possible contents of StreamObjectName.
Validation.Types.State
Validation execution state.
ValidationMessage.Types.Level
Validation message level.