format manually

Signed-off-by: tabVersion <[email protected]>
risingwavelabs · May 8, 2024 · fed0cc2 · fed0cc2
1 parent 07c7587
commit fed0cc2
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 35 deletions.
diff --git a/src/connector/src/sink/formatter/mod.rs b/src/connector/src/sink/formatter/mod.rs
@@ -51,7 +51,7 @@ pub trait SinkFormatter {
     fn format_chunk(
         &self,
         chunk: &StreamChunk,
-    ) -> impl Iterator<Item=Result<(Option<Self::K>, Option<Self::V>)>>;
+    ) -> impl Iterator<Item = Result<(Option<Self::K>, Option<Self::V>)>>;
 }
 
 /// `tri!` in generators yield `Err` and return `()`

diff --git a/src/sqlparser/src/ast/legacy_source.rs b/src/sqlparser/src/ast/legacy_source.rs
@@ -125,28 +125,18 @@ pub fn parse_source_schema(p: &mut Parser) -> Result<CompatibleSourceSchema, Par
 #[derive(Debug, Clone, PartialEq, Eq, Hash)]
 #[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
 pub enum SourceSchema {
-    // Keyword::PROTOBUF ProtobufSchema
-    Protobuf(ProtobufSchema),
-    // Keyword::JSON
-    Json,
-    // Keyword::DEBEZIUM_JSON
-    DebeziumJson,
+    Protobuf(ProtobufSchema), // Keyword::PROTOBUF ProtobufSchema
+    Json,                     // Keyword::JSON
+    DebeziumJson,             // Keyword::DEBEZIUM_JSON
     DebeziumMongoJson,
-    // Keyword::UPSERT_JSON
-    UpsertJson,
-    // Keyword::AVRO
-    Avro(AvroSchema),
-    // Keyword::UpsertAVRO
-    UpsertAvro(AvroSchema),
-    // Keyword::MAXWELL
-    Maxwell,
-    // Keyword::CANAL_JSON
-    CanalJson,
-    // Keyword::CSV
-    Csv(CsvInfo),
+    UpsertJson,             // Keyword::UPSERT_JSON
+    Avro(AvroSchema),       // Keyword::AVRO
+    UpsertAvro(AvroSchema), // Keyword::UpsertAVRO
+    Maxwell,                // Keyword::MAXWELL
+    CanalJson,              // Keyword::CANAL_JSON
+    Csv(CsvInfo),           // Keyword::CSV
     Native,
-    // Keyword::DEBEZIUM_AVRO
-    DebeziumAvro(DebeziumAvroSchema),
+    DebeziumAvro(DebeziumAvroSchema), // Keyword::DEBEZIUM_AVRO
     Bytes,
 }
 

diff --git a/src/sqlparser/src/ast/statement.rs b/src/sqlparser/src/ast/statement.rs
@@ -154,20 +154,13 @@ impl Format {
 #[derive(Debug, Clone, PartialEq, Eq, Hash)]
 #[cfg_attr(feature = "serde", derive(Serialize, Deserialize))]
 pub enum Encode {
-    // Keyword::Avro
-    Avro,
-    // Keyword::CSV
-    Csv,
-    // Keyword::PROTOBUF
-    Protobuf,
-    // Keyword::JSON
-    Json,
-    // Keyword::BYTES
-    Bytes,
-    // Keyword::None
-    None,
-    // Keyword::TEXT
-    Text,
+    Avro,     // Keyword::Avro
+    Csv,      // Keyword::CSV
+    Protobuf, // Keyword::PROTOBUF
+    Json,     // Keyword::JSON
+    Bytes,    // Keyword::BYTES
+    None,     // Keyword::None
+    Text,     // Keyword::TEXT
     Native,
     Template,
 }