Class DebeziumTransformRegistrar.ReadBuilder.Configuration

java.lang.Object
org.apache.beam.io.debezium.DebeziumTransformRegistrar.ReadBuilder.Configuration
Enclosing class:
DebeziumTransformRegistrar.ReadBuilder

public static class DebeziumTransformRegistrar.ReadBuilder.Configuration extends Object
  • Constructor Details

    • Configuration

      public Configuration()
  • Method Details

    • setConnectionProperties

      public void setConnectionProperties(@Nullable List<String> connectionProperties)
    • setMaxNumberOfRecords

      public void setMaxNumberOfRecords(@Nullable Long maxNumberOfRecords)
    • setUsername

      public void setUsername(String username)
    • setPassword

      public void setPassword(String password)
    • setHost

      public void setHost(String host)
    • setPort

      public void setPort(String port)
    • setConnectorClass

      public void setConnectorClass(String connectorClass)