OnRamps for loading data into a distributed event processing/storage platform