Samples

Copy bucket

Load external UDF

Use inline UDF

Print S3 bucket

SQL filter

Basic Runtime

ListS3 -> Process -> Print

Partionning produced Data based on a String key (see meta extract partitionBy field)

Write in a s3 bucket

Write in a postgresql store

Write in an opensearch store

Activate the error SideStream

The error SideStream must currently point to a natsjs. The message produced must be then consumed from the topic configured. The error SideStream message structure is normalized and all error can be sent to the same topic.

Store the errors from SideStreams to Elasticsearch

Schedule a batch processing flow analytics with a cron schedule

Copy bucket​

Load external UDF​

Use inline UDF​

Print S3 bucket​

SQL filter​

Basic Runtime​

ListS3 -> Process -> Print​

Partionning produced Data based on a String key (see meta extract partitionBy field)​

Write in a s3 bucket​

Write in a postgresql store​

Write in an opensearch store​

Activate the error SideStream​

Store the errors from SideStreams to Elasticsearch​

Schedule a batch processing flow analytics with a cron schedule​