File tree

• CONTRIBUTING.md
• Cargo.lock
• Cargo.toml
• crates
  • dbsp
    • Cargo.toml
    • src
      • circuit
        • dbsp_handle.rs
      • storage
        • test.rs
  • fda
    • Cargo.toml
    • src
      • main.rs
  • nexmark
    • Cargo.toml
    • benches/nexmark
      • main.rs
    • examples
      • generate.rs
  • pipeline-manager
    • Cargo.toml
    • src
      • api
        • demo.rs
        • endpoints
          • api_key.rs
          • pipeline_interaction.rs
          • pipeline_management.rs
        • main.rs
        • support_data_collector.rs
      • auth.rs
      • bin
        • pipeline-manager.rs
      • cluster_health.rs
      • compiler
        • main.rs
        • rust_compiler.rs
        • sql_compiler.rs
        • util.rs
      • config.rs
      • db
        • listen_table.rs
        • operations
          • pipeline.rs
        • probe.rs
        • storage_postgres.rs
        • test.rs
        • types
          • combined_status.rs
          • program.rs
          • utils.rs
      • lib.rs
      • logging.rs
      • runner
        • interaction.rs
        • local_runner.rs
        • main.rs
        • pipeline_automata.rs
        • pipeline_logs.rs
• demo/packaged/sql
  • 10-spreadsheet.udf.rs
  • 10-spreadsheet.udf.toml