Struct TestCaseResult

pub struct TestCaseResult {

    pub input: TestInput,
    pub logical_plan: Option<String>,
    pub optimized_logical_plan_for_batch: Option<String>,
    pub optimized_logical_plan_for_stream: Option<String>,
    pub batch_plan: Option<String>,
    pub batch_plan_proto: Option<String>,
    pub batch_local_plan: Option<String>,
    pub batch_distributed_plan: Option<String>,
    pub sink_plan: Option<String>,
    pub stream_plan: Option<String>,
    pub stream_dist_plan: Option<String>,
    pub eowc_stream_plan: Option<String>,
    pub eowc_stream_dist_plan: Option<String>,
    pub binder_error: Option<String>,
    pub planner_error: Option<String>,
    pub optimizer_error: Option<String>,
    pub batch_error: Option<String>,
    pub batch_local_error: Option<String>,
    pub stream_error: Option<String>,
    pub eowc_stream_error: Option<String>,
    pub sink_error: Option<String>,
    pub explain_output: Option<String>,
    pub create_source: Option<CreateConnector>,
    pub create_table_with_connector: Option<CreateConnector>,
    pub with_config_map: Option<BTreeMap<String, String>>,
}

Fields

input: TestInput

logical_plan: Option<String>

The original logical plan

optimized_logical_plan_for_batch: Option<String>

Logical plan with optimization .gen_optimized_logical_plan_for_batch()

optimized_logical_plan_for_stream: Option<String>

Logical plan with optimization .gen_optimized_logical_plan_for_stream()

batch_plan: Option<String>

Distributed batch plan .gen_batch_query_plan()

batch_plan_proto: Option<String>

Proto JSON of generated batch plan

batch_local_plan: Option<String>

Batch plan for local execution .gen_batch_local_plan()

batch_distributed_plan: Option<String>

Batch plan for distributed execution .gen_batch_distributed_plan()

sink_plan: Option<String>

Generate sink plan

stream_plan: Option<String>

Create MV plan .gen_create_mv_plan()

stream_dist_plan: Option<String>

Create MV fragments plan

eowc_stream_plan: Option<String>

Create MV plan with EOWC semantics .gen_create_mv_plan(.., EmitMode::OnWindowClose)

eowc_stream_dist_plan: Option<String>

Create MV fragments plan with EOWC semantics

binder_error: Option<String>

Error of binder

planner_error: Option<String>

Error of planner

optimizer_error: Option<String>

Error of optimizer

batch_error: Option<String>

Error of .gen_batch_query_plan()

batch_local_error: Option<String>

Error of .gen_batch_local_plan()

stream_error: Option<String>

Error of .gen_stream_plan()

eowc_stream_error: Option<String>

Error of .gen_stream_plan() with emit_on_window_close = true

sink_error: Option<String>

Error of .gen_sink_plan()

explain_output: Option<String>

The result of an EXPLAIN statement.

This field is used when sql is an EXPLAIN statement. In this case, all other fields are invalid.

create_source: Option<CreateConnector>

Support using file content or file location to create source.

create_table_with_connector: Option<CreateConnector>

Support using file content or file location to create table with connector.

with_config_map: Option<BTreeMap<String, String>>

Provide config map to frontend

Trait Implementations

impl Debug for TestCaseResult

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for TestCaseResult

fn default() -> TestCaseResult

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for TestCaseResult

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for TestCaseResult

fn eq(&self, other: &TestCaseResult) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for TestCaseResult

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for TestCaseResult