goldsky-io/streamling

1

streamling-advanced-plugins Use when implementing a streamling preprocessor (rewriting pipeline topology YAML before it parses), a DataFusion sca…

goldsky-io/streamling

1

2

streamling-plugin-basics Use when creating a new streamling plugin crate in Rust (source, sink, transform, preprocessor, UDF, or side output),…

goldsky-io/streamling

1

3

streamling-sink-plugin Use when implementing a streamling SinkPlugin — lazy client initialization in initialize(), the empty-batch guard, co…

goldsky-io/streamling

1

4

streamling-source-plugin Use when implementing a streamling SourcePlugin — defining the output schema and _gs_op column, generate_batch and th…

goldsky-io/streamling

1

5

streamling-transform-plugin Use when implementing a streamling TransformPlugin — process_batch with RecordBatch in and RecordBatch out, declaring…

goldsky-io/streamling

1

6

streamling-udf-plugin Use when implementing a streamling DataFusion scalar UDF — a custom function callable from pipeline SQL (SELECT my_fu…

goldsky-io/streamling

1