ERDOS
0.2

Overview

  • What is ERDOS?
  • Streams
  • Operators
  • Messages
  • ERDOS Package Reference
ERDOS
  • »
  • Index

Index

_ | A | C | D | E | F | I | L | M | N | O | P | R | S | T | W

_

  • __init__() (erdos.Operator method)

A

  • add_callback() (erdos.ReadStream method)
  • add_watermark_callback() (erdos.ReadStream method)
    • (in module erdos)

C

  • config() (erdos.Operator property)
  • connect() (erdos.Operator static method)
    • (in module erdos)
  • coordinates (erdos.Timestamp attribute)
  • csv_log_file_name() (erdos.OperatorConfig property)

D

  • data (erdos.Message attribute)

E

  • erdos
    • module
  • ExtractStream (class in erdos)

F

  • flow_watermarks() (erdos.OperatorConfig property)

I

  • id() (erdos.Operator property)
  • IngestStream (class in erdos)
  • is_top (erdos.Timestamp attribute)

L

  • log_file_name() (erdos.OperatorConfig property)
  • LoopStream (class in erdos)

M

  • Message (class in erdos)
  • module
    • erdos

N

  • name() (erdos.OperatorConfig property)
  • NodeHandle (class in erdos)

O

  • Operator (class in erdos)
  • OperatorConfig (class in erdos)

P

  • profile_file_name() (erdos.OperatorConfig property)

R

  • read() (erdos.ExtractStream method)
    • (erdos.ReadStream method)
  • ReadStream (class in erdos)
  • reset() (in module erdos)
  • run() (erdos.Operator method)
    • (in module erdos)
  • run_async() (in module erdos)

S

  • send() (erdos.IngestStream method)
    • (erdos.WriteStream method)
  • shutdown() (erdos.NodeHandle method)

T

  • Timestamp (class in erdos)
  • timestamp (erdos.Message attribute)
    • (erdos.Timestamp attribute)
    • (erdos.WatermarkMessage attribute)
  • try_read() (erdos.ExtractStream method)
    • (erdos.ReadStream method)

W

  • WatermarkMessage (class in erdos)
  • WriteStream (class in erdos)

© Copyright 2018, The ERDOS Team

Built with Sphinx using a theme provided by Read the Docs.