Versions Compared

Old Version 21

changes.mady.by.user John Roesler

Saved on

compared with

New Version Current

changes.mady.by.user Matthias J. Sax

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
public interface FixedKeyProcessor<KIn, VIn, VOut> {

    default void init(final FixedKeyProcessorContext<KIn, VOut> context) {}

    void process(FixedKeyRecord<KIn, VIn> record);

    default void close() {}
}

...



ContextualFixedKeyProcessor

Helper, same as ContextualProcessor.

Code Block
public abstract class FixedKeyContextualProcessor<KInContextualFixedKeyProcessor<KIn, VIn, VOut> implements FixedKeyProcessor<KIn, VIn, VOut> {

    private FixedKeyProcessorContext<KIn, VOut> context;

    protected FixedKeyContextualProcessor() {}

    @Override
    public void init(final FixedKeyProcessorContext<KIn, VOut> context) {
        this.context = context;
    }

    protected final FixedKeyProcessorContext<KIn, VOut> context() {
        return context;
    }
}

...