The pipeline executor that support caching intermediate dataset.
A client that is scoped to a specific job.
A listener that is notified on specific job status changed, which should be firstly registered by
The entity responsible for executing a
A factory for selecting and instantiating the adequate
An interface to be implemented by the entity responsible for finding the correct
The default implementation of the
Describes the binary format in which a savepoint should be taken.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.