Packages

package executors

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. abstract class DepCompilerBaseExecutor[T, StateType] extends StatefulCompilerExecutor

    Base class for the DepCompilers.

    Base class for the DepCompilers.

    T

    the type of the compiler intermediate data

    StateType

    the type of the state value (always associated to a Partition.Key)

  2. class DepCompilerExecutor[T] extends DepCompilerBaseExecutor[T, OutKey] with ContextLogging
  3. class Direct1ToNCompilerExecutor[T] extends NonIncrementalCompilerExecutor with IncrementalCompilerExecutor with ContextLogging

    Implements an incremental compiler for cases where input partitions are mapped to output partitions without overlaps.

    Implements an incremental compiler for cases where input partitions are mapped to output partitions without overlaps. This means that each output partition is the result of the processing of one and only one input partition. One input partition may be mapped to one or multiple output partitions.

    The mapping must be function of the partition keys only, so cannot depend from metadata or data.

  4. class DirectMToNCompilerExecutor[T] extends NonIncrementalCompilerExecutor with IncrementalCompilerExecutor with ContextLogging

    Executor for the com.here.platform.data.processing.compiler.DirectMToNCompiler interface.

  5. class IncrementalDepCompilerExecutor[T, CarryOver] extends DepCompilerExecutor[T] with ContextLogging
  6. class InputCatalogUtils extends AnyRef

    Provides functions required by Executors to query the input catalogs.

    Provides functions required by Executors to query the input catalogs.

    The special com.here.platform.data.processing.driver.Default.OutCatalogId may be accepted by this class if the parameter outCatalogExpected specifies so. However, the output catalog is never queried, but gracefully skipped. If outCatalogExpected is false, an exception is thrown in case com.here.platform.data.processing.driver.Default.OutCatalogId is found in the com.here.platform.data.processing.compiler.InputLayers.

  7. class MapGroupToRefTreeWrapper1To1[T] extends MapGroupToRefTreeWrapperBase[T] with CompileOut1To1Fn[T]
  8. class MapGroupToRefTreeWrapper1ToN[T] extends MapGroupToRefTreeWrapperBase[T] with CompileOut1ToNFn[T]
  9. abstract class MapGroupToRefTreeWrapperBase[T] extends RefTreeCompiler[T] with CompileInFnWithRefs[T]
  10. class NonIncrementalExecutor extends NonIncrementalCompilerExecutor with ContextLogging

    Implements a generic non-incremental compiler.

    Implements a generic non-incremental compiler. Input is passed directly to the main compile function, output is published and committed.

  11. class OutputCatalogUtils extends AnyRef

    Provides functions required by Executors to query the input catalogs.

  12. class RefTreeCompilerExecutor[T] extends StatefulCompilerExecutor with ContextLogging
  13. class StateCatalogUtils extends AnyRef

    State management class that provides utilities related to the compilation status:

    State management class that provides utilities related to the compilation status:

    - querying from a catalog - publishing and retrieving

Value Members

  1. object Direct1ToNCompilerExecutor
  2. object DirectCompileFnUtils
  3. object ExecutorUtils
  4. object MapGroupToRefTreeWrapper
  5. object OutputCatalogUtils
  6. object RefTreeCompilerExecutor
  7. object RefTreeUtils
  8. object StateCatalogUtils

Ungrouped