fix: use new APIs in examplenew

Author: laysakura

c_example/doc_app1/doc_app1.c

@@ -91,7 +91,7 @@ int main()
 
     fprintf(stderr, "waiting JSON records in tcp/54300...\n");
 
-    SpringRow *row;
+    SpringSinkRow *row;
     while (1)
     {
         row = spring_pop(pipeline, "q");
@@ -108,7 +108,7 @@ int main()
         assert_ok(ret);
 
         fprintf(stderr, "%s\t%f\n", ts, temperature_fahrenheit);
-        spring_row_close(row);
+        spring_sink_row_close(row);
     }
 
     ret = spring_close(pipeline);

c_example/doc_app2/doc_app2.c

@@ -137,7 +137,7 @@ int main()
 
     fprintf(stderr, "waiting JSON records in tcp/54300...\n");
 
-    SpringRow *row;
+    SpringSinkRow *row;
     bool is_err = false;
     while (1)
     {
@@ -159,7 +159,7 @@ int main()
                 assert_ok(ret);
 
                 fprintf(stderr, "[q_avg_all] %s\t%f\n", ts, avg_amount);
-                spring_row_close(row);
+                spring_sink_row_close(row);
             }
             else
             {
@@ -182,7 +182,7 @@ int main()
             assert_ok(ret);
 
             fprintf(stderr, "[q_avg_by_symbol] %s\t%s\t%f\n", ts, symbol, avg_amount);
-            spring_row_close(row);
+            spring_sink_row_close(row);
         }
         else
         {

c_example/trade_projection/trade_projection.c

@@ -91,7 +91,7 @@ void pop_print(const SpringPipeline *pipeline)
     {
         SpringErrno ret;
 
-        SpringRow *row = spring_pop(pipeline, "q_sink_trade");
+        SpringSinkRow *row = spring_pop(pipeline, "q_sink_trade");
         assert_not_null(row);
 
         int r = spring_column_text(row, 0, (char *)ts, TS_LEN);
@@ -103,7 +103,7 @@ void pop_print(const SpringPipeline *pipeline)
 
         printf("[row#%d] ts=%s amount=%d\n", i, ts, amount);
 
-        spring_row_close(row);
+        spring_sink_row_close(row);
     }
 }