Skip to content

Commit

Permalink
[FLINK-36336] Remove deprecated dataset API exclude table module
Browse files Browse the repository at this point in the history
  • Loading branch information
@codenohup
codenohup authored Oct 1, 2024
1 parent a6a5ee6 commit 4e6dc79
Show file tree
Hide file tree
Showing 711 changed files with 2,218 additions and 97,633 deletions.
23 changes: 4 additions & 19 deletions ...nk-architecture-tests-production/archunit-violations/18509c9e-3250-4c52-91b9-11ccefc85db1
View file
Original file line number Diff line number Diff line change
Expand Up @@ -51,25 +51,6 @@ org.apache.flink.api.connector.source.lib.NumberSequenceSource.getSplitSerialize
org.apache.flink.api.connector.source.lib.NumberSequenceSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext, java.util.Collection): Argument leaf type org.apache.flink.api.connector.source.lib.NumberSequenceSource$NumberSequenceSplit does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.connector.source.lib.NumberSequenceSource.restoreEnumerator(org.apache.flink.api.connector.source.SplitEnumeratorContext, java.util.Collection): Returned leaf type org.apache.flink.api.connector.source.lib.NumberSequenceSource$NumberSequenceSplit does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.connector.source.lib.util.IteratorSourceReaderBase.pollNext(org.apache.flink.api.connector.source.ReaderOutput): Returned leaf type org.apache.flink.core.io.InputStatus does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.DataSet.coGroup(org.apache.flink.api.java.DataSet): Returned leaf type org.apache.flink.api.java.operators.CoGroupOperator$CoGroupOperatorSets does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.DataSet.write(org.apache.flink.api.common.io.FileOutputFormat, java.lang.String, org.apache.flink.core.fs.FileSystem$WriteMode): Argument leaf type org.apache.flink.core.fs.FileSystem$WriteMode does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.DataSet.writeAsCsv(java.lang.String, java.lang.String, java.lang.String, org.apache.flink.core.fs.FileSystem$WriteMode): Argument leaf type org.apache.flink.core.fs.FileSystem$WriteMode does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.DataSet.writeAsCsv(java.lang.String, org.apache.flink.core.fs.FileSystem$WriteMode): Argument leaf type org.apache.flink.core.fs.FileSystem$WriteMode does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.DataSet.writeAsFormattedText(java.lang.String, org.apache.flink.api.java.io.TextOutputFormat$TextFormatter): Argument leaf type org.apache.flink.api.java.io.TextOutputFormat$TextFormatter does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.DataSet.writeAsFormattedText(java.lang.String, org.apache.flink.core.fs.FileSystem$WriteMode, org.apache.flink.api.java.io.TextOutputFormat$TextFormatter): Argument leaf type org.apache.flink.api.java.io.TextOutputFormat$TextFormatter does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.DataSet.writeAsFormattedText(java.lang.String, org.apache.flink.core.fs.FileSystem$WriteMode, org.apache.flink.api.java.io.TextOutputFormat$TextFormatter): Argument leaf type org.apache.flink.core.fs.FileSystem$WriteMode does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.DataSet.writeAsText(java.lang.String, org.apache.flink.core.fs.FileSystem$WriteMode): Argument leaf type org.apache.flink.core.fs.FileSystem$WriteMode does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.aggregation.Aggregations.getFactory(): Returned leaf type org.apache.flink.api.java.aggregation.AggregationFunctionFactory does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.CoGroupOperator.getSemanticProperties(): Returned leaf type org.apache.flink.api.common.operators.DualInputSemanticProperties does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.CoGroupOperator.getSemanticProperties(): Returned leaf type org.apache.flink.api.common.operators.SemanticProperties does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.JoinOperator$JoinOperatorSets.where([I): Returned leaf type org.apache.flink.api.java.operators.join.JoinOperatorSetsBase$JoinOperatorSetsPredicateBase does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.JoinOperator$JoinOperatorSets.where([Ljava.lang.String;): Returned leaf type org.apache.flink.api.java.operators.join.JoinOperatorSetsBase$JoinOperatorSetsPredicateBase does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.JoinOperator$JoinOperatorSets.where(org.apache.flink.api.java.functions.KeySelector): Returned leaf type org.apache.flink.api.java.operators.join.JoinOperatorSetsBase$JoinOperatorSetsPredicateBase does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.Operator.getMinResources(): Returned leaf type org.apache.flink.api.common.operators.ResourceSpec does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.Operator.getPreferredResources(): Returned leaf type org.apache.flink.api.common.operators.ResourceSpec does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.join.JoinOperatorSetsBase.where([I): Returned leaf type org.apache.flink.api.java.operators.join.JoinOperatorSetsBase$JoinOperatorSetsPredicateBase does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.join.JoinOperatorSetsBase.where([Ljava.lang.String;): Returned leaf type org.apache.flink.api.java.operators.join.JoinOperatorSetsBase$JoinOperatorSetsPredicateBase does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.operators.join.JoinOperatorSetsBase.where(org.apache.flink.api.java.functions.KeySelector): Returned leaf type org.apache.flink.api.java.operators.join.JoinOperatorSetsBase$JoinOperatorSetsPredicateBase does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.typeutils.PojoTypeInfo.createPojoSerializer(org.apache.flink.api.common.serialization.SerializerConfig): Argument leaf type org.apache.flink.api.common.serialization.SerializerConfig does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.typeutils.PojoTypeInfo.createPojoSerializer(org.apache.flink.api.common.serialization.SerializerConfig): Returned leaf type org.apache.flink.api.java.typeutils.runtime.PojoSerializer does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.api.java.typeutils.ValueTypeInfo.createSerializer(org.apache.flink.api.common.serialization.SerializerConfig): Argument leaf type org.apache.flink.api.common.serialization.SerializerConfig does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
Expand All @@ -88,6 +69,10 @@ org.apache.flink.core.fs.FileSystem.initOutPathLocalFS(org.apache.flink.core.fs.
org.apache.flink.core.fs.FileSystem.initialize(org.apache.flink.configuration.Configuration, org.apache.flink.core.plugin.PluginManager): Argument leaf type org.apache.flink.core.plugin.PluginManager does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.core.fs.FileSystem.initialize(org.apache.flink.configuration.Configuration, org.apache.flink.core.plugin.PluginManager): Exception leaf type org.apache.flink.configuration.IllegalConfigurationException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.core.io.InputSplitSource.getInputSplitAssigner([Lorg.apache.flink.core.io.InputSplit;): Returned leaf type org.apache.flink.core.io.InputSplitAssigner does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction.apply(java.lang.Object, org.apache.flink.streaming.api.windowing.windows.GlobalWindow, java.lang.Iterable, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.windowing.windows.GlobalWindow does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction.apply(java.lang.Object, org.apache.flink.streaming.api.windowing.windows.Window, java.lang.Iterable, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.windowing.windows.Window does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction.apply(org.apache.flink.streaming.api.windowing.windows.GlobalWindow, java.lang.Iterable, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.windowing.windows.GlobalWindow does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction.apply(org.apache.flink.streaming.api.windowing.windows.Window, java.lang.Iterable, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.windowing.windows.Window does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.runtime.jobgraph.tasks.InputSplitProvider.getNextInputSplit(java.lang.ClassLoader): Exception leaf type org.apache.flink.runtime.jobgraph.tasks.InputSplitProviderException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.streaming.api.checkpoint.CheckpointedFunction.initializeState(org.apache.flink.runtime.state.FunctionInitializationContext): Argument leaf type org.apache.flink.runtime.state.FunctionInitializationContext does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
org.apache.flink.streaming.api.checkpoint.CheckpointedFunction.snapshotState(org.apache.flink.runtime.state.FunctionSnapshotContext): Argument leaf type org.apache.flink.runtime.state.FunctionSnapshotContext does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
Expand Down
9 changes: 0 additions & 9 deletions ...nk-architecture-tests-production/archunit-violations/5b9eed8a-5fb6-4373-98ac-3be2a71941b8
View file
Original file line number Diff line number Diff line change
Expand Up @@ -13,15 +13,6 @@ org.apache.flink.api.common.state.StateDescriptor.getType(): Returned leaf type
org.apache.flink.api.common.state.ValueStateDescriptor.getType(): Returned leaf type org.apache.flink.api.common.state.StateDescriptor$Type does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.common.typeinfo.PrimitiveArrayTypeInfo.createComparator(boolean, org.apache.flink.api.common.ExecutionConfig): Returned leaf type org.apache.flink.api.common.typeutils.base.array.PrimitiveArrayComparator does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.common.typeutils.TypeComparator.putNormalizedKey(java.lang.Object, org.apache.flink.core.memory.MemorySegment, int, int): Argument leaf type org.apache.flink.core.memory.MemorySegment does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.io.SplitDataProperties.getSplitOrder(): Returned leaf type org.apache.flink.api.common.operators.Ordering does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.operators.DataSink.getMinResources(): Returned leaf type org.apache.flink.api.common.operators.ResourceSpec does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.operators.DataSink.getPreferredResources(): Returned leaf type org.apache.flink.api.common.operators.ResourceSpec does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.operators.DeltaIteration.getAggregators(): Returned leaf type org.apache.flink.api.common.aggregators.AggregatorRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.operators.DeltaIteration.getMinResources(): Returned leaf type org.apache.flink.api.common.operators.ResourceSpec does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.operators.DeltaIteration.getPreferredResources(): Returned leaf type org.apache.flink.api.common.operators.ResourceSpec does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.operators.DistinctOperator.setCombineHint(org.apache.flink.api.common.operators.base.ReduceOperatorBase$CombineHint): Argument leaf type org.apache.flink.api.common.operators.base.ReduceOperatorBase$CombineHint does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.operators.IterativeDataSet.getAggregators(): Returned leaf type org.apache.flink.api.common.aggregators.AggregatorRegistry does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.operators.ReduceOperator.setCombineHint(org.apache.flink.api.common.operators.base.ReduceOperatorBase$CombineHint): Argument leaf type org.apache.flink.api.common.operators.base.ReduceOperatorBase$CombineHint does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.typeutils.PojoTypeInfo.getPojoFieldAt(int): Returned leaf type org.apache.flink.api.java.typeutils.PojoField does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.api.java.typeutils.TupleTypeInfo.createSerializer(org.apache.flink.api.common.serialization.SerializerConfig): Returned leaf type org.apache.flink.api.java.typeutils.runtime.TupleSerializer does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
org.apache.flink.cep.functions.PatternProcessFunction.processMatch(java.util.Map, org.apache.flink.cep.functions.PatternProcessFunction$Context, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.cep.functions.PatternProcessFunction$Context does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @PublicEvolving or annotated with @Deprecated
Expand Down
Loading

0 comments on commit 4e6dc79

Please sign in to comment.