Package io.github.flink.gcp.connector.bigtable.table
package io.github.flink.gcp.connector.bigtable.table
-
ClassDescriptionThe
WITHoptions of thebigtabletable connector.Creates thebigtabletable sink and table source from aCREATE TABLEstatement's options.The lookup values aCREATE TABLEmaps into the Bigtable table source.The DDL schema of abigtabletable: which column is the row key, and which column family and qualifier every other column addresses.One column family: aROWcolumn whose nested fields are its qualifiers.One qualifier: a nested field of a column family'sROW.Turns aRowDatafield into the bytes of a Bigtable cell, and back.Reads the bytes of a cell as one field of a row.Reads one field of a row as the bytes of a cell.The physical changelog representation emitted by a Bigtable Change Streams table source.A table option's Bigtable Change Streams start-position mode.What the Bigtable table sink tells the planner when the requested changelog is insert-only.Applies Table API option values to DataStream builder setters, renaming a rejected value's failure to the option key the SQL caller actually wrote (issue #1030, ADR-0133).How a Bigtable table option represents a row-key bound.Which Bigtable read surface a table source uses.The physical primary key and value-format payload of a selected-cell table.What a fixed-width decoder does with a cell or row key longer than the declared type's layout.