@Test(expected = IllegalArgumentException.class) public void testInvalidSyntax() throws Exception { ProjectionTransform.ProjectionTransformConfig config = new ProjectionTransform .ProjectionTransformConfig(null, "x,y", null, null); Transform<StructuredRecord, StructuredRecord> transform = new ProjectionTransform(config); TransformContext transformContext = new MockTransformContext(); transform.initialize(transformContext); }
@Override public void initialize(TransformContext context) throws Exception { super.initialize(context); FailureCollector collector = context.getFailureCollector(); init(null, collector); collector.getOrThrowException(); }
ProjectionTransform extends Transform<StructuredRecord, StructuredRecord> { @Override public void initialize(TransformContext context) throws Exception { super.initialize(context); FailureCollector collector = context.getFailureCollector(); init(null, collector); collector.getOrThrowException(); } }
ProjectionTransform extends Transform<StructuredRecord, StructuredRecord> { @Override public void initialize(TransformContext context) throws Exception { super.initialize(context); FailureCollector collector = context.getFailureCollector(); init(null, collector); collector.getOrThrowException(); } ProjectionTransform(ProjectionTransformConfig projectionTransformConfig); }
ProjectionTransform extends Transform<StructuredRecord, StructuredRecord> { @Override public void initialize(TransformContext context) throws Exception { super.initialize(context); FailureCollector collector = context.getFailureCollector(); init(null, collector); collector.getOrThrowException(); } ProjectionTransform(ProjectionTransformConfig projectionTransformConfig); @Override void configurePipeline(PipelineConfigurer pipelineConfigurer); @Override void initialize(TransformContext context); @Override void prepareRun(StageSubmitterContext context); @Override void transform(StructuredRecord valueIn, Emitter<StructuredRecord> emitter); }
ProjectionTransform extends Transform<StructuredRecord, StructuredRecord> { @Override public void initialize(TransformContext context) throws Exception { super.initialize(context); FailureCollector collector = context.getFailureCollector(); init(null, collector); collector.getOrThrowException(); } ProjectionTransform(ProjectionTransformConfig projectionTransformConfig); @Override void configurePipeline(PipelineConfigurer pipelineConfigurer); @Override void initialize(TransformContext context); @Override void prepareRun(StageSubmitterContext context); @Override void transform(StructuredRecord valueIn, Emitter<StructuredRecord> emitter);  }