package com.fivetran.query_cache

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc RegisterSessionStart (SessionStartRequest, SessionStartResponse)

  client_telemetry_service.proto:9

  message SessionStartResponse

  client_telemetry_service.proto:22

  • bool success = 1

  • string session_id = 2

• rpc SubmitTelemetryBatch (SubmitTelemetryBatchRequest, SubmitTelemetryBatchResponse)

  client_telemetry_service.proto:10

  message SubmitTelemetryBatchRequest

  client_telemetry_service.proto:74

  • repeated ClientTelemetryEvent events = 1

  message SubmitTelemetryBatchResponse

  client_telemetry_service.proto:78

  • bool success = 1

• rpc ValidateClientVersion (ValidateClientVersionRequest, ValidateClientVersionResponse)

  client_validation_service.proto:6

  message ValidateClientVersionRequest

  client_validation_service.proto:9

  • string dbt_run_cache_version = 1

  message ValidateClientVersionResponse

  client_validation_service.proto:13

  • bool is_supported = 1

• rpc RegisterClone (CloneRequest, CloneResponse)

  clone_service.proto:9

  message CloneRequest

  clone_service.proto:17

  • string target_table = 1

  • string dialect = 2

  • string default_catalog = 3

  • ModelExecutionType execution_type = 4

  • string clone_source_table = 5

  • optional int64 clone_source_last_modified_epoch = 6

  • map<string, string> labels = 7

  • optional string clone_source_table_type = 8

  • optional TableProperties table_properties = 9

  message CloneResponse

  clone_service.proto:29

  • optional ReadyToCloneResponse ready_to_clone = 3

  • oneof response

    • ReadyToCloneResponse ready_to_clone_v1 = 1

    • UntrackableCloneResponse untrackable_clone = 2

• rpc ConfirmExecution (ConfirmExecutionRequest, ConfirmExecutionResponse)

  execution_service.proto:9

  message ConfirmExecutionRequest

  execution_service.proto:13

  • string request_id = 1

  • optional int64 last_modified_epoch = 2

  • bool failed_to_clone = 3

  • optional string table_type = 4

    database-specific type of what just got created

  • optional Struct execution_results = 6

  • optional int64 execution_runtime_ms = 7

  • map<string, string> labels = 8

  message ConfirmExecutionResponse

  execution_service.proto:28

  • bool success = 1

  • string request_id = 2

• rpc RecordExecutions (RecordExecutionsRequest, RecordExecutionsResponse)

  execution_service.proto:10

  message RecordExecutionsRequest

  execution_service.proto:37

  Records the outcome of one or more already-executed queries directly into the cache state, bypassing cache-candidate lookup and the Submit/Confirm round-trip. Used to hydrate state with historical execution data. The whole batch is processed atomically -- any failure rolls back all records.

  • repeated ExecutionRecord records = 1

  message RecordExecutionsResponse

  execution_service.proto:81

  • uint32 records_stored = 1

• rpc GetExplainMessages (GetExplainMessagesRequest, GetExplainMessagesResponse)

  explain_service.proto:8

  message GetExplainMessagesRequest

  explain_service.proto:44

  • repeated string execution_decision_ids = 1

  message GetExplainMessagesResponse

  explain_service.proto:48

  • repeated ExplainMessageEntry messages = 1

• rpc SubmitEnrichedSQL (SubmitEnrichedSQLRequest, SubmitSQLResponse)

  sql_service.proto:10

  message SubmitEnrichedSQLRequest

  sql_service.proto:14

  • optional string target_table = 1

  • string dialect = 2

  • string default_catalog = 3

  • ModelExecutionType execution_type = 4

  • string sql = 5

  • repeated TableModifiedInfo tables = 6

  • repeated QueryDependency query_dependencies = 7

  • map<string, string> semantic_extras = 8

  • int64 freshness_tolerance_seconds = 11

  • repeated string lenient_dependencies = 12

  • bool tolerate_nondeterminism = 13

  • map<string, string> labels = 14

  • optional int64 clone_time_travel_limit = 15

  • optional TableProperties clone_table_properties = 16

  • StaleUpstreamPolicy stale_upstream_policy = 17

    Selects how the service should aggregate per-dependency freshness checks. ANY (default): every upstream must be within tolerance for a candidate to be admitted (matches dbt's `updates_on=any`). ALL: at least one upstream must be within tolerance — i.e. skip while at least one upstream hasn't drifted yet (matches dbt's `freshness.build_after.updates_on=all`). Service-side wire field already exists; this entry restores Fusion's ability to set it.

• rpc SubmitValues (SubmitValuesRequest, SubmitSQLResponse)

  sql_service.proto:11

  message SubmitValuesRequest

  sql_service.proto:41

  • string target_table = 1

  • string dialect = 2

  • string default_catalog = 3

  • string values_hash = 4

  • map<string, string> semantic_extras = 5

  • optional int64 last_modified_epoch = 6

  • map<string, string> labels = 7

  • optional int64 clone_time_travel_limit = 8

  • optional TableProperties clone_table_properties = 9

Used in: ClientTelemetryEvent

• string request_id = 1

• double duration = 2

• optional string target_table_fqn = 3

• optional int64 num_dependencies = 4

• optional int64 num_view_dependencies = 5

• optional string error_type = 6

• optional int64 view_traversal_duration_ms = 7

• optional int64 last_modified_duration_ms = 8

• map<string, string> labels = 9

Used in: SubmitTelemetryBatchRequest

• oneof request

  • ClientPrepareEnrichedSQLRequest enriched_sql_prepared = 1

  • SessionStartRequest session_start = 2

  • SessionEndRequest session_end = 4

    note: this is only called SessionEndRequest to match SessionStartRequest future event payloads should be called FooEvent, not FooRequest

• optional int64 event_order = 3

Used in: ExecutionRecord

• optional int64 last_modified_epoch = 1

• optional string table_type = 2

• optional Struct execution_results = 3

• optional int64 execution_runtime_ms = 4

Used in: RecordExecutionsRequest

• optional ExecutionOutcome outcome = 1

• oneof input

  • SQLExecution enriched_sql = 2

  • ValuesExecution values = 3

Used in: ExplainLine

• EB_UNSPECIFIED = 0

• FRESH = 1

• WITHIN_TOLERANCE = 2

• OUTDATED = 3

• NODE_QUERY_CHANGED = 4

• NODE_QUERY_UNCHANGED = 5

• UPSTREAM_QUERY_CHANGED = 6

• UPSTREAM_QUERY_UNCHANGED = 7

• TARGET_TABLE_EXISTS = 8

Used in: ExplainMessageEntry

• string text = 1

• optional ExplainMarker marker = 2

• optional ExplainBadge badge = 3

• repeated ExplainLine children = 4

Used in: ExplainLine

• EM_UNSPECIFIED = 0

• SUCCESS = 1

• FAIL = 2

• INFO = 3

Used in: GetExplainMessagesResponse

• string execution_decision_id = 1

• SubmitSQLResultType decision = 2

• string decision_description = 3

• repeated ExplainLine explain_lines = 4

Used in: ReadyToCloneResponse, ReadyToExecuteResponse, SkipExecutionResponse, UntrackableCloneResponse

• SubmitSQLResultType decision = 1

• optional RejectionReason skip_rejection_reason = 2

• optional RejectionReason clone_rejection_reason = 3

• bool is_stale = 4

Used in: Value

• repeated Value values = 1

Used in: CloneRequest, SQLExecution, SubmitEnrichedSQLRequest

• UNSPECIFIED = 0

• FULL = 1

• APPEND = 2

• MERGE = 3

• INSERT_OVERWRITE = 4

• DELETE_INSERT = 5

• MICROBATCH = 6

• SNAPSHOT = 7

• DBT_DATA_TEST = 8

• VALUES = 9

• VIEW = 10

• DBT_CUSTOM = 11

Used in: ReadyToCloneResponse, ReadyToExecuteResponse, SkipExecutionResponse, UntrackableCloneResponse

• map<string, string> node_to_func = 1

Used in: Value

• NULL_VALUE = 0

Used in: SQLExecution, SubmitEnrichedSQLRequest

• string name = 1

• string query = 2

• string default_catalog = 3

  these are used to qualify any unqualified object references within the query

• string default_schema = 4

Used in: ReadyToExecuteResponse

• bool semantic_hash_match = 1

• bool data_hash_match = 2

Used in: CloneResponse, SubmitSQLResponse

• string request_id = 1

• string last_modified_query = 2

• repeated string clone_sqls = 3

• string clone_source = 4

• string clone_target = 5

• optional ExplainedDecision explained_decision = 6

• map<string, NodeFuncMapping> transformed_nodes_by_query = 7

• optional int64 clone_required_last_modified_epoch = 8

• optional Struct clone_execution_results = 10

• optional int64 execution_runtime_ms = 11

• optional string execution_decision_id = 12

Used in: SubmitSQLResponse

• string request_id = 1

• string last_modified_query = 2

• optional ExplainedDecision explained_decision = 3

• map<string, NodeFuncMapping> transformed_nodes_by_query = 4

• optional QueryHashMatchMetadataInfo query_hash_metadata_info = 5

• optional string execution_decision_id = 6

Used in: ExplainedDecision

• NO_FINGERPRINT_MATCH = 0

• TARGET_TABLE_MISMATCH = 1

• EXECUTION_TYPE_MISMATCH = 2

• EXECUTION_TYPE_NOT_FULL = 3

• TARGET_TABLE_DOES_NOT_EXIST = 4

• FORCED_NOT_ELIGIBLE = 5

• NO_SUITABLE_MATCH_FOUND = 6

• TARGET_TABLE_MATCH = 7

• LATEST_QUERY_HASH_NOT_MATCH = 8

• OUTSIDE_TIME_TRAVEL_WINDOW = 9

Mirrors SubmitEnrichedSQLRequest minus cache-decision-only fields.

Used in: ExecutionRecord

• optional string target_table = 1

• string dialect = 2

• string default_catalog = 3

• ModelExecutionType execution_type = 4

• string sql = 5

• repeated TableModifiedInfo tables = 6

• repeated QueryDependency query_dependencies = 7

• map<string, string> semantic_extras = 8

• map<string, string> labels = 9

Used in: ClientTelemetryEvent

• optional google.protobuf.Duration session_duration = 1

  How long the session lasted, as measured by the client itself

• SessionEndRequest.ClientResult result = 2

  More information about why the session ended

• string result_description = 3

• optional Struct metrics = 4

  Client-specific metrics. The key should be an identifier and the value should be structured data

Used in: SessionEndRequest

• SUCCESS = 0

  Session ended naturally

  Client success - eg models ran without error

• FAILURE = 1

  Client failure - eg database error occurred

• CANCELLED = 2

  Session ended because the client deliberately hit cancel / ctrl+c

Used as request type in: ClientTelemetry.RegisterSessionStart

Used as field type in: ClientTelemetryEvent

• string dbt_run_cache_version = 1

• string dbt_version = 2

• string sqlglot_version = 3

• optional Struct config = 5

Used in: SubmitSQLResponse

• optional ExplainedDecision explained_decision = 1

• map<string, NodeFuncMapping> transformed_nodes_by_query = 2

• optional Struct execution_results = 4

• optional int64 execution_runtime_ms = 5

• optional string execution_decision_id = 6

Used in: SubmitEnrichedSQLRequest

• ANY = 0

• ALL = 1

The copy of google.protobuf.Struct but with support for integer values

Used in: ConfirmExecutionRequest, ExecutionOutcome, ReadyToCloneResponse, SessionEndRequest, SessionStartRequest, SkipExecutionResponse, Value

• map<string, Value> fields = 1

Used as response type in: SQL.SubmitEnrichedSQL, SQL.SubmitValues

• oneof response

  • ReadyToExecuteResponse ready_to_execute = 2

  • SkipExecutionResponse skip_execution = 3

  • ReadyToCloneResponse ready_to_clone = 4

Used in: ExplainMessageEntry, ExplainedDecision

• SKIP_EXECUTION = 0

• READY_TO_EXECUTE = 1

• READY_TO_CLONE = 3

• UNKNOWN = 4

Used in: SQLExecution, SubmitEnrichedSQLRequest

• string name = 1

• int64 last_modified_epoch = 2

Used in: CloneRequest, SubmitEnrichedSQLRequest, SubmitValuesRequest

• optional int32 hours_to_expiration = 1

• optional int32 partition_expiration_days = 2

Used in: CloneResponse

• repeated string clone_sqls = 1

• string clone_source = 2

• string clone_target = 3

• optional ExplainedDecision explained_decision = 4

• map<string, NodeFuncMapping> transformed_nodes_by_query = 5

Used in: ListValue, Struct

• oneof kind

  • NullValue null_value = 1

  • double double_value = 2

  • int64 int_value = 3

  • string string_value = 4

  • bool bool_value = 5

  • Struct struct_value = 6

  • ListValue list_value = 7

Mirrors SubmitValuesRequest minus cache-decision-only fields. Note that last_modified_epoch lives on ExecutionOutcome, not here.

Used in: ExecutionRecord

• string target_table = 1

• string dialect = 2

• string default_catalog = 3

• string values_hash = 4

• map<string, string> semantic_extras = 5

• map<string, string> labels = 6