List of all items

Structs

• channels::operator_io::Input
• channels::operator_io::Output
• coordinator::Coordinator
• coordinator::CoordinatorApi
• operators::NeedsEpochs
• runtime::CommunicationError
• runtime::communication::CommunicationClient
• runtime::threaded::InterThreadCommunication
• runtime::threaded::MultiThreadRuntime
• runtime::threaded::SingleThreadRuntime
• runtime::threaded::SingleThreadRuntimeFlavor
• sinks::StatefulSink
• sinks::StatelessSink
• sinks::StdOutSink
• sinks::VecSink
• snapshot::Barrier
• snapshot::NoPersistence
• sources::SingleIteratorSource
• sources::StatefulSource
• sources::StatelessSource
• stream::BuildContext
• stream::OperatorBuilder
• stream::OperatorContext
• stream::StreamBuilder
• types::DataMessage
• types::NoData
• types::NoKey
• types::NoTime
• types::RescaleMessage
• types::SuspendMarker
• worker::WorkerBuilder

Enums

• coordinator::CoordinatorExecutionError
• coordinator::CoordinatorRequestError
• coordinator::CoordinatorStatus
• runtime::communication::CommunicationBackendError
• runtime::communication::TransportError
• types::Message
• worker::WorkerExecutionError

Traits

• errorhandling::MalstromFatal
• keyed::KeyDistribute
• keyed::KeyLocal
• operators::AssignTimestamps
• operators::Cloned
• operators::Filter
• operators::FilterMap
• operators::Flatten
• operators::GenerateEpochs
• operators::Inspect
• operators::InspectFrontier
• operators::Map
• operators::Sink
• operators::Source
• operators::Split
• operators::StatefulLogic
• operators::StatefulMap
• operators::StatefulOp
• operators::StatelessLogic
• operators::StatelessOp
• operators::StreamSink
• operators::StreamSource
• operators::TtlMap
• runtime::RuntimeFlavor
• runtime::communication::BiStreamTransport
• runtime::communication::CoordinatorWorkerComm
• runtime::communication::Distributable
• runtime::communication::OperatorOperatorComm
• runtime::communication::WorkerCoordinatorComm
• sinks::StatefulSinkImpl
• sinks::StatefulSinkPartition
• sinks::StatelessSinkImpl
• snapshot::PersistenceBackend
• snapshot::PersistenceClient
• sources::StatefulSourceImpl
• sources::StatefulSourcePartition
• sources::StatelessSourceImpl
• sources::StatelessSourcePartition
• stream::Logic
• stream::LogicWrapper
• types::Data
• types::Key
• types::MaybeData
• types::MaybeKey
• types::MaybeTime
• types::OperatorPartitioner
• types::Timestamp
• worker::StreamProvider

Functions

• keyed::partitioners::index_select
• keyed::partitioners::rendezvous_select
• operators::limit_out_of_orderness
• runtime::communication::broadcast

Type Aliases

• runtime::communication::BiCommunicationClient
• snapshot::SnapshotVersion
• types::OperatorId
• types::WorkerId