public OutputSchemaGenerator getOuputSchemaGenerator()

in streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/output/OutputSchemaFactory.java [42:62]

• 21 lines of code
• 9 McCabe index (conditional complexity)

  public OutputSchemaGenerator<?> getOuputSchemaGenerator() {
    if (outputStrategy instanceof AppendOutputStrategy) {
      return AppendOutputSchemaGenerator.from(outputStrategy);
    } else if (outputStrategy instanceof KeepOutputStrategy) {
      return RenameOutputSchemaGenerator.from(outputStrategy);
    } else if (outputStrategy instanceof FixedOutputStrategy) {
      return FixedOutputSchemaGenerator.from(outputStrategy);
    } else if (outputStrategy instanceof CustomOutputStrategy) {
      return CustomOutputSchemaGenerator.from(outputStrategy);
    } else if (outputStrategy instanceof ListOutputStrategy) {
      return ListOutputSchemaGenerator.from(outputStrategy);
    } else if (outputStrategy instanceof TransformOutputStrategy) {
      return TransformOutputSchemaGenerator.from(outputStrategy, dataProcessorInvocation);
    } else if (outputStrategy instanceof CustomTransformOutputStrategy) {
      return CustomTransformOutputSchemaGenerator.from(outputStrategy, dataProcessorInvocation);
    } else if (outputStrategy instanceof UserDefinedOutputStrategy) {
      return UserDefinedOutputSchemaGenerator.from(outputStrategy);
    } else {
      throw new IllegalArgumentException();
    }
  }