ChangeStreamRecordMetadata.Builder (Apache Beam 2.39.0)

java.lang.Object
- org.apache.beam.sdk.io.gcp.spanner.changestreams.model.ChangeStreamRecordMetadata.Builder

Enclosing class:: ChangeStreamRecordMetadata

public static class ChangeStreamRecordMetadata.Builder
extends java.lang.Object

Constructor Summary

Constructors
Constructor and Description

Builder()

Constructors
Constructor and Description
`Builder()`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`ChangeStreamRecordMetadata`	`build()` Builds the `ChangeStreamRecordMetadata`.
`ChangeStreamRecordMetadata.Builder`	`withNumberOfRecordsRead(long numberOfRecordsRead)` Sets the number of records read in the partition change stream query before reading this record.
`ChangeStreamRecordMetadata.Builder`	`withPartitionCreatedAt(com.google.cloud.Timestamp partitionCreatedAt)` Sets the time at which this partition was first detected and created in the metadata table.
`ChangeStreamRecordMetadata.Builder`	`withPartitionEndTimestamp(com.google.cloud.Timestamp partitionEndTimestamp)` Sets the end time for the partition change stream query that originated this record.
`ChangeStreamRecordMetadata.Builder`	`withPartitionRunningAt(com.google.cloud.Timestamp partitionRunningAt)` Sets the time at which the connector started processing this partition.
`ChangeStreamRecordMetadata.Builder`	`withPartitionScheduledAt(com.google.cloud.Timestamp partitionScheduledAt)` Sets the time at which this partition was scheduled to be queried.
`ChangeStreamRecordMetadata.Builder`	`withPartitionStartTimestamp(com.google.cloud.Timestamp partitionStartTimestamp)` Sets the start time for the partition change stream query that originated this record.
`ChangeStreamRecordMetadata.Builder`	`withPartitionToken(java.lang.String partitionToken)` Sets the partition token where this record originated from.
`ChangeStreamRecordMetadata.Builder`	`withQueryStartedAt(com.google.cloud.Timestamp queryStartedAt)` Sets the time that the change stream query which produced this record started.
`ChangeStreamRecordMetadata.Builder`	`withRecordReadAt(com.google.cloud.Timestamp recordReadAt)` Sets the time at which the record was fully read.
`ChangeStreamRecordMetadata.Builder`	`withRecordStreamEndedAt(com.google.cloud.Timestamp recordStreamEndedAt)` Sets the time at which the record finished streaming.
`ChangeStreamRecordMetadata.Builder`	`withRecordStreamStartedAt(com.google.cloud.Timestamp recordStreamStartedAt)` Sets the time at which the record started to be streamed.
`ChangeStreamRecordMetadata.Builder`	`withRecordTimestamp(com.google.cloud.Timestamp recordTimestamp)` Sets the timestamp of when this record occurred.
`ChangeStreamRecordMetadata.Builder`	`withTotalStreamTimeMillis(long totalStreamTimeMillis)` Sets the total streaming time (in millis) for this record.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - Builder
```
public Builder()
```
- Method Detail
  - withPartitionToken
```
public ChangeStreamRecordMetadata.Builder withPartitionToken(java.lang.String partitionToken)
```
    Sets the partition token where this record originated from.
    
    Parameters:
    
    partitionToken - the partition token to be set
    
    Returns:
    
    Builder
  - withRecordTimestamp
```
public ChangeStreamRecordMetadata.Builder withRecordTimestamp(com.google.cloud.Timestamp recordTimestamp)
```
    Sets the timestamp of when this record occurred.
    
    Parameters:
    
    recordTimestamp - the timestamp to be set
    
    Returns:
    
    Builder
  - withPartitionStartTimestamp
```
public ChangeStreamRecordMetadata.Builder withPartitionStartTimestamp(com.google.cloud.Timestamp partitionStartTimestamp)
```
    Sets the start time for the partition change stream query that originated this record.
    
    Parameters:
    
    partitionStartTimestamp - the timestamp to be set
    
    Returns:
    
    Builder
  - withPartitionEndTimestamp
```
public ChangeStreamRecordMetadata.Builder withPartitionEndTimestamp(com.google.cloud.Timestamp partitionEndTimestamp)
```
    Sets the end time for the partition change stream query that originated this record.
    
    Parameters:
    
    partitionEndTimestamp - the timestamp to be set
    
    Returns:
    
    Builder
  - withPartitionCreatedAt
```
public ChangeStreamRecordMetadata.Builder withPartitionCreatedAt(com.google.cloud.Timestamp partitionCreatedAt)
```
    Sets the time at which this partition was first detected and created in the metadata table.
    
    Parameters:
    
    partitionCreatedAt - the timestamp to be set
    
    Returns:
    
    Builder
  - withPartitionScheduledAt
```
public ChangeStreamRecordMetadata.Builder withPartitionScheduledAt(@Nullable
                                                                   com.google.cloud.Timestamp partitionScheduledAt)
```
    Sets the time at which this partition was scheduled to be queried.
    
    Parameters:
    
    partitionScheduledAt - the timestamp to be set
    
    Returns:
    
    Builder
  - withPartitionRunningAt
```
public ChangeStreamRecordMetadata.Builder withPartitionRunningAt(@Nullable
                                                                 com.google.cloud.Timestamp partitionRunningAt)
```
    Sets the time at which the connector started processing this partition.
    
    Parameters:
    
    partitionRunningAt - the timestamp to be set
    
    Returns:
    
    Builder
  - withQueryStartedAt
```
public ChangeStreamRecordMetadata.Builder withQueryStartedAt(com.google.cloud.Timestamp queryStartedAt)
```
    Sets the time that the change stream query which produced this record started.
    
    Parameters:
    
    queryStartedAt - the timestamp to be set
    
    Returns:
    
    Builder
  - withRecordStreamStartedAt
```
public ChangeStreamRecordMetadata.Builder withRecordStreamStartedAt(com.google.cloud.Timestamp recordStreamStartedAt)
```
    Sets the time at which the record started to be streamed.
    
    Parameters:
    
    recordStreamStartedAt - the timestamp to be set
    
    Returns:
    
    Builder
  - withRecordStreamEndedAt
```
public ChangeStreamRecordMetadata.Builder withRecordStreamEndedAt(com.google.cloud.Timestamp recordStreamEndedAt)
```
    Sets the time at which the record finished streaming.
    
    Parameters:
    
    recordStreamEndedAt - the timestamp to be set
    
    Returns:
    
    Builder
  - withRecordReadAt
```
public ChangeStreamRecordMetadata.Builder withRecordReadAt(com.google.cloud.Timestamp recordReadAt)
```
    Sets the time at which the record was fully read.
    
    Parameters:
    
    recordReadAt - the timestamp to be set
    
    Returns:
    
    Builder
  - withTotalStreamTimeMillis
```
public ChangeStreamRecordMetadata.Builder withTotalStreamTimeMillis(long totalStreamTimeMillis)
```
    Sets the total streaming time (in millis) for this record.
    
    Parameters:
    
    totalStreamTimeMillis - the total time in millis
    
    Returns:
    
    Builder
  - withNumberOfRecordsRead
```
public ChangeStreamRecordMetadata.Builder withNumberOfRecordsRead(long numberOfRecordsRead)
```
    Sets the number of records read in the partition change stream query before reading this record.
    
    Parameters:
    
    numberOfRecordsRead - the number of records read
    
    Returns:
    
    Builder
  - build
```
public ChangeStreamRecordMetadata build()
```
    Builds the ChangeStreamRecordMetadata.
    
    Returns:
    
    ChangeStreamRecordMetadata

Class ChangeStreamRecordMetadata.Builder

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Builder

Method Detail

withPartitionToken

withRecordTimestamp

withPartitionStartTimestamp

withPartitionEndTimestamp

withPartitionCreatedAt

withPartitionScheduledAt

withPartitionRunningAt

withQueryStartedAt

withRecordStreamStartedAt

withRecordStreamEndedAt

withRecordReadAt

withTotalStreamTimeMillis

withNumberOfRecordsRead

build