CLASS

SocketConnection

in org.apache.flink.streaming.api.operators.collect

Fully qualified name:	org.apache.flink.streaming.api.operators.collect.SocketConnection
Containing JAR files:	JAR flink-streaming-java-1.20.3.jar in org/apache/flink/flink-streaming-java/1.20.3 Latest JAR flink-streaming-java-1.20.2.jar in org/apache/flink/flink-streaming-java/1.20.2 JAR flink-streaming-java-1.20.1.jar in org/apache/flink/flink-streaming-java/1.20.1 JAR flink-streaming-java-1.20.0.jar in org/apache/flink/flink-streaming-java/1.20.0 JAR flink-streaming-java-1.19.3.jar in org/apache/flink/flink-streaming-java/1.19.3 JAR flink-streaming-java-1.19.2.jar in org/apache/flink/flink-streaming-java/1.19.2 JAR flink-streaming-java-1.19.1.jar in org/apache/flink/flink-streaming-java/1.19.1 JAR flink-streaming-java-1.19.0.jar in org/apache/flink/flink-streaming-java/1.19.0 JAR flink-streaming-java-1.18.1.jar in org/apache/flink/flink-streaming-java/1.18.1 JAR flink-streaming-java-1.18.0.jar in org/apache/flink/flink-streaming-java/1.18.0

	JAR flink-streaming-java-1.17.2.jar in org/apache/flink/flink-streaming-java/1.17.2 JAR flink-streaming-java-1.16.3.jar in org/apache/flink/flink-streaming-java/1.16.3 JAR beam-runners-flink-1.17-job-server-2.67.0.jar in org/apache/beam/beam-runners-flink-1.17-job-server/2.67.0 Java 22 Latest JAR beam-runners-flink-1.17-job-server-2.67.0-tests.jar in org/apache/beam/beam-runners-flink-1.17-job-server/2.67.0 Java 11 Latest JAR beam-runners-flink-1.17-job-server-2.66.0.jar in org/apache/beam/beam-runners-flink-1.17-job-server/2.66.0 Java 22 JAR beam-runners-flink-1.17-job-server-2.66.0-tests.jar in org/apache/beam/beam-runners-flink-1.17-job-server/2.66.0 Java 22 JAR beam-runners-flink-1.18-job-server-2.74.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.74.0 Java 17 Latest JAR beam-runners-flink-1.18-job-server-2.70.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.70.0 Java 24 JAR beam-runners-flink-1.18-job-server-2.69.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.69.0 Java 24 JAR beam-runners-flink-1.18-job-server-2.68.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.68.0 Java 22 JAR beam-runners-flink-1.18-job-server-2.67.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.67.0 Java 22 JAR beam-runners-flink-1.18-job-server-2.67.0-tests.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.67.0 Java 11 Latest JAR beam-runners-flink-1.18-job-server-2.66.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.66.0 Java 22 JAR beam-runners-flink-1.18-job-server-2.66.0-tests.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.66.0 Java 22 JAR beam-runners-flink-1.18-job-server-2.65.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.65.0 Java 22 JAR beam-runners-flink-1.18-job-server-2.64.0-tests.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.64.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.64.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.64.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.63.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.63.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.62.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.62.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.61.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.61.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.60.0-tests.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.60.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.60.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.60.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.59.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.59.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.59.0-tests.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.59.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.58.1.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.58.1 Java 21 JAR beam-runners-flink-1.18-job-server-2.58.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.58.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.58.0-tests.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.58.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.57.0-tests.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.57.0 Java 21 JAR beam-runners-flink-1.18-job-server-2.57.0.jar in org/apache/beam/beam-runners-flink-1.18-job-server/2.57.0 Java 21 JAR beam-runners-flink-1.19-job-server-2.76.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.76.0 Java 17 Latest JAR beam-runners-flink-1.19-job-server-2.75.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.75.0 JAR beam-runners-flink-1.19-job-server-2.70.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.70.0 Java 24 JAR beam-runners-flink-1.19-job-server-2.69.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.69.0 Java 24 JAR beam-runners-flink-1.19-job-server-2.68.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.68.0 Java 22 JAR beam-runners-flink-1.19-job-server-2.67.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.67.0 Java 22 JAR beam-runners-flink-1.19-job-server-2.67.0-tests.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.67.0 Java 11 Latest JAR beam-runners-flink-1.19-job-server-2.66.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.66.0 Java 22 JAR beam-runners-flink-1.19-job-server-2.66.0-tests.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.66.0 Java 22 JAR beam-runners-flink-1.19-job-server-2.65.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.65.0 Java 22 JAR beam-runners-flink-1.19-job-server-2.65.0-tests.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.65.0 Java 22 JAR beam-runners-flink-1.19-job-server-2.64.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.64.0 Java 21 JAR beam-runners-flink-1.19-job-server-2.64.0-tests.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.64.0 Java 21 JAR beam-runners-flink-1.19-job-server-2.63.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.63.0 Java 21 JAR beam-runners-flink-1.19-job-server-2.63.0-tests.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.63.0 Java 21 JAR beam-runners-flink-1.19-job-server-2.62.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.62.0 Java 21 JAR beam-runners-flink-1.19-job-server-2.61.0-tests.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.61.0 Java 21 JAR beam-runners-flink-1.19-job-server-2.61.0.jar in org/apache/beam/beam-runners-flink-1.19-job-server/2.61.0 Java 21 JAR beam-runners-flink-1.20-job-server-2.76.0.jar in org/apache/beam/beam-runners-flink-1.20-job-server/2.76.0 Java 17 Latest JAR beam-runners-flink-1.20-job-server-2.75.0.jar in org/apache/beam/beam-runners-flink-1.20-job-server/2.75.0 JAR beam-runners-flink-1.20-job-server-2.70.0.jar in org/apache/beam/beam-runners-flink-1.20-job-server/2.70.0 Java 24 JAR beam-runners-flink-2.0-job-server-2.76.0.jar in org/apache/beam/beam-runners-flink-2.0-job-server/2.76.0 Java 24 Latest JAR beam-runners-flink-2.0-job-server-2.75.0.jar in org/apache/beam/beam-runners-flink-2.0-job-server/2.75.0 JAR beam-runners-flink-2.1-job-server-2.76.0.jar in org/apache/beam/beam-runners-flink-2.1-job-server/2.76.0 Java 24 Latest JAR beam-runners-flink-2.1-job-server-2.75.0.jar in org/apache/beam/beam-runners-flink-2.1-job-server/2.75.0 JAR beam-runners-flink-2.2-job-server-2.76.0.jar in org/apache/beam/beam-runners-flink-2.2-job-server/2.76.0 Java 24 Latest JAR beam-runners-flink-2.2-job-server-2.75.0.jar in org/apache/beam/beam-runners-flink-2.2-job-server/2.75.0 JAR flink-runtime-2.3.0.jar in org/apache/flink/flink-runtime/2.3.0 Java 11 Latest JAR flink-runtime-2.2.0.jar in org/apache/flink/flink-runtime/2.2.0 JAR flink-runtime-2.1.1.jar in org/apache/flink/flink-runtime/2.1.1 JAR flink-runtime-2.1.0.jar in org/apache/flink/flink-runtime/2.1.0 JAR flink-runtime-2.0.1.jar in org/apache/flink/flink-runtime/2.0.1 JAR flink-runtime-2.0-preview1.jar in org/apache/flink/flink-runtime/2.0-preview1 JAR flink-runtime-2.0.0.jar in org/apache/flink/flink-runtime/2.0.0 JAR flink-sql-jdbc-driver-bundle-2.3.0.jar in org/apache/flink/flink-sql-jdbc-driver-bundle/2.3.0 Java 11 Latest JAR flink-sql-jdbc-driver-bundle-2.2.0.jar in org/apache/flink/flink-sql-jdbc-driver-bundle/2.2.0 JAR flink-sql-jdbc-driver-bundle-2.1.1.jar in org/apache/flink/flink-sql-jdbc-driver-bundle/2.1.1 JAR flink-sql-jdbc-driver-bundle-2.1.0.jar in org/apache/flink/flink-sql-jdbc-driver-bundle/2.1.0 JAR flink-sql-jdbc-driver-bundle-2.0.1.jar in org/apache/flink/flink-sql-jdbc-driver-bundle/2.0.1 JAR flink-sql-jdbc-driver-bundle-2.0-preview1.jar in org/apache/flink/flink-sql-jdbc-driver-bundle/2.0-preview1 JAR flink-sql-jdbc-driver-bundle-2.0.0.jar in org/apache/flink/flink-sql-jdbc-driver-bundle/2.0.0 JAR sort-connector-elasticsearch6-2.4.0.jar in org/apache/inlong/sort-connector-elasticsearch6/2.4.0 Java 8 Latest JAR sort-connector-elasticsearch6-2.3.0.jar in org/apache/inlong/sort-connector-elasticsearch6/2.3.0 JAR sort-connector-elasticsearch6-2.2.0.jar in org/apache/inlong/sort-connector-elasticsearch6/2.2.0 JAR sort-connector-elasticsearch6-2.1.0.jar in org/apache/inlong/sort-connector-elasticsearch6/2.1.0 JAR sort-connector-elasticsearch6-2.0.0.jar in org/apache/inlong/sort-connector-elasticsearch6/2.0.0 JAR sort-connector-elasticsearch6-1.13.0.jar in org/apache/inlong/sort-connector-elasticsearch6/1.13.0 JAR sort-connector-elasticsearch6-1.12.0.jar in org/apache/inlong/sort-connector-elasticsearch6/1.12.0 JAR sort-connector-elasticsearch6-1.11.0.jar in org/apache/inlong/sort-connector-elasticsearch6/1.11.0 JAR sort-connector-elasticsearch6-1.10.0.jar in org/apache/inlong/sort-connector-elasticsearch6/1.10.0 JAR sort-connector-elasticsearch6-1.9.0.jar in org/apache/inlong/sort-connector-elasticsearch6/1.9.0 JAR sort-connector-elasticsearch6-1.8.0.jar in org/apache/inlong/sort-connector-elasticsearch6/1.8.0 JAR sort-connector-elasticsearch6-1.7.0.jar in org/apache/inlong/sort-connector-elasticsearch6/1.7.0 JAR sort-connector-elasticsearch7-2.4.0.jar in org/apache/inlong/sort-connector-elasticsearch7/2.4.0 Java 8 Latest JAR sort-connector-elasticsearch7-2.3.0.jar in org/apache/inlong/sort-connector-elasticsearch7/2.3.0 JAR sort-connector-elasticsearch7-2.2.0.jar in org/apache/inlong/sort-connector-elasticsearch7/2.2.0 JAR sort-connector-elasticsearch7-2.1.0.jar in org/apache/inlong/sort-connector-elasticsearch7/2.1.0 JAR sort-connector-elasticsearch7-2.0.0.jar in org/apache/inlong/sort-connector-elasticsearch7/2.0.0 JAR sort-connector-elasticsearch7-1.13.0.jar in org/apache/inlong/sort-connector-elasticsearch7/1.13.0 JAR sort-connector-elasticsearch7-1.12.0.jar in org/apache/inlong/sort-connector-elasticsearch7/1.12.0 JAR sort-connector-elasticsearch7-1.11.0.jar in org/apache/inlong/sort-connector-elasticsearch7/1.11.0 JAR sort-connector-elasticsearch7-1.10.0.jar in org/apache/inlong/sort-connector-elasticsearch7/1.10.0 JAR sort-connector-elasticsearch7-1.9.0.jar in org/apache/inlong/sort-connector-elasticsearch7/1.9.0 JAR sort-connector-elasticsearch7-1.8.0.jar in org/apache/inlong/sort-connector-elasticsearch7/1.8.0 JAR sort-connector-elasticsearch7-1.7.0.jar in org/apache/inlong/sort-connector-elasticsearch7/1.7.0 JAR sort-connector-hive-2.4.0.jar in org/apache/inlong/sort-connector-hive/2.4.0 Java 8 Latest JAR sort-connector-hive-2.3.0.jar in org/apache/inlong/sort-connector-hive/2.3.0 JAR sort-connector-hive-2.2.0.jar in org/apache/inlong/sort-connector-hive/2.2.0 JAR sort-connector-hive-2.1.0.jar in org/apache/inlong/sort-connector-hive/2.1.0 JAR sort-connector-hive-2.0.0.jar in org/apache/inlong/sort-connector-hive/2.0.0 JAR sort-connector-hive-1.13.0.jar in org/apache/inlong/sort-connector-hive/1.13.0 JAR sort-connector-hive-1.12.0.jar in org/apache/inlong/sort-connector-hive/1.12.0 JAR sort-connector-hive-1.11.0.jar in org/apache/inlong/sort-connector-hive/1.11.0 JAR sort-connector-hive-1.10.0.jar in org/apache/inlong/sort-connector-hive/1.10.0 JAR sort-connector-hive-1.9.0.jar in org/apache/inlong/sort-connector-hive/1.9.0 JAR sort-connector-hive-1.7.0.jar in org/apache/inlong/sort-connector-hive/1.7.0 JAR sort-connector-hive-1.6.0.jar in org/apache/inlong/sort-connector-hive/1.6.0 JAR sort-connector-hive-1.5.0.jar in org/apache/inlong/sort-connector-hive/1.5.0 JAR sort-connector-hive-1.4.0.jar in org/apache/inlong/sort-connector-hive/1.4.0 JAR sort-connector-hive-1.3.0.jar in org/apache/inlong/sort-connector-hive/1.3.0 JAR sort-connector-jdbc-v1.18-2.4.0.jar in org/apache/inlong/sort-connector-jdbc-v1.18/2.4.0 Java 8 Latest JAR sort-connector-jdbc-v1.18-2.3.0.jar in org/apache/inlong/sort-connector-jdbc-v1.18/2.3.0 JAR sort-connector-jdbc-v1.18-2.2.0.jar in org/apache/inlong/sort-connector-jdbc-v1.18/2.2.0 JAR sort-connector-jdbc-v1.18-2.1.0.jar in org/apache/inlong/sort-connector-jdbc-v1.18/2.1.0 JAR sort-connector-jdbc-v1.18-2.0.0.jar in org/apache/inlong/sort-connector-jdbc-v1.18/2.0.0 JAR sort-connector-jdbc-v1.18-1.13.0.jar in org/apache/inlong/sort-connector-jdbc-v1.18/1.13.0 JAR sort-connector-redis-2.4.0.jar in org/apache/inlong/sort-connector-redis/2.4.0 Java 8 Latest JAR sort-connector-redis-2.3.0.jar in org/apache/inlong/sort-connector-redis/2.3.0 JAR sort-connector-redis-2.2.0.jar in org/apache/inlong/sort-connector-redis/2.2.0 JAR sort-connector-redis-2.1.0.jar in org/apache/inlong/sort-connector-redis/2.1.0 JAR sort-connector-redis-2.0.0.jar in org/apache/inlong/sort-connector-redis/2.0.0 JAR sort-connector-redis-1.13.0.jar in org/apache/inlong/sort-connector-redis/1.13.0 JAR sort-connector-redis-1.12.0.jar in org/apache/inlong/sort-connector-redis/1.12.0 JAR sort-connector-redis-1.11.0.jar in org/apache/inlong/sort-connector-redis/1.11.0 JAR sort-connector-redis-1.10.0.jar in org/apache/inlong/sort-connector-redis/1.10.0 JAR sort-connector-redis-1.9.0.jar in org/apache/inlong/sort-connector-redis/1.9.0 JAR sort-connector-redis-1.7.0.jar in org/apache/inlong/sort-connector-redis/1.7.0 JAR sort-connector-tubemq-2.4.0.jar in org/apache/inlong/sort-connector-tubemq/2.4.0 Java 8 Latest JAR sort-connector-tubemq-2.3.0.jar in org/apache/inlong/sort-connector-tubemq/2.3.0 JAR sort-connector-tubemq-2.2.0.jar in org/apache/inlong/sort-connector-tubemq/2.2.0 JAR sort-connector-tubemq-2.1.0.jar in org/apache/inlong/sort-connector-tubemq/2.1.0 JAR sort-connector-tubemq-2.0.0.jar in org/apache/inlong/sort-connector-tubemq/2.0.0 JAR sort-connector-tubemq-1.13.0.jar in org/apache/inlong/sort-connector-tubemq/1.13.0 JAR sort-connector-tubemq-1.12.0.jar in org/apache/inlong/sort-connector-tubemq/1.12.0 JAR sort-connector-tubemq-1.11.0.jar in org/apache/inlong/sort-connector-tubemq/1.11.0 JAR sort-connector-tubemq-1.10.0.jar in org/apache/inlong/sort-connector-tubemq/1.10.0 JAR sort-single-tenant-1.1.0-incubating.jar in org/apache/inlong/sort-single-tenant/1.1.0-incubating Java 8 JAR seatunnel-spark-examples-2.1.3.jar in org/apache/seatunnel/seatunnel-spark-examples/2.1.3 Java 8 Latest JAR seatunnel-spark-examples-2.1.2.jar in org/apache/seatunnel/seatunnel-spark-examples/2.1.2 JAR seatunnel-spark-examples-2.1.1.jar in org/apache/seatunnel/seatunnel-spark-examples/2.1.1 JAR seatunnel-spark-examples-2.1.0.jar in org/apache/seatunnel/seatunnel-spark-examples/2.1.0 JAR flink-cdc-connector-2026.0.0.jar in org/devlive/connector/flink-cdc-connector/2026.0.0 Java 9 Latest JAR flink-cdc-connector-2025.1.0.jar in org/devlive/connector/flink-cdc-connector/2025.1.0 Java 9 JAR lakesoul-flink-2.5.1-flink-1.17.jar in com/dmetasoul/lakesoul-flink/2.5.1-flink-1.17 Java 11 JAR statefun-smoke-e2e-driver-3.5.0.jar in com/sbbsystems/flink/statefun-smoke-e2e-driver/3.5.0 Java 22 JAR statefun-smoke-e2e-embedded-3.5.0.jar in com/sbbsystems/flink/statefun-smoke-e2e-embedded/3.5.0 Java 22 JAR flink-connector-tdengine-1.0.1-dist.jar in com/taosdata/flink/flink-connector-tdengine/1.0.1 Java 21 JAR changebook-flink-cdc-1.0.2-jar-with-dependencies.jar in io/github/changebooks/changebook-flink-cdc/1.0.2 Java 8 JAR cobble-flink-monitor-0.4.0-1-flink-1.17.jar in io/github/cobble-project/cobble-flink-monitor/0.4.0-1-flink-1.17 Java 9 JAR flink-clients-scastie_2.13-1.19.1.jar in io/github/novakov-alexey/flink-clients-scastie_2.13/1.19.1 Java 8 JAR flink-clients-scastie_3-1.19.1.jar in io/github/novakov-alexey/flink-clients-scastie_3/1.19.1 Java 8 JAR flinkify-flink-core-0.2.2.jar in io/github/regychang/flinkify-flink-core/0.2.2 Java 17 JAR nussknacker-flink-manager_2.12-1.18.1-assembly.jar in pl/touk/nussknacker/nussknacker-flink-manager_2.12/1.18.1 Java 8 JAR nussknacker-flink-manager_2.13-1.18.1-assembly.jar in pl/touk/nussknacker/nussknacker-flink-manager_2.13/1.18.1 Java 22 JAR nussknacker-flink-periodic-manager_2.12-1.18.1-assembly.jar in pl/touk/nussknacker/nussknacker-flink-periodic-manager_2.12/1.18.1 Java 8 JAR nussknacker-flink-periodic-manager_2.13-1.18.1-assembly.jar in pl/touk/nussknacker/nussknacker-flink-periodic-manager_2.13/1.18.1 Java 22 JAR nussknacker-flink-table-components_2.12-1.18.1-assembly.jar in pl/touk/nussknacker/nussknacker-flink-table-components_2.12/1.18.1 Java 11 JAR nussknacker-flink-table-components_2.13-1.18.1-assembly.jar in pl/touk/nussknacker/nussknacker-flink-table-components_2.13/1.18.1 Java 11 JAR flink-sql-jdbc-driver-bundle-2.3.0-EXNESS-0.2.Final.jar in com/exness/flink-sql-jdbc-driver-bundle/2.3.0-EXNESS-0.2.Final Java 21 Latest JAR flink-sql-jdbc-driver-bundle-2.2.0-EXNESS-0.1.Final.jar in com/exness/flink-sql-jdbc-driver-bundle/2.2.0-EXNESS-0.1.Final JAR MappingWeaver-0.3.0.jar in be/ugent/idlab/knows/MappingWeaver/0.3.0 Java 22 JAR fluss-lakehouse-cli-0.6.1.jar in com/alibaba/fluss/fluss-lakehouse-cli/0.6.1 Java 8 JAR arctic-optimizer-0.4.0-jar-with-dependencies.jar in com/netease/arctic/arctic-optimizer/0.4.0 Java 9 JAR plugin-beam-1.2.6.jar in io/kestra/plugin/plugin-beam/1.2.6 Java 24 Latest JAR plugin-beam-1.2.5.jar in io/kestra/plugin/plugin-beam/1.2.5 Java 24 JAR plugin-beam-1.2.4.jar in io/kestra/plugin/plugin-beam/1.2.4 JAR sansa-examples-flink_2.11-0.7.1-jar-with-dependencies.jar in net/sansa-stack/sansa-examples-flink_2.11/0.7.1 Java 11 Latest JAR sansa-examples-flink_2.11-0.6.0-jar-with-dependencies.jar in net/sansa-stack/sansa-examples-flink_2.11/0.6.0 Java 8