Package io.github.flink.gcp.connector.bigtable.table
package io.github.flink.gcp.connector.bigtable.table
-
ClassDescriptionThe
WITHoptions of thebigtablecatalog, created byCREATE CATALOG ... WITH ('type' = 'bigtable', ...).TheWITHoptions 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, or aMAPcolumn whose entries are.One qualifier: a nested field of a column family'sROW.The Flink type thebigtablecatalog gives a table's row key and the keys of its column family maps, which are the qualifiers.Turns aRowDatafield, or an element of aMAPfamily's value array, into the bytes of a Bigtable cell, and back.Reads one element of an array as the bytes of a cell: aMAPfamily's key or value.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.What the Bigtable table sink does with aMAPfamily's qualifiers a row does not carry.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.Destination-side write operation selected by sink.write-mode.