Package 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.options.PipelineOptions

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

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

TestPipelineOptions.AlwaysPassMatcher, TestPipelineOptions.AlwaysPassMatcherFactory

Method Summary

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

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

populateDisplayData

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.testing.TestPipelineOptions

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

Method Details

getBigtableChangeStreamInstanceId

@String("beam-test")
String getBigtableChangeStreamInstanceId()

setBigtableChangeStreamInstanceId

void setBigtableChangeStreamInstanceId(String value)