Class TransformEffectiveSettings

java.lang.Object
org.elasticsearch.xpack.core.transform.transforms.TransformEffectiveSettings

public final class TransformEffectiveSettings extends Object
  • Method Details

    • writeDatesAsEpochMillis

      public static boolean writeDatesAsEpochMillis(SettingsConfig settings, TransformConfigVersion version)
      Determines if the transform should write dates as epoch millis based on settings and version.
      Parameters:
      settings - transform's settings
      Returns:
      whether or not the transform is unattended
    • isAlignCheckpointsDisabled

      public static boolean isAlignCheckpointsDisabled(SettingsConfig settings)
      Determines if aligning checkpoints is disabled for this transform based on settings.
      Parameters:
      settings - transform's settings
      Returns:
      whether or not aligning checkpoints is disabled for this transform
    • isPitDisabled

      public static boolean isPitDisabled(SettingsConfig settings)
      Determines if pit is disabled for this transform based on settings.
      Parameters:
      settings - transform's settings
      Returns:
      whether or not pit is disabled for this transform
    • isDeduceMappingsDisabled

      public static boolean isDeduceMappingsDisabled(SettingsConfig settings)
      Determines if mappings deduction is disabled for this transform based on settings.
      Parameters:
      settings - transform's settings
      Returns:
      whether or not mappings deduction is disabled for this transform
    • getNumFailureRetries

      public static int getNumFailureRetries(SettingsConfig settings, int defaultNumFailureRetries)
      Determines the appropriate number of retries.

      The number of retries are read from the config or if not read from the context which is based on a cluster wide default. If the transform runs in unattended mode, the number of retries is always indefinite.

      Parameters:
      settings - transform's settings
      Returns:
      the number of retries or -1 if retries are indefinite
    • isUnattended

      public static boolean isUnattended(SettingsConfig settings)
      Determines if the transform is unattended based on settings.
      Parameters:
      settings - transform's settings
      Returns:
      whether or not the transform is unattended