CuriousVini

Pattern p = Pattern.compile("[a-z0–9._-]+");
if (!p.matcher(bucket).matches()) {
 collector.addFailure("Allowed characters are lowercase characters, numbers,'.', '_', and '-'", "Bucket name should only contain allowed characters.'").withConfigProperty("bucket");
}

CuriousVini

@Override
public void configurePipeline(PipelineConfigurer configurer) {
 StageConfigurer stageConfigurer = configurer.getStageConfigurer();
 // get failure collector from stage configurer
 FailureCollector collector = stageConfigurer.getFailureCollector();
 // use failure collector to collect multiple validation failures
 config.validate(collector);
 validatePartitionProperties(collector);
 validateConfiguredSchema(configuredSchema, collector);
 stageConfigurer.setOutputSchema(configuredSchema);

CuriousVini

public interface FailureCollector {

  /**
   * Add a validation failure to this failure collector. The method returns the validation failure that was added to
   * the failure collector. This failure can be used to add additional {@link ValidationFailure.Cause}s.
   * For example,
   * <code>failureCollector.addFailure("message", "action").withConfigProperty("configProperty");</code>
   *
   * @param message failure message
   * @param correctiveAction corrective action

CuriousVini

public class IncrementTest extends LongRunningTestBase<IncrementTestState> {
  private static final int BATCH_SIZE = 100;
  public static final int SUM_BATCH = (BATCH_SIZE * (BATCH_SIZE - 1)) / 2;

  @Override
  public void deploy() throws Exception {
    deployApplication(getLongRunningNamespace(), IncrementApp.class);
  }

  @Override

CuriousVini

public class IncrementTest extends LongRunningTestBase<IncrementTestState> {
  private static final int BATCH_SIZE = 100;
  public static final int SUM_BATCH = (BATCH_SIZE * (BATCH_SIZE - 1)) / 2;

  @Override
  public void deploy() throws Exception {
    deployApplication(getLongRunningNamespace(), IncrementApp.class);
  }

  @Override