Migration From 1.9.x to 2.1.0

[Arunkumar Santhanagopalan]

Hi,

We are trying to migrate from Dataflow 1.9.x to Dataflow 2.1.0

I need help with the following changes


1.
class Join extends DoFn<String, String> {
@Override
public void startBundle(Context c) throws Exception {
    super.startBundle(c);
    createParser();
}

Method "startBundle" does not override method startBundle from its
superclass


2.
class Join extends DoFn<String, String>{
  private final Aggregator<Long, Long> duplicatesCount =
createAggregator(DUPLICATES_COUNTER, new Sum.SumLongFn());

cannot resolve method 'createAggregator, Sum.SumLongFn has a private access

3.
class Join extends DoFn<String, String>{
  public void processElement(ProcessContext c) {
         c.sideOutput(duplicatesTag, s)
  }
cannot resolve method sideOutput(org.apache.beam.sdk.values.TupleTag)


4.
public abstract class ReadCsv<T> extends DoFn<String, T> {

@Override
public final void processElement(ProcessContext c) throws Exception {
    T output = processElement(c.element(), c);
    if (output != null) {
        c.output(output);
    }
}
Method does not override method processElement from its superclass


5.
import org.apache.beam.sdk.io.TextIO;

TextIO.Read.from("gs://spins/data/part-*")
Non-static method "from" cannot be referenced from static context