2019-02-17 14:00:40

CONTRIBUTING.md

@@ -6,148 +6,148 @@
 
 ## 章节列表
 
-+ [Apache Flink Documentation](docs/1.md)
-+ [Dataflow Programming Model](docs/2.md)
-+ [Distributed Runtime Environment](docs/3.md)
-+ [DataStream API Tutorial](docs/4.md)
-+ [Local Setup Tutorial](docs/5.md)
-+ [Running Flink on Windows](docs/6.md)
-+ [Examples](docs/7.md)
-+ [Batch Examples](docs/8.md)
-+ [Project Template for Java](docs/9.md)
-+ [Project Template for Scala](docs/10.md)
-+ [Configuring Dependencies, Connectors, Libraries](docs/11.md)
-+ [Basic API Concepts](docs/12.md)
-+ [Scala API Extensions](docs/13.md)
-+ [Java Lambda Expressions](docs/14.md)
-+ [Flink DataStream API Programming Guide](docs/15.md)
-+ [Event Time](docs/16.md)
-+ [Generating Timestamps / Watermarks](docs/17.md)
-+ [Pre-defined Timestamp Extractors / Watermark Emitters](docs/18.md)
-+ [State & Fault Tolerance](docs/19.md)
-+ [Working with State](docs/20.md)
-+ [The Broadcast State Pattern](docs/21.md)
-+ [Checkpointing](docs/22.md)
-+ [Queryable State Beta](docs/23.md)
-+ [State Backends](docs/24.md)
-+ [State Schema Evolution](docs/25.md)
-+ [Custom Serialization for Managed State](docs/26.md)
-+ [Operators](docs/27.md)
-+ [Windows](docs/28.md)
-+ [Joining](docs/29.md)
-+ [Process Function (Low-level Operations)](docs/30.md)
-+ [Asynchronous I/O for External Data Access](docs/31.md)
-+ [Streaming Connectors](docs/32.md)
-+ [Fault Tolerance Guarantees of Data Sources and Sinks](docs/33.md)
-+ [Apache Kafka Connector](docs/34.md)
-+ [Apache Cassandra Connector](docs/35.md)
-+ [Amazon AWS Kinesis Streams Connector](docs/36.md)
-+ [Elasticsearch Connector](docs/37.md)
-+ [HDFS Connector](docs/38.md)
-+ [Streaming File Sink](docs/39.md)
-+ [RabbitMQ Connector](docs/40.md)
-+ [Apache NiFi Connector](docs/41.md)
-+ [Twitter Connector](docs/42.md)
-+ [Side Outputs](docs/43.md)
-+ [Python Programming Guide (Streaming) Beta](docs/44.md)
-+ [Testing](docs/45.md)
-+ [Experimental Features](docs/46.md)
-+ [Flink DataSet API Programming Guide](docs/47.md)
-+ [DataSet Transformations](docs/48.md)
-+ [Fault Tolerance](docs/49.md)
-+ [Iterations](docs/50.md)
-+ [Zipping Elements in a DataSet](docs/51.md)
-+ [Connectors](docs/52.md)
-+ [Python Programming Guide Beta](docs/53.md)
-+ [Hadoop Compatibility Beta](docs/54.md)
-+ [Local Execution](docs/55.md)
-+ [Cluster Execution](docs/56.md)
-+ [Table API & SQL](docs/57.md)
-+ [Concepts & Common API](docs/58.md)
-+ [Streaming Concepts](docs/59.md)
-+ [Dynamic Tables](docs/60.md)
-+ [Time Attributes](docs/61.md)
-+ [Joins in Continuous Queries](docs/62.md)
-+ [Temporal Tables](docs/63.md)
-+ [Detecting Patterns in Tables Beta](docs/64.md)
-+ [Query Configuration](docs/65.md)
-+ [Connect to External Systems](docs/66.md)
-+ [Table API](docs/67.md)
-+ [SQL](docs/68.md)
-+ [Built-In Functions](docs/69.md)
-+ [User-defined Sources & Sinks](docs/70.md)
-+ [User-defined Functions](docs/71.md)
-+ [SQL Client Beta](docs/72.md)
-+ [Data Types & Serialization](docs/73.md)
-+ [Register a custom serializer for your Flink program](docs/74.md)
-+ [Execution Configuration](docs/75.md)
-+ [Program Packaging and Distributed Execution](docs/76.md)
-+ [Parallel Execution](docs/77.md)
-+ [Execution Plans](docs/78.md)
-+ [Restart Strategies](docs/79.md)
-+ [FlinkCEP - Complex event processing for Flink](docs/80.md)
-+ [Storm Compatibility Beta](docs/81.md)
-+ [Gelly: Flink Graph API](docs/82.md)
-+ [Graph API](docs/83.md)
-+ [Iterative Graph Processing](docs/84.md)
-+ [Library Methods](docs/85.md)
-+ [Graph Algorithms](docs/86.md)
-+ [Graph Generators](docs/87.md)
-+ [Bipartite Graph](docs/88.md)
-+ [FlinkML - Machine Learning for Flink](docs/89.md)
-+ [Quickstart Guide](docs/90.md)
-+ [Alternating Least Squares](docs/91.md)
-+ [How to Contribute](docs/92.md)
-+ [Cross Validation](docs/93.md)
-+ [Distance Metrics](docs/94.md)
-+ [k-Nearest Neighbors Join](docs/95.md)
-+ [MinMax Scaler](docs/96.md)
-+ [Multiple Linear Regression](docs/97.md)
-+ [Looking under the hood of pipelines](docs/98.md)
-+ [Polynomial Features](docs/99.md)
-+ [Stochastic Outlier Selection](docs/100.md)
-+ [Standard Scaler](docs/101.md)
-+ [SVM using CoCoA](docs/102.md)
-+ [Best Practices](docs/103.md)
-+ [API Migration Guides](docs/104.md)
-+ [Standalone Cluster](docs/105.md)
-+ [YARN Setup](docs/106.md)
-+ [Mesos Setup](docs/107.md)
-+ [Docker Setup](docs/108.md)
-+ [Kubernetes Setup](docs/109.md)
-+ [Amazon Web Services (AWS)](docs/110.md)
-+ [Google Compute Engine Setup](docs/111.md)
-+ [MapR Setup](docs/112.md)
-+ [Hadoop Integration](docs/113.md)
-+ [JobManager High Availability (HA)](docs/114.md)
-+ [Checkpoints](docs/115.md)
-+ [Savepoints](docs/116.md)
-+ [State Backends](docs/117.md)
-+ [Tuning Checkpoints and Large State](docs/118.md)
-+ [Configuration](docs/119.md)
-+ [Production Readiness Checklist](docs/120.md)
-+ [Command-Line Interface](docs/121.md)
-+ [Scala REPL](docs/122.md)
-+ [Kerberos Authentication Setup and Configuration](docs/123.md)
-+ [SSL Setup](docs/124.md)
-+ [File Systems](docs/125.md)
-+ [Upgrading Applications and Flink Versions](docs/126.md)
-+ [Metrics](docs/127.md)
-+ [How to use logging](docs/128.md)
-+ [History Server](docs/129.md)
-+ [Monitoring Checkpointing](docs/130.md)
-+ [Monitoring Back Pressure](docs/131.md)
-+ [Monitoring REST API](docs/132.md)
-+ [Debugging Windows & Event Time](docs/133.md)
-+ [Debugging Classloading](docs/134.md)
-+ [Application Profiling](docs/135.md)
-+ [Importing Flink into an IDE](docs/136.md)
-+ [Building Flink from Source](docs/137.md)
-+ [Component Stack](docs/138.md)
-+ [Data Streaming Fault Tolerance](docs/139.md)
-+ [Jobs and Scheduling](docs/140.md)
-+ [Task Lifecycle](docs/141.md)
-+ [File Systems](docs/142.md)
++ [Apache Flink Documentation](docs/1.7/1.md)
++ [Dataflow Programming Model](docs/1.7/2.md)
++ [Distributed Runtime Environment](docs/1.7/3.md)
++ [DataStream API Tutorial](docs/1.7/4.md)
++ [Local Setup Tutorial](docs/1.7/5.md)
++ [Running Flink on Windows](docs/1.7/6.md)
++ [Examples](docs/1.7/7.md)
++ [Batch Examples](docs/1.7/8.md)
++ [Project Template for Java](docs/1.7/9.md)
++ [Project Template for Scala](docs/1.7/10.md)
++ [Configuring Dependencies, Connectors, Libraries](docs/1.7/11.md)
++ [Basic API Concepts](docs/1.7/12.md)
++ [Scala API Extensions](docs/1.7/13.md)
++ [Java Lambda Expressions](docs/1.7/14.md)
++ [Flink DataStream API Programming Guide](docs/1.7/15.md)
++ [Event Time](docs/1.7/16.md)
++ [Generating Timestamps / Watermarks](docs/1.7/17.md)
++ [Pre-defined Timestamp Extractors / Watermark Emitters](docs/1.7/18.md)
++ [State & Fault Tolerance](docs/1.7/19.md)
++ [Working with State](docs/1.7/20.md)
++ [The Broadcast State Pattern](docs/1.7/21.md)
++ [Checkpointing](docs/1.7/22.md)
++ [Queryable State Beta](docs/1.7/23.md)
++ [State Backends](docs/1.7/24.md)
++ [State Schema Evolution](docs/1.7/25.md)
++ [Custom Serialization for Managed State](docs/1.7/26.md)
++ [Operators](docs/1.7/27.md)
++ [Windows](docs/1.7/28.md)
++ [Joining](docs/1.7/29.md)
++ [Process Function (Low-level Operations)](docs/1.7/30.md)
++ [Asynchronous I/O for External Data Access](docs/1.7/31.md)
++ [Streaming Connectors](docs/1.7/32.md)
++ [Fault Tolerance Guarantees of Data Sources and Sinks](docs/1.7/33.md)
++ [Apache Kafka Connector](docs/1.7/34.md)
++ [Apache Cassandra Connector](docs/1.7/35.md)
++ [Amazon AWS Kinesis Streams Connector](docs/1.7/36.md)
++ [Elasticsearch Connector](docs/1.7/37.md)
++ [HDFS Connector](docs/1.7/38.md)
++ [Streaming File Sink](docs/1.7/39.md)
++ [RabbitMQ Connector](docs/1.7/40.md)
++ [Apache NiFi Connector](docs/1.7/41.md)
++ [Twitter Connector](docs/1.7/42.md)
++ [Side Outputs](docs/1.7/43.md)
++ [Python Programming Guide (Streaming) Beta](docs/1.7/44.md)
++ [Testing](docs/1.7/45.md)
++ [Experimental Features](docs/1.7/46.md)
++ [Flink DataSet API Programming Guide](docs/1.7/47.md)
++ [DataSet Transformations](docs/1.7/48.md)
++ [Fault Tolerance](docs/1.7/49.md)
++ [Iterations](docs/1.7/50.md)
++ [Zipping Elements in a DataSet](docs/1.7/51.md)
++ [Connectors](docs/1.7/52.md)
++ [Python Programming Guide Beta](docs/1.7/53.md)
++ [Hadoop Compatibility Beta](docs/1.7/54.md)
++ [Local Execution](docs/1.7/55.md)
++ [Cluster Execution](docs/1.7/56.md)
++ [Table API & SQL](docs/1.7/57.md)
++ [Concepts & Common API](docs/1.7/58.md)
++ [Streaming Concepts](docs/1.7/59.md)
++ [Dynamic Tables](docs/1.7/60.md)
++ [Time Attributes](docs/1.7/61.md)
++ [Joins in Continuous Queries](docs/1.7/62.md)
++ [Temporal Tables](docs/1.7/63.md)
++ [Detecting Patterns in Tables Beta](docs/1.7/64.md)
++ [Query Configuration](docs/1.7/65.md)
++ [Connect to External Systems](docs/1.7/66.md)
++ [Table API](docs/1.7/67.md)
++ [SQL](docs/1.7/68.md)
++ [Built-In Functions](docs/1.7/69.md)
++ [User-defined Sources & Sinks](docs/1.7/70.md)
++ [User-defined Functions](docs/1.7/71.md)
++ [SQL Client Beta](docs/1.7/72.md)
++ [Data Types & Serialization](docs/1.7/73.md)
++ [Register a custom serializer for your Flink program](docs/1.7/74.md)
++ [Execution Configuration](docs/1.7/75.md)
++ [Program Packaging and Distributed Execution](docs/1.7/76.md)
++ [Parallel Execution](docs/1.7/77.md)
++ [Execution Plans](docs/1.7/78.md)
++ [Restart Strategies](docs/1.7/79.md)
++ [FlinkCEP - Complex event processing for Flink](docs/1.7/80.md)
++ [Storm Compatibility Beta](docs/1.7/81.md)
++ [Gelly: Flink Graph API](docs/1.7/82.md)
++ [Graph API](docs/1.7/83.md)
++ [Iterative Graph Processing](docs/1.7/84.md)
++ [Library Methods](docs/1.7/85.md)
++ [Graph Algorithms](docs/1.7/86.md)
++ [Graph Generators](docs/1.7/87.md)
++ [Bipartite Graph](docs/1.7/88.md)
++ [FlinkML - Machine Learning for Flink](docs/1.7/89.md)
++ [Quickstart Guide](docs/1.7/90.md)
++ [Alternating Least Squares](docs/1.7/91.md)
++ [How to Contribute](docs/1.7/92.md)
++ [Cross Validation](docs/1.7/93.md)
++ [Distance Metrics](docs/1.7/94.md)
++ [k-Nearest Neighbors Join](docs/1.7/95.md)
++ [MinMax Scaler](docs/1.7/96.md)
++ [Multiple Linear Regression](docs/1.7/97.md)
++ [Looking under the hood of pipelines](docs/1.7/98.md)
++ [Polynomial Features](docs/1.7/99.md)
++ [Stochastic Outlier Selection](docs/1.7/100.md)
++ [Standard Scaler](docs/1.7/101.md)
++ [SVM using CoCoA](docs/1.7/102.md)
++ [Best Practices](docs/1.7/103.md)
++ [API Migration Guides](docs/1.7/104.md)
++ [Standalone Cluster](docs/1.7/105.md)
++ [YARN Setup](docs/1.7/106.md)
++ [Mesos Setup](docs/1.7/107.md)
++ [Docker Setup](docs/1.7/108.md)
++ [Kubernetes Setup](docs/1.7/109.md)
++ [Amazon Web Services (AWS)](docs/1.7/110.md)
++ [Google Compute Engine Setup](docs/1.7/111.md)
++ [MapR Setup](docs/1.7/112.md)
++ [Hadoop Integration](docs/1.7/113.md)
++ [JobManager High Availability (HA)](docs/1.7/114.md)
++ [Checkpoints](docs/1.7/115.md)
++ [Savepoints](docs/1.7/116.md)
++ [State Backends](docs/1.7/117.md)
++ [Tuning Checkpoints and Large State](docs/1.7/118.md)
++ [Configuration](docs/1.7/119.md)
++ [Production Readiness Checklist](docs/1.7/120.md)
++ [Command-Line Interface](docs/1.7/121.md)
++ [Scala REPL](docs/1.7/122.md)
++ [Kerberos Authentication Setup and Configuration](docs/1.7/123.md)
++ [SSL Setup](docs/1.7/124.md)
++ [File Systems](docs/1.7/125.md)
++ [Upgrading Applications and Flink Versions](docs/1.7/126.md)
++ [Metrics](docs/1.7/127.md)
++ [How to use logging](docs/1.7/128.md)
++ [History Server](docs/1.7/129.md)
++ [Monitoring Checkpointing](docs/1.7/130.md)
++ [Monitoring Back Pressure](docs/1.7/131.md)
++ [Monitoring REST API](docs/1.7/132.md)
++ [Debugging Windows & Event Time](docs/1.7/133.md)
++ [Debugging Classloading](docs/1.7/134.md)
++ [Application Profiling](docs/1.7/135.md)
++ [Importing Flink into an IDE](docs/1.7/136.md)
++ [Building Flink from Source](docs/1.7/137.md)
++ [Component Stack](docs/1.7/138.md)
++ [Data Streaming Fault Tolerance](docs/1.7/139.md)
++ [Jobs and Scheduling](docs/1.7/140.md)
++ [Task Lifecycle](docs/1.7/141.md)
++ [File Systems](docs/1.7/142.md)
 
 ## 流程
 
@@ -170,4 +170,4 @@
 +   `push`
 +   `pull request`
 
-请见 [Github 入门指南](https://github.com/apachecn/kaggle/blob/dev/docs/GitHub)。
\ No newline at end of file
+请见 [Github 入门指南](https://github.com/apachecn/kaggle/blob/dev/docs/1.7/GitHub)。
\ No newline at end of file

README.md

 # Flink 1.7 中文文档
 
-![](docs/img/navbar-brand-logo.png)
+![](logo.png)
 
 > 原文：[Apache Flink 1.7 Documentation](https://ci.apache.org/projects/flink/flink-docs-release-1.7/)
 > 

SUMMARY.md

-+ [Flink 1.7 中文文档](README.md)
-+ [Apache Flink Documentation](docs/1.md)
-+ [Dataflow Programming Model](docs/2.md)
-+ [Distributed Runtime Environment](docs/3.md)
-+ [DataStream API Tutorial](docs/4.md)
-+ [Local Setup Tutorial](docs/5.md)
-+ [Running Flink on Windows](docs/6.md)
-+ [Examples](docs/7.md)
-+ [Batch Examples](docs/8.md)
-+ [Project Template for Java](docs/9.md)
-+ [Project Template for Scala](docs/10.md)
-+ [Configuring Dependencies, Connectors, Libraries](docs/11.md)
-+ [Basic API Concepts](docs/12.md)
-+ [Scala API Extensions](docs/13.md)
-+ [Java Lambda Expressions](docs/14.md)
-+ [Flink DataStream API Programming Guide](docs/15.md)
-+ [Event Time](docs/16.md)
-+ [Generating Timestamps / Watermarks](docs/17.md)
-+ [Pre-defined Timestamp Extractors / Watermark Emitters](docs/18.md)
-+ [State & Fault Tolerance](docs/19.md)
-+ [Working with State](docs/20.md)
-+ [The Broadcast State Pattern](docs/21.md)
-+ [Checkpointing](docs/22.md)
-+ [Queryable State Beta](docs/23.md)
-+ [State Backends](docs/24.md)
-+ [State Schema Evolution](docs/25.md)
-+ [Custom Serialization for Managed State](docs/26.md)
-+ [Operators](docs/27.md)
-+ [Windows](docs/28.md)
-+ [Joining](docs/29.md)
-+ [Process Function (Low-level Operations)](docs/30.md)
-+ [Asynchronous I/O for External Data Access](docs/31.md)
-+ [Streaming Connectors](docs/32.md)
-+ [Fault Tolerance Guarantees of Data Sources and Sinks](docs/33.md)
-+ [Apache Kafka Connector](docs/34.md)
-+ [Apache Cassandra Connector](docs/35.md)
-+ [Amazon AWS Kinesis Streams Connector](docs/36.md)
-+ [Elasticsearch Connector](docs/37.md)
-+ [HDFS Connector](docs/38.md)
-+ [Streaming File Sink](docs/39.md)
-+ [RabbitMQ Connector](docs/40.md)
-+ [Apache NiFi Connector](docs/41.md)
-+ [Twitter Connector](docs/42.md)
-+ [Side Outputs](docs/43.md)
-+ [Python Programming Guide (Streaming) Beta](docs/44.md)
-+ [Testing](docs/45.md)
-+ [Experimental Features](docs/46.md)
-+ [Flink DataSet API Programming Guide](docs/47.md)
-+ [DataSet Transformations](docs/48.md)
-+ [Fault Tolerance](docs/49.md)
-+ [Iterations](docs/50.md)
-+ [Zipping Elements in a DataSet](docs/51.md)
-+ [Connectors](docs/52.md)
-+ [Python Programming Guide Beta](docs/53.md)
-+ [Hadoop Compatibility Beta](docs/54.md)
-+ [Local Execution](docs/55.md)
-+ [Cluster Execution](docs/56.md)
-+ [Table API & SQL](docs/57.md)
-+ [Concepts & Common API](docs/58.md)
-+ [Streaming Concepts](docs/59.md)
-+ [Dynamic Tables](docs/60.md)
-+ [Time Attributes](docs/61.md)
-+ [Joins in Continuous Queries](docs/62.md)
-+ [Temporal Tables](docs/63.md)
-+ [Detecting Patterns in Tables Beta](docs/64.md)
-+ [Query Configuration](docs/65.md)
-+ [Connect to External Systems](docs/66.md)
-+ [Table API](docs/67.md)
-+ [SQL](docs/68.md)
-+ [Built-In Functions](docs/69.md)
-+ [User-defined Sources & Sinks](docs/70.md)
-+ [User-defined Functions](docs/71.md)
-+ [SQL Client Beta](docs/72.md)
-+ [Data Types & Serialization](docs/73.md)
-+ [Register a custom serializer for your Flink program](docs/74.md)
-+ [Execution Configuration](docs/75.md)
-+ [Program Packaging and Distributed Execution](docs/76.md)
-+ [Parallel Execution](docs/77.md)
-+ [Execution Plans](docs/78.md)
-+ [Restart Strategies](docs/79.md)
-+ [FlinkCEP - Complex event processing for Flink](docs/80.md)
-+ [Storm Compatibility Beta](docs/81.md)
-+ [Gelly: Flink Graph API](docs/82.md)
-+ [Graph API](docs/83.md)
-+ [Iterative Graph Processing](docs/84.md)
-+ [Library Methods](docs/85.md)
-+ [Graph Algorithms](docs/86.md)
-+ [Graph Generators](docs/87.md)
-+ [Bipartite Graph](docs/88.md)
-+ [FlinkML - Machine Learning for Flink](docs/89.md)
-+ [Quickstart Guide](docs/90.md)
-+ [Alternating Least Squares](docs/91.md)
-+ [How to Contribute](docs/92.md)
-+ [Cross Validation](docs/93.md)
-+ [Distance Metrics](docs/94.md)
-+ [k-Nearest Neighbors Join](docs/95.md)
-+ [MinMax Scaler](docs/96.md)
-+ [Multiple Linear Regression](docs/97.md)
-+ [Looking under the hood of pipelines](docs/98.md)
-+ [Polynomial Features](docs/99.md)
-+ [Stochastic Outlier Selection](docs/100.md)
-+ [Standard Scaler](docs/101.md)
-+ [SVM using CoCoA](docs/102.md)
-+ [Best Practices](docs/103.md)
-+ [API Migration Guides](docs/104.md)
-+ [Standalone Cluster](docs/105.md)
-+ [YARN Setup](docs/106.md)
-+ [Mesos Setup](docs/107.md)
-+ [Docker Setup](docs/108.md)
-+ [Kubernetes Setup](docs/109.md)
-+ [Amazon Web Services (AWS)](docs/110.md)
-+ [Google Compute Engine Setup](docs/111.md)
-+ [MapR Setup](docs/112.md)
-+ [Hadoop Integration](docs/113.md)
-+ [JobManager High Availability (HA)](docs/114.md)
-+ [Checkpoints](docs/115.md)
-+ [Savepoints](docs/116.md)
-+ [State Backends](docs/117.md)
-+ [Tuning Checkpoints and Large State](docs/118.md)
-+ [Configuration](docs/119.md)
-+ [Production Readiness Checklist](docs/120.md)
-+ [Command-Line Interface](docs/121.md)
-+ [Scala REPL](docs/122.md)
-+ [Kerberos Authentication Setup and Configuration](docs/123.md)
-+ [SSL Setup](docs/124.md)
-+ [File Systems](docs/125.md)
-+ [Upgrading Applications and Flink Versions](docs/126.md)
-+ [Metrics](docs/127.md)
-+ [How to use logging](docs/128.md)
-+ [History Server](docs/129.md)
-+ [Monitoring Checkpointing](docs/130.md)
-+ [Monitoring Back Pressure](docs/131.md)
-+ [Monitoring REST API](docs/132.md)
-+ [Debugging Windows & Event Time](docs/133.md)
-+ [Debugging Classloading](docs/134.md)
-+ [Application Profiling](docs/135.md)
-+ [Importing Flink into an IDE](docs/136.md)
-+ [Building Flink from Source](docs/137.md)
-+ [Component Stack](docs/138.md)
-+ [Data Streaming Fault Tolerance](docs/139.md)
-+ [Jobs and Scheduling](docs/140.md)
-+ [Task Lifecycle](docs/141.md)
-+ [File Systems](docs/142.md)
++   [Flink 1.7 中文文档](https://pytorch.apachecn.org/docs/1.7)
++   [Flink 1.7-SNAPSHOT 中文文档](https://pytorch.apachecn.org/docs/1.7-SNAPSHOT)
\ No newline at end of file

docs/1.7/404.html

+---
+permalink: /404.html
+---
+<script>window.location.href = '/';</script>