ray.rllib.offline.mixed_input.MixedInput#
- class ray.rllib.offline.mixed_input.MixedInput(dist: Dict[JsonReader, float], ioctx: IOContext)[source]#
Bases:
InputReader
Mixes input from a number of other input sources.
from ray.rllib.offline.io_context import IOContext from ray.rllib.offline.mixed_input import MixedInput ioctx = IOContext(...) MixedInput({ "sampler": 0.4, "/tmp/experiences/*.json": 0.4, "s3://bucket/expert.json": 0.2, }, ioctx)
Methods
Initialize a MixedInput.
Returns TensorFlow queue ops for reading inputs from this reader.