Deprecated API

Contents

• Deprecated Interfaces
• Deprecated Classes
• Deprecated Fields
• Deprecated Methods
• Deprecated Constructors

Deprecated Interfaces

Interface and Description
org.apache.flink.types.Key The Key type is a relict of a deprecated and removed API and will be removed in future versions as well.
org.apache.flink.api.common.state.OperatorState OperatorState has been replaced by ValueState.
org.apache.flink.streaming.api.functions.TimestampExtractor This class has been replaced by AssignerWithPeriodicWatermarks and AssignerWithPunctuatedWatermarks

Deprecated Classes

Class and Description
org.apache.flink.streaming.runtime.operators.ExtractTimestampsOperator Subsumed by TimestampsAndPeriodicWatermarksOperator and TimestampsAndPunctuatedWatermarksOperator.
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer081
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer
org.apache.flink.streaming.api.windowing.assigners.SlidingTimeWindows Please use SlidingEventTimeWindows.
org.apache.flink.streaming.api.windowing.assigners.TumblingTimeWindows Please use TumblingEventTimeWindows.

Deprecated Fields

Field and Description
org.apache.flink.configuration.ConfigConstants.EXECUTION_RETRIES_KEY The configuration value will be replaced by ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_ATTEMPTS and the corresponding FixedDelayRestartStrategy.
org.apache.flink.configuration.ConfigConstants.EXECUTION_RETRY_DELAY_KEY The configuration value will be replaced by ConfigConstants.RESTART_STRATEGY_FIXED_DELAY_DELAY and the corresponding FixedDelayRestartStrategy.

Deprecated Methods

Method and Description
org.apache.flink.api.common.operators.DualInputOperator.addFirstInput(Operator<IN1>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addFirstInputs(List<Operator<IN1>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(List<Operator<IN>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.addInput(Operator<IN>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInput(Operator<IN>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.addInputs(List<? extends Operator<IN>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addSecondInput(Operator<IN2>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.DualInputOperator.addSecondInputs(List<Operator<IN2>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.streaming.api.datastream.DataStream.assignTimestamps(TimestampExtractor<T>) Please use DataStream.assignTimestampsAndWatermarks(AssignerWithPeriodicWatermarks) of DataStream.assignTimestampsAndWatermarks(AssignerWithPunctuatedWatermarks) instread.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.enableCheckpointing() Use StreamExecutionEnvironment.enableCheckpointing(long) instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode, boolean)
org.apache.flink.api.java.io.CsvReader.fieldDelimiter(char)
org.apache.flink.api.common.functions.RuntimeContext.getAllAccumulators() Use getAccumulator(..) to obtain the value of an accumulator.
org.apache.flink.streaming.api.scala.DataStream.getExecutionConfig() Use executionConfig instead.
org.apache.flink.streaming.api.scala.DataStream.getExecutionEnvironment() Use executionEnvironment instead
org.apache.flink.api.common.ExecutionConfig.getExecutionRetryDelay() Should no longer be used because it is subsumed by RestartStrategyConfiguration
org.apache.flink.api.common.JobExecutionResult.getIntCounterResult(String)
org.apache.flink.api.common.functions.RuntimeContext.getKeyValueState(String, Class<S>, S) Use the more expressive RuntimeContext.getState(ValueStateDescriptor) instead.
org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext.getKeyValueState(String, Class<S>, S)
org.apache.flink.streaming.api.operators.StreamingRuntimeContext.getKeyValueState(String, Class<S>, S)
org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext.getKeyValueState(String, Class<S>, S)
org.apache.flink.api.common.functions.RuntimeContext.getKeyValueState(String, TypeInformation<S>, S) Use the more expressive RuntimeContext.getState(ValueStateDescriptor) instead.
org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext.getKeyValueState(String, TypeInformation<S>, S)
org.apache.flink.streaming.api.operators.StreamingRuntimeContext.getKeyValueState(String, TypeInformation<S>, S)
org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext.getKeyValueState(String, TypeInformation<S>, S)
org.apache.flink.streaming.api.scala.DataStream.getName() Use name instead
org.apache.flink.api.common.ExecutionConfig.getNumberOfExecutionRetries() Should no longer be used because it is subsumed by RestartStrategyConfiguration
org.apache.flink.api.java.ExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced by ExecutionEnvironment.getRestartStrategy(). The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the number of execution retries.
org.apache.flink.api.scala.ExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced by getRestartStrategy. The FixedDelayRestartStrategyConfiguration contains the number of execution retries.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced by StreamExecutionEnvironment.getRestartStrategy(). The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the number of execution retries.
org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.getNumberOfExecutionRetries() This method will be replaced by getRestartStrategy. The FixedDelayRestartStrategyConfiguration contains the number of execution retries.
org.apache.flink.streaming.api.scala.DataStream.getParallelism() Use parallelism instead.
org.apache.flink.streaming.api.scala.DataStream.getType() Use dataType instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.isForceCheckpointing()
org.apache.flink.streaming.api.environment.CheckpointConfig.isForceCheckpointing() This will be removed once iterations properly participate in checkpointing.
org.apache.flink.streaming.api.windowing.assigners.TumblingTimeWindows.of(Time) Please use TumblingEventTimeWindows.of(Time).
org.apache.flink.streaming.api.windowing.assigners.SlidingTimeWindows.of(Time, Time) Please use SlidingEventTimeWindows.of(Time, Time).
org.apache.flink.runtime.operators.hash.InMemoryPartition.overwriteRecordAt(long, T)
org.apache.flink.api.java.DataSet.print(String) Use DataSet.printOnTaskManager(String) instead.
org.apache.flink.api.scala.DataSet.print(String) Use DataSet.printOnTaskManager(String) instead.
org.apache.flink.api.java.DataSet.printToErr(String) Use DataSet.printOnTaskManager(String) instead, othe PrintingOutputFormat instead.
org.apache.flink.api.scala.DataSet.printToErr(String) Use DataSet.printOnTaskManager(String) instead.
org.apache.flink.api.java.operators.TwoInputUdfOperator.returns(String) Please use TwoInputUdfOperator.returns(Class) or TwoInputUdfOperator.returns(TypeHint) instead.
org.apache.flink.api.java.operators.SingleInputUdfOperator.returns(String) Please use SingleInputUdfOperator.returns(Class) or SingleInputUdfOperator.returns(TypeHint) instead.
org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator.returns(String) Please use SingleOutputStreamOperator.returns(Class) or SingleOutputStreamOperator.returns(TypeHint) instead.
org.apache.flink.api.common.ExecutionConfig.setExecutionRetryDelay(long) This method will be replaced by ExecutionConfig.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration). The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the delay between successive execution attempts.
org.apache.flink.api.common.operators.DualInputOperator.setFirstInput(Operator<IN1>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.DualInputOperator.setFirstInputs(List<Operator<IN1>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.streaming.api.environment.CheckpointConfig.setForceCheckpointing(boolean) This will be removed once iterations properly participate in checkpointing.
org.apache.flink.api.common.operators.SingleInputOperator.setInput(Operator<IN>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.SingleInputOperator.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.setInputs(List<Operator<IN>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.GenericDataSinkBase.setInputs(Operator<IN>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.ExecutionConfig.setNumberOfExecutionRetries(int) This method will be replaced by ExecutionConfig.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration). The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the number of execution retries.
org.apache.flink.api.java.ExecutionEnvironment.setNumberOfExecutionRetries(int) This method will be replaced by ExecutionEnvironment.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration). The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the number of execution retries.
org.apache.flink.api.scala.ExecutionEnvironment.setNumberOfExecutionRetries(int) This method will be replaced by setRestartStrategy(). The FixedDelayRestartStrategyConfiguration contains the number of execution retries.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.setNumberOfExecutionRetries(int) This method will be replaced by StreamExecutionEnvironment.setRestartStrategy(org.apache.flink.api.common.restartstrategy.RestartStrategies.RestartStrategyConfiguration). The RestartStrategies.FixedDelayRestartStrategyConfiguration contains the number of execution retries.
org.apache.flink.streaming.api.scala.StreamExecutionEnvironment.setNumberOfExecutionRetries(int) This method will be replaced by setRestartStrategy(). The FixedDelayRestartStrategyConfiguration contains the number of execution retries.
org.apache.flink.api.common.operators.DualInputOperator.setSecondInput(Operator<IN2>...) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.common.operators.DualInputOperator.setSecondInputs(List<Operator<IN2>>) This method will be removed in future versions. Use the Union operator instead.
org.apache.flink.api.java.operators.DataSink.sortLocalOutput(int, Order)
org.apache.flink.api.java.operators.DataSink.sortLocalOutput(String, Order)
org.apache.flink.api.java.operators.JoinOperator.ProjectJoin.types(Class<?>...)
org.apache.flink.api.java.operators.CrossOperator.ProjectCross.types(Class<?>...)
org.apache.flink.api.java.operators.ProjectOperator.types(Class<?>...)

Deprecated Constructors

Constructor and Description
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer081(String, DeserializationSchema<T>, Properties)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer082(String, DeserializationSchema<T>, Properties)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, KeyedSerializationSchema<IN>, Properties)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, KeyedSerializationSchema<IN>, Properties, KafkaPartitioner)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, SerializationSchema<IN>, Properties)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, SerializationSchema<IN>, Properties, KafkaPartitioner)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, String, KeyedSerializationSchema<IN>)
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer(String, String, SerializationSchema<IN>)