This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 34729c88914 [FLINK-32656][table] Deprecate ManagedTable related APIs
add aa98c18d2ba [FLINK-32558][flink-java] Deprecate all DataSet API
No new revisions were added by this update.
Summary of changes:
.../generated/pipeline_configuration.html | 6 -
.../apache/flink/api/common/ExecutionConfig.java | 38 ++++
.../org/apache/flink/api/common/ExecutionMode.java | 8 +
.../flink/configuration/PipelineOptions.java | 13 ++
flink-dist/src/main/assemblies/bin.xml | 6 +-
flink-examples/flink-examples-batch/pom.xml | 42 ++--
.../flink/examples/java/clustering/KMeans.java | 13 ++
.../apache/flink/examples/java/distcp/DistCp.java | 8 +
.../examples/java/graph/ConnectedComponents.java | 13 ++
.../flink/examples/java/graph/EnumTriangles.java | 13 ++
.../apache/flink/examples/java/graph/PageRank.java | 11 +
.../java/graph/TransitiveClosureNaive.java | 13 ++
.../java/misc/CollectionExecutionExample.java | 14 ++
.../flink/examples/java/misc/PiEstimation.java | 13 ++
.../relational/EmptyFieldsCountAccumulator.java | 12 ++
.../examples/java/relational/TPCHQuery10.java | 13 ++
.../flink/examples/java/relational/TPCHQuery3.java | 13 ++
.../examples/java/relational/WebLogAnalysis.java | 13 ++
.../examples/java/util/DataSetDeprecationInfo.java | 20 +-
.../flink/examples/java/wordcount/WordCount.java | 13 ++
.../examples/java/wordcount/WordCountPojo.java | 13 ++
flink-examples/flink-examples-streaming/pom.xml | 1 +
.../streaming/examples/async/AsyncIOExample.java | 2 +-
.../streaming/examples/gpu/MatrixVectorMul.java | 2 +-
.../examples/iteration/IterateExample.java | 2 +-
.../flink/streaming/examples/join/WindowJoin.java | 5 +-
.../examples/sideoutput/SideOutputExample.java | 2 +-
.../examples/socket/SocketWindowWordCount.java | 2 +-
.../statemachine/KafkaEventsGeneratorJob.java | 2 +-
.../examples/statemachine/StateMachineExample.java | 2 +-
.../streaming/examples/utils/ParameterTool.java | 227 +++++++++++++++++++++
.../examples/windowing/SessionWindowing.java | 2 +-
.../streaming/examples/wordcount/util/CLI.java | 10 +-
.../java/connectors/ChangelogSocketExample.java | 43 +++-
.../flink/api/java/CollectionEnvironment.java | 7 +
.../java/org/apache/flink/api/java/DataSet.java | 6 +
.../flink/api/java/ExecutionEnvironment.java | 6 +
.../api/java/ExecutionEnvironmentFactory.java | 11 +-
.../apache/flink/api/java/LocalEnvironment.java | 7 +
.../apache/flink/api/java/RemoteEnvironment.java | 7 +
.../flink/api/java/aggregation/Aggregations.java | 11 +-
.../UnsupportedAggregationTypeException.java | 11 +-
.../flink/api/java/functions/FlatMapIterator.java | 6 +
.../api/java/functions/FunctionAnnotation.java | 7 +
.../api/java/functions/GroupReduceIterator.java | 6 +
.../flink/api/java/io/CollectionInputFormat.java | 11 +-
.../apache/flink/api/java/io/CsvOutputFormat.java | 7 +
.../org/apache/flink/api/java/io/CsvReader.java | 34 ++-
.../flink/api/java/io/DiscardingOutputFormat.java | 6 +
.../flink/api/java/io/IteratorInputFormat.java | 11 +-
.../api/java/io/LocalCollectionOutputFormat.java | 11 +-
.../api/java/io/ParallelIteratorInputFormat.java | 11 +-
.../flink/api/java/io/PrimitiveInputFormat.java | 7 +
.../flink/api/java/io/PrintingOutputFormat.java | 6 +
.../flink/api/java/io/RowCsvInputFormat.java | 11 +-
.../flink/api/java/io/SplitDataProperties.java | 6 +
.../apache/flink/api/java/io/TextInputFormat.java | 11 +-
.../apache/flink/api/java/io/TextOutputFormat.java | 6 +
.../flink/api/java/io/TextValueInputFormat.java | 11 +-
.../api/java/io/TypeSerializerInputFormat.java | 6 +
.../api/java/io/TypeSerializerOutputFormat.java | 6 +
.../api/java/operators/AggregateOperator.java | 6 +
.../flink/api/java/operators/CoGroupOperator.java | 6 +
.../flink/api/java/operators/CrossOperator.java | 6 +
.../api/java/operators/CustomUnaryOperation.java | 6 +
.../apache/flink/api/java/operators/DataSink.java | 6 +
.../flink/api/java/operators/DataSource.java | 6 +
.../flink/api/java/operators/DeltaIteration.java | 6 +
.../java/operators/DeltaIterationResultSet.java | 6 +
.../flink/api/java/operators/DistinctOperator.java | 6 +
.../flink/api/java/operators/FilterOperator.java | 6 +
.../flink/api/java/operators/FlatMapOperator.java | 6 +
.../api/java/operators/GroupCombineOperator.java | 6 +
.../api/java/operators/GroupReduceOperator.java | 6 +
.../apache/flink/api/java/operators/Grouping.java | 6 +
.../flink/api/java/operators/IterativeDataSet.java | 6 +
.../flink/api/java/operators/JoinOperator.java | 6 +
.../flink/api/java/operators/MapOperator.java | 6 +
.../api/java/operators/MapPartitionOperator.java | 6 +
.../apache/flink/api/java/operators/Operator.java | 6 +
.../api/java/operators/PartitionOperator.java | 6 +
.../flink/api/java/operators/ProjectOperator.java | 6 +
.../flink/api/java/operators/ReduceOperator.java | 6 +
.../api/java/operators/SingleInputOperator.java | 6 +
.../api/java/operators/SingleInputUdfOperator.java | 6 +
.../api/java/operators/SortPartitionOperator.java | 6 +
.../flink/api/java/operators/SortedGrouping.java | 6 +
.../flink/api/java/operators/TwoInputOperator.java | 6 +
.../api/java/operators/TwoInputUdfOperator.java | 6 +
.../flink/api/java/operators/UdfOperator.java | 7 +
.../flink/api/java/operators/UnionOperator.java | 6 +
.../flink/api/java/operators/UnsortedGrouping.java | 6 +
.../java/operators/join/JoinFunctionAssigner.java | 6 +
.../java/operators/join/JoinOperatorSetsBase.java | 6 +
.../flink/api/java/operators/join/JoinType.java | 11 +-
.../api/java/summarize/BooleanColumnSummary.java | 11 +-
.../flink/api/java/summarize/ColumnSummary.java | 11 +-
.../api/java/summarize/NumericColumnSummary.java | 6 +
.../api/java/summarize/ObjectColumnSummary.java | 11 +-
.../api/java/summarize/StringColumnSummary.java | 11 +-
.../api/java/utils/AbstractParameterTool.java | 7 +
.../apache/flink/api/java/utils/DataSetUtils.java | 7 +
.../api/java/utils/MultipleParameterTool.java | 7 +
.../apache/flink/api/java/utils/ParameterTool.java | 7 +
104 files changed, 1062 insertions(+), 82 deletions(-)
copy
flink-clients/src/main/java/org/apache/flink/client/cli/CliArgsException.java
=>
flink-examples/flink-examples-batch/src/main/java/org/apache/flink/examples/java/util/DataSetDeprecationInfo.java
(56%)
create mode 100644
flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/utils/ParameterTool.java
