- Resource: StreamObject
- BackfillJob
- State
- Trigger
- SourceObjectIdentifier
- OracleObjectIdentifier
- MysqlObjectIdentifier
- PostgresqlObjectIdentifier
- SqlServerObjectIdentifier
- SalesforceObjectIdentifier
- MongodbObjectIdentifier
- Methods
Resource: StreamObject
A specific stream object (e.g a specific DB table).
JSON representation |
---|
{ "name" : string , "createTime" : string , "updateTime" : string , "displayName" : string , "errors" : [ { object ( |
Fields | |
---|---|
name
|
Output only. Identifier. The object resource's name. |
createTime
|
Output only. The creation time of the object. Uses RFC 3339, where generated output will always be Z-normalized and use 0, 3, 6 or 9 fractional digits. Offsets other than "Z" are also accepted. Examples: |
updateTime
|
Output only. The last update time of the object. Uses RFC 3339, where generated output will always be Z-normalized and use 0, 3, 6 or 9 fractional digits. Offsets other than "Z" are also accepted. Examples: |
displayName
|
Required. Display name. |
errors[]
|
Output only. Active errors on the object. |
backfillJob
|
The latest backfill job that was initiated for the stream object. |
sourceObject
|
The object identifier in the data source. |
BackfillJob
Represents a backfill job on a specific stream object.
JSON representation |
---|
{ "state" : enum ( |
Fields | |
---|---|
state
|
Output only. Backfill job state. |
trigger
|
Backfill job's triggering reason. |
lastStartTime
|
Output only. Backfill job's start time. Uses RFC 3339, where generated output will always be Z-normalized and use 0, 3, 6 or 9 fractional digits. Offsets other than "Z" are also accepted. Examples: |
lastEndTime
|
Output only. Backfill job's end time. Uses RFC 3339, where generated output will always be Z-normalized and use 0, 3, 6 or 9 fractional digits. Offsets other than "Z" are also accepted. Examples: |
errors[]
|
Output only. Errors which caused the backfill job to fail. |
State
State of the stream object's backfill job.
Enums | |
---|---|
STATE_UNSPECIFIED
|
Default value. |
NOT_STARTED
|
Backfill job was never started for the stream object (stream has backfill strategy defined as manual or object was explicitly excluded from automatic backfill). |
PENDING
|
Backfill job will start pending available resources. |
ACTIVE
|
Backfill job is running. |
STOPPED
|
Backfill job stopped (next job run will start from beginning). |
FAILED
|
Backfill job failed (due to an error). |
COMPLETED
|
Backfill completed successfully. |
UNSUPPORTED
|
Backfill job failed since the table structure is currently unsupported for backfill. |
Trigger
Triggering reason for a backfill job.
Enums | |
---|---|
TRIGGER_UNSPECIFIED
|
Default value. |
AUTOMATIC
|
Object backfill job was triggered automatically according to the stream's backfill strategy. |
MANUAL
|
Object backfill job was triggered manually using the dedicated API. |
SourceObjectIdentifier
Represents an identifier of an object in the data source.
JSON representation |
---|
{ // Union field |
source_identifier
. The identifier for an object in the data source. source_identifier
can be only one of the following:oracleIdentifier
object (
OracleObjectIdentifier
)
Oracle data source object identifier.
mysqlIdentifier
object (
MysqlObjectIdentifier
)
Mysql data source object identifier.
postgresqlIdentifier
object (
PostgresqlObjectIdentifier
)
PostgreSQL data source object identifier.
sqlServerIdentifier
object (
SqlServerObjectIdentifier
)
SQLServer data source object identifier.
salesforceIdentifier
object (
SalesforceObjectIdentifier
)
Salesforce data source object identifier.
mongodbIdentifier
object (
MongodbObjectIdentifier
)
MongoDB data source object identifier.
OracleObjectIdentifier
Oracle data source object identifier.
JSON representation |
---|
{ "schema" : string , "table" : string } |
Fields | |
---|---|
schema
|
Required. The schema name. |
table
|
Required. The table name. |
MysqlObjectIdentifier
Mysql data source object identifier.
JSON representation |
---|
{ "database" : string , "table" : string } |
Fields | |
---|---|
database
|
Required. The database name. |
table
|
Required. The table name. |
PostgresqlObjectIdentifier
PostgreSQL data source object identifier.
JSON representation |
---|
{ "schema" : string , "table" : string } |
Fields | |
---|---|
schema
|
Required. The schema name. |
table
|
Required. The table name. |
SqlServerObjectIdentifier
SQLServer data source object identifier.
JSON representation |
---|
{ "schema" : string , "table" : string } |
Fields | |
---|---|
schema
|
Required. The schema name. |
table
|
Required. The table name. |
SalesforceObjectIdentifier
Salesforce data source object identifier.
JSON representation |
---|
{ "objectName" : string } |
Fields | |
---|---|
objectName
|
Required. The object name. |
MongodbObjectIdentifier
MongoDB data source object identifier.
JSON representation |
---|
{ "database" : string , "collection" : string } |
Fields | |
---|---|
database
|
Required. The database name. |
collection
|
Required. The collection name. |
Methods |
|
---|---|
|
Use this method to get details about a stream object. |
|
Use this method to list the objects of a specific stream. |
|
Use this method to look up a stream object by its source object identifier. |
|
Use this method to start a backfill job for the specified stream object. |
|
Use this method to stop a backfill job for the specified stream object. |