Skip to main content Module postgres Copy item path Source PostgresConfig PostgresSink PostgresSinkWriter PendingOp 🔒 PendingRows 🔒 Rows accumulated across chunks, written out on flush. StatementKind 🔒 CHECK_FOREIGN_KEY_SQL 🔒 MAX_BATCH_ROWS_LIMIT 🔒 Upper bound of max_batch_rows: bigger batches only add buffer memory, since statements are
split at MAX_STATEMENT_PARAMS MAX_STATEMENT_PARAMS 🔒 Maximum number of bind parameters of a single statement. PostgreSQL itself allows 65535, but
the client encodes the parameter count of a Bind message as i16, so a larger batch fails
before ever reaching the server. POSTGRES_SINK convert_row_to_pg_row 🔒 create_delete_sql 🔒 create_insert_sql 🔒 create_parameter_tuples 🔒 ($1, $2), ($3, $4), ...create_upsert_sql 🔒 default_max_batch_rows 🔒 default_schema 🔒 ensure_no_foreign_key 🔒 ensure_no_foreign_key_with_client 🔒 execute_batches 🔒 prev_power_of_two 🔒 Largest power of two not exceeding n. n must be positive. quote_identifier 🔒 Quote an identifier for PostgreSQL. split_power_of_two 🔒 Splits rows into power-of-two-sized chunks no larger than cap, largest first. tcp_keepalive_from_config 🔒 tuples_per_statement 🔒 Number of tuples a single statement may carry, bounded by the parameter limit of the protocol. PgDatum 🔒 PgRow 🔒