[FLINK-12440][python] Add all connector support align Java Table API.

This closes apache#8531
mbalassi · May 31, 2019 · 836fdff · 836fdff
1 parent 809e40d
commit 836fdff
Show file tree

Hide file tree

Showing 5 changed files with 883 additions and 17 deletions.
diff --git a/flink-dist/src/main/flink-bin/bin/pyflink-gateway-server.sh b/flink-dist/src/main/flink-bin/bin/pyflink-gateway-server.sh
@@ -63,7 +63,7 @@ if [[ -n "$FLINK_TESTING" ]]; then
  else
  FLINK_TEST_CLASSPATH="$FLINK_TEST_CLASSPATH":"$testJarFile"
  fi
- done < <(find "$FLINK_SOURCE_ROOT_DIR" ! -type d -name 'flink-*-tests.jar' -print0 | sort -z)
+ done < <(find "$FLINK_SOURCE_ROOT_DIR" ! -type d \( -name 'flink-*-tests.jar' -o -path "${FLINK_SOURCE_ROOT_DIR}/flink-connectors/flink-connector-elasticsearch-base/target/flink*.jar" -o -path "${FLINK_SOURCE_ROOT_DIR}/flink-connectors/flink-connector-kafka-base/target/flink*.jar" \) -print0 | sort -z)
 fi
 
 exec $JAVA_RUN $JVM_ARGS "${log_setting[@]}" -cp ${FLINK_CLASSPATH}:${TABLE_JAR_PATH}:${FLINK_TEST_CLASSPATH} ${DRIVER} ${ARGS[@]}
diff --git a/flink-python/pyflink/table/__init__.py b/flink-python/pyflink/table/__init__.py
@@ -40,7 +40,7 @@
 from pyflink.table.table_source import TableSource, CsvTableSource
 from pyflink.table.types import DataTypes, UserDefinedType, Row
 from pyflink.table.window import Tumble, Session, Slide, Over
-from pyflink.table.table_descriptor import Rowtime, Schema, OldCsv, FileSystem
+from pyflink.table.table_descriptor import Rowtime, Schema, OldCsv, FileSystem, Kafka, Elasticsearch
 
 __all__ = [
  'TableEnvironment',
@@ -63,4 +63,6 @@
  'FileSystem',
  'UserDefinedType',
  'Row',
+ 'Kafka',
+ 'Elasticsearch'
 ]