error when use Broadcast Variables cannot find symbol getRuntimeContext()

Posted by hagersaleh on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/error-when-use-Broadcast-Variables-cannot-find-symbol-getRuntimeContext-tp2010.html

import java.util.Collection;
import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.api.java.DataSet;
import org.apache.flink.api.java.ExecutionEnvironment;


   ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();

    DataSet<Integer> toBroadcast = env.fromElements(1, 2, 3);

   DataSet<String> data = env.fromElements("a", "b");
  data.map(new MapFunction<String, String>() {
    @Override
    public void open(Configuration parameters) throws Exception {
      // 3. Access the broadcasted DataSet as a Collection
      Collection<Integer> broadcastSet = getRuntimeContext().getBroadcastVariable("broadcastSetName");
    }


    @Override
    public String map(String value) throws Exception {
        return "hager";
}
 
}).withBroadcastSet(toBroadcast, "broadcastSetName");
   

display error
cannot find symbol
Collection<Integer> broadcastSet = getRuntimeContext().getBroadcastVariable("broadcastSetName");
  symbol: method getRuntimeContext()

method does not override or implement a method from a supertype
    @Override