Interface ProcessorSupplier.Context

All Superinterfaces:
ProcessorMetaSupplier.Context
All Known Subinterfaces:
Processor.Context
All Known Implementing Classes:
TestProcessorContext, TestProcessorSupplierContext
Enclosing interface:
ProcessorSupplier

public static interface ProcessorSupplier.Context
extends ProcessorMetaSupplier.Context
Context passed to the supplier in the init() call.
Since:
3.0
  • Method Details

    • logger

      @Nonnull ILogger logger()
      Returns a logger for the associated ProcessorSupplier.
      Specified by:
      logger in interface ProcessorMetaSupplier.Context
    • memberIndex

      int memberIndex()
      Returns the index of the member among all the members that run this job: it's a unique cluster-wide index.

      The value is in the range [0...memberCount-1].

    • attachedDirectory

      @Nonnull File attachedDirectory​(@Nonnull String id)
      Uses the supplied ID to look up a directory you attached to the current Jet job. Creates a temporary directory with the same contents on the local cluster member and returns the location of the created directory. If the directory was already created, just returns its location.
      Parameters:
      id - the ID you used in a previous JobConfig.attachDirectory(java.net.URL) call
      Since:
      4.0
    • attachedFile

      @Nonnull File attachedFile​(@Nonnull String id)
      Uses the supplied ID to look up a file you attached to the current Jet job. Creates a temporary file with the same contents on the local cluster member and returns the location of the created file. If the file was already created, just returns its location.
      Parameters:
      id - the ID you used in a previous JobConfig.attachFile(java.net.URL) call
      Since:
      4.0
    • managedContext

      @Nonnull ManagedContext managedContext()
      Returns ManagedContext associated with this job.