#[allow(unused_imports)]
use super::*;
impl std::fmt::Debug for super::ArrowSchema {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ArrowSchema");
debug_struct.field("serialized_schema", &self.serialized_schema);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ArrowRecordBatch {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ArrowRecordBatch");
debug_struct.field("serialized_record_batch", &self.serialized_record_batch);
debug_struct.field("row_count", &self.row_count);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ArrowSerializationOptions {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ArrowSerializationOptions");
debug_struct.field("buffer_compression", &self.buffer_compression);
debug_struct.field("picos_timestamp_precision", &self.picos_timestamp_precision);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::AvroSchema {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("AvroSchema");
debug_struct.field("schema", &self.schema);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::AvroRows {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("AvroRows");
debug_struct.field("serialized_binary_rows", &self.serialized_binary_rows);
debug_struct.field("row_count", &self.row_count);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::AvroSerializationOptions {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("AvroSerializationOptions");
debug_struct.field(
"enable_display_name_attribute",
&self.enable_display_name_attribute,
);
debug_struct.field("picos_timestamp_precision", &self.picos_timestamp_precision);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ProtoSchema {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ProtoSchema");
debug_struct.field("proto_descriptor", &self.proto_descriptor);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ProtoRows {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ProtoRows");
debug_struct.field("serialized_rows", &self.serialized_rows);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::CreateReadSessionRequest {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("CreateReadSessionRequest");
debug_struct.field("parent", &self.parent);
debug_struct.field("read_session", &self.read_session);
debug_struct.field("max_stream_count", &self.max_stream_count);
debug_struct.field(
"preferred_min_stream_count",
&self.preferred_min_stream_count,
);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ReadRowsRequest {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ReadRowsRequest");
debug_struct.field("read_stream", &self.read_stream);
debug_struct.field("offset", &self.offset);
debug_struct.field(
"output_format_serialization_options",
&self.output_format_serialization_options,
);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ThrottleState {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ThrottleState");
debug_struct.field("throttle_percent", &self.throttle_percent);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::StreamStats {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("StreamStats");
debug_struct.field("progress", &self.progress);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::stream_stats::Progress {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("Progress");
debug_struct.field("at_response_start", &self.at_response_start);
debug_struct.field("at_response_end", &self.at_response_end);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ReadRowsResponse {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ReadRowsResponse");
debug_struct.field("row_count", &self.row_count);
debug_struct.field("stats", &self.stats);
debug_struct.field("throttle_state", &self.throttle_state);
debug_struct.field("uncompressed_byte_size", &self.uncompressed_byte_size);
debug_struct.field("total_estimated_row_count", &self.total_estimated_row_count);
debug_struct.field("rows", &self.rows);
debug_struct.field("schema", &self.schema);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::SplitReadStreamRequest {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("SplitReadStreamRequest");
debug_struct.field("name", &self.name);
debug_struct.field("fraction", &self.fraction);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::SplitReadStreamResponse {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("SplitReadStreamResponse");
debug_struct.field("primary_stream", &self.primary_stream);
debug_struct.field("remainder_stream", &self.remainder_stream);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::CreateWriteStreamRequest {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("CreateWriteStreamRequest");
debug_struct.field("parent", &self.parent);
debug_struct.field("write_stream", &self.write_stream);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::AppendRowsRequest {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("AppendRowsRequest");
debug_struct.field("write_stream", &self.write_stream);
debug_struct.field("offset", &self.offset);
debug_struct.field("trace_id", &self.trace_id);
debug_struct.field(
"missing_value_interpretations",
&self.missing_value_interpretations,
);
debug_struct.field(
"default_missing_value_interpretation",
&self.default_missing_value_interpretation,
);
debug_struct.field("client_stats", &self.client_stats);
debug_struct.field("rows", &self.rows);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::append_rows_request::ArrowData {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ArrowData");
debug_struct.field("writer_schema", &self.writer_schema);
debug_struct.field("rows", &self.rows);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::append_rows_request::ProtoData {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ProtoData");
debug_struct.field("writer_schema", &self.writer_schema);
debug_struct.field("rows", &self.rows);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::AppendRowsResponse {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("AppendRowsResponse");
debug_struct.field("updated_schema", &self.updated_schema);
debug_struct.field("row_errors", &self.row_errors);
debug_struct.field("write_stream", &self.write_stream);
debug_struct.field("response", &self.response);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::append_rows_response::AppendResult {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("AppendResult");
debug_struct.field("offset", &self.offset);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::GetWriteStreamRequest {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("GetWriteStreamRequest");
debug_struct.field("name", &self.name);
debug_struct.field("view", &self.view);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::BatchCommitWriteStreamsRequest {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("BatchCommitWriteStreamsRequest");
debug_struct.field("parent", &self.parent);
debug_struct.field("write_streams", &self.write_streams);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::BatchCommitWriteStreamsResponse {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("BatchCommitWriteStreamsResponse");
debug_struct.field("commit_time", &self.commit_time);
debug_struct.field("stream_errors", &self.stream_errors);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::FinalizeWriteStreamRequest {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("FinalizeWriteStreamRequest");
debug_struct.field("name", &self.name);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::FinalizeWriteStreamResponse {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("FinalizeWriteStreamResponse");
debug_struct.field("row_count", &self.row_count);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::FlushRowsRequest {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("FlushRowsRequest");
debug_struct.field("write_stream", &self.write_stream);
debug_struct.field("offset", &self.offset);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::FlushRowsResponse {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("FlushRowsResponse");
debug_struct.field("offset", &self.offset);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::StorageError {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("StorageError");
debug_struct.field("code", &self.code);
debug_struct.field("entity", &self.entity);
debug_struct.field("error_message", &self.error_message);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::RowError {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("RowError");
debug_struct.field("index", &self.index);
debug_struct.field("code", &self.code);
debug_struct.field("message", &self.message);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ClientStats {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ClientStats");
debug_struct.field("request_stats", &self.request_stats);
debug_struct.field("window_stats", &self.window_stats);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::client_stats::RequestStats {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("RequestStats");
debug_struct.field("send_time_millis", &self.send_time_millis);
debug_struct.field("queued_requests_count", &self.queued_requests_count);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::client_stats::WindowStats {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("WindowStats");
debug_struct.field(
"max_response_latency_millis",
&self.max_response_latency_millis,
);
debug_struct.field(
"avg_response_latency_millis",
&self.avg_response_latency_millis,
);
debug_struct.field(
"longest_wait_no_response_millis",
&self.longest_wait_no_response_millis,
);
debug_struct.field("requests_sent_count", &self.requests_sent_count);
debug_struct.field("responses_received_count", &self.responses_received_count);
debug_struct.field("bytes_sent_count", &self.bytes_sent_count);
debug_struct.field(
"window_start_time_epoch_millis",
&self.window_start_time_epoch_millis,
);
debug_struct.field("window_millis", &self.window_millis);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ReadSession {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ReadSession");
debug_struct.field("name", &self.name);
debug_struct.field("expire_time", &self.expire_time);
debug_struct.field("data_format", &self.data_format);
debug_struct.field("table", &self.table);
debug_struct.field("table_modifiers", &self.table_modifiers);
debug_struct.field("read_options", &self.read_options);
debug_struct.field("streams", &self.streams);
debug_struct.field(
"estimated_total_bytes_scanned",
&self.estimated_total_bytes_scanned,
);
debug_struct.field(
"estimated_total_physical_file_size",
&self.estimated_total_physical_file_size,
);
debug_struct.field("estimated_row_count", &self.estimated_row_count);
debug_struct.field("trace_id", &self.trace_id);
debug_struct.field("schema", &self.schema);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::read_session::TableModifiers {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("TableModifiers");
debug_struct.field("snapshot_time", &self.snapshot_time);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::read_session::TableReadOptions {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("TableReadOptions");
debug_struct.field("selected_fields", &self.selected_fields);
debug_struct.field("row_restriction", &self.row_restriction);
debug_struct.field("sample_percentage", &self.sample_percentage);
debug_struct.field(
"response_compression_codec",
&self.response_compression_codec,
);
debug_struct.field(
"output_format_serialization_options",
&self.output_format_serialization_options,
);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::ReadStream {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("ReadStream");
debug_struct.field("name", &self.name);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::WriteStream {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("WriteStream");
debug_struct.field("name", &self.name);
debug_struct.field("r#type", &self.r#type);
debug_struct.field("create_time", &self.create_time);
debug_struct.field("commit_time", &self.commit_time);
debug_struct.field("table_schema", &self.table_schema);
debug_struct.field("write_mode", &self.write_mode);
debug_struct.field("location", &self.location);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::TableSchema {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("TableSchema");
debug_struct.field("fields", &self.fields);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::TableFieldSchema {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("TableFieldSchema");
debug_struct.field("name", &self.name);
debug_struct.field("r#type", &self.r#type);
debug_struct.field("mode", &self.mode);
debug_struct.field("fields", &self.fields);
debug_struct.field("description", &self.description);
debug_struct.field("max_length", &self.max_length);
debug_struct.field("precision", &self.precision);
debug_struct.field("scale", &self.scale);
debug_struct.field("default_value_expression", &self.default_value_expression);
debug_struct.field("timestamp_precision", &self.timestamp_precision);
debug_struct.field("range_element_type", &self.range_element_type);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}
impl std::fmt::Debug for super::table_field_schema::FieldElementType {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
let mut debug_struct = f.debug_struct("FieldElementType");
debug_struct.field("r#type", &self.r#type);
if !self._unknown_fields.is_empty() {
debug_struct.field("_unknown_fields", &self._unknown_fields);
}
debug_struct.finish()
}
}