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

Interface BigtableChangeStreamTestOptions

All Superinterfaces:

HasDisplayData, PipelineOptions, TestPipelineOptions

public interface BigtableChangeStreamTestOptions
extends TestPipelineOptions

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.testing.TestPipelineOptions

TestPipelineOptions.AlwaysPassMatcher, TestPipelineOptions.AlwaysPassMatcherFactory

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method and Description
java.lang.String	getBigtableChangeStreamInstanceId()
void	setBigtableChangeStreamInstanceId(java.lang.String value)

Methods inherited from interface org.apache.beam.sdk.testing.TestPipelineOptions

getOnCreateMatcher, getOnSuccessMatcher, getTempRoot, getTestTimeoutSeconds, isBlockOnRun, setBlockOnRun, setOnCreateMatcher, setOnSuccessMatcher, setTempRoot, setTestTimeoutSeconds

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Method Detail

getBigtableChangeStreamInstanceId

@Default.String(value="beam-test")
java.lang.String getBigtableChangeStreamInstanceId()

setBigtableChangeStreamInstanceId

void setBigtableChangeStreamInstanceId(java.lang.String value)