Package io.github.flink.gcp.connector.bigtable.sink

Class BigtableSinkConfig<T>

java.lang.Object
io.github.flink.gcp.connector.bigtable.sink.BigtableSinkConfig<T>
Type Parameters:
T - type of the records written by the sink
All Implemented Interfaces:
Serializable
@Internal public final class BigtableSinkConfig<T> extends Object implements Serializable
Immutable sink configuration assembled by BigtableSinkBuilder.
See Also:

  • Method Details

    • getDestinationResolver

      public DestinationResolver<? super T> getDestinationResolver()
      Returns the resolver naming the table each record is written to.

    • getSerializer

      public BigtableSerializationSchema<? super T> getSerializer()
      Returns the record serialization schema.

    • getAppProfileId

      @Nullable public String getAppProfileId()
      Returns the application profile the client routes through, or null for the instance's default profile.

    • getWriterOptions

      public BigtableWriterOptions getWriterOptions()
      Returns the writer tuning options.

    • getFailedMutationHandler

      public FailureHandler<? super FailedMutation> getFailedMutationHandler()
      Returns the policy for mutations that terminally fail.

    • getServiceAccountKeyFile

      @Nullable public String getServiceAccountKeyFile()
      Returns the service-account key-file path, or null to use ADC.

    • getEmulatorEndpoint

      @Nullable public EmulatorEndpoint getEmulatorEndpoint()
      Returns the emulator endpoint, or null for production Bigtable.

    • getCreateDisposition

      public CreateDisposition getCreateDisposition()
      Returns whether the sink may create a missing table.

    • getTableCreateOptions

      @Nullable public TableCreateOptions getTableCreateOptions()
      Returns the settings for the table the sink creates, or null under CreateDisposition.CREATE_NEVER — the builder rejects every other combination.