Package org.apache.beam.sdk.io.gcp.bigtable.changestreams.model

Class InitialPipelineState

java.lang.Object

org.apache.beam.sdk.io.gcp.bigtable.changestreams.model.InitialPipelineState

All Implemented Interfaces:

Serializable

@Internal
public class InitialPipelineState
extends Object
implements Serializable

States to initialize a pipeline outputted by InitializeDoFn.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
InitialPipelineState(Instant startTime, boolean resume)

Method Summary

Modifier and Type	Method	Description
boolean	equals(@Nullable Object o)
Instant	getStartTime()
int	hashCode()
boolean	isResume()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

InitialPipelineState

public InitialPipelineState(Instant startTime,
 boolean resume)

Method Details

getStartTime

public Instant getStartTime()

isResume

public boolean isResume()

equals

public boolean equals(@Nullable Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object