Path	Lines of Code
flink-python/MANIFEST.in	33
flink-python/dev/glibc_version_fix.h	1
flink-python/dev/pip_test_code.py	29
flink-python/pyflink/__init__.py	12
flink-python/pyflink/common/__init__.py	23
flink-python/pyflink/common/completable_future.py	28
flink-python/pyflink/common/configuration.py	69
flink-python/pyflink/common/execution_config.py	167
flink-python/pyflink/common/execution_mode.py	37
flink-python/pyflink/common/input_dependency_constraint.py	30
flink-python/pyflink/common/job_client.py	30
flink-python/pyflink/common/job_execution_result.py	19
flink-python/pyflink/common/job_id.py	6
flink-python/pyflink/common/job_status.py	77
flink-python/pyflink/common/restart_strategy.py	141
flink-python/pyflink/common/serialization_schemas.py	180
flink-python/pyflink/common/typeinfo.py	298
flink-python/pyflink/dataset/__init__.py	2
flink-python/pyflink/dataset/execution_environment.py	48
flink-python/pyflink/datastream/__init__.py	20
flink-python/pyflink/datastream/checkpoint_config.py	88
flink-python/pyflink/datastream/checkpointing_mode.py	29
flink-python/pyflink/datastream/data_stream.py	410
flink-python/pyflink/datastream/functions.py	86
flink-python/pyflink/datastream/state_backend.py	230
flink-python/pyflink/datastream/stream_execution_environment.py	209
flink-python/pyflink/datastream/time_characteristic.py	33
flink-python/pyflink/find_flink_home.py	40
flink-python/pyflink/fn_execution/ResettableIO.py	33
flink-python/pyflink/fn_execution/__init__.py	1
flink-python/pyflink/fn_execution/beam/__init__.py	1
flink-python/pyflink/fn_execution/beam/beam_boot.py	55
flink-python/pyflink/fn_execution/beam/beam_coder_impl_fast.pxd	10
flink-python/pyflink/fn_execution/beam/beam_coder_impl_fast.pyx	27
flink-python/pyflink/fn_execution/beam/beam_coder_impl_slow.py	403
flink-python/pyflink/fn_execution/beam/beam_coders.py	173
flink-python/pyflink/fn_execution/beam/beam_operations_fast.pxd	19
flink-python/pyflink/fn_execution/beam/beam_operations_fast.pyx	145
flink-python/pyflink/fn_execution/beam/beam_operations_slow.py	125
flink-python/pyflink/fn_execution/beam/beam_sdk_worker_main.py	9
flink-python/pyflink/fn_execution/beam/beam_stream.pxd	16
flink-python/pyflink/fn_execution/beam/beam_stream.pyx	69
flink-python/pyflink/fn_execution/coder_impl_fast.pxd	132
flink-python/pyflink/fn_execution/coder_impl_fast.pyx	649
flink-python/pyflink/fn_execution/coders.py	281
flink-python/pyflink/fn_execution/operation_utils.py	100
flink-python/pyflink/fn_execution/stream.pxd	6
flink-python/pyflink/fn_execution/stream.pyx	10
flink-python/pyflink/gen_protos.py	143
flink-python/pyflink/java_gateway.py	113
flink-python/pyflink/metrics/__init__.py	2
flink-python/pyflink/metrics/metricbase.py	101
flink-python/pyflink/ml/__init__.py	1
flink-python/pyflink/ml/api/__init__.py	8
flink-python/pyflink/ml/api/base.py	153
flink-python/pyflink/ml/api/ml_environment.py	27
flink-python/pyflink/ml/api/ml_environment_factory.py	55
flink-python/pyflink/ml/api/param/__init__.py	2
flink-python/pyflink/ml/api/param/base.py	151
flink-python/pyflink/ml/lib/__init__.py	1
flink-python/pyflink/ml/lib/param/__init__.py	2
flink-python/pyflink/ml/lib/param/colname.py	31
flink-python/pyflink/proto/flink-fn-execution.proto	183
flink-python/pyflink/pyflink_callback_server.py	11
flink-python/pyflink/pyflink_gateway_server.py	160
flink-python/pyflink/serializers.py	104
flink-python/pyflink/shell.py	114
flink-python/pyflink/table/__init__.py	47
flink-python/pyflink/table/catalog.py	406
flink-python/pyflink/table/descriptors.py	607
flink-python/pyflink/table/environment_settings.py	41
flink-python/pyflink/table/explain_detail.py	4
flink-python/pyflink/table/module.py	13
flink-python/pyflink/table/result_kind.py	15
flink-python/pyflink/table/serializers.py	49
flink-python/pyflink/table/sinks.py	29
flink-python/pyflink/table/sources.py	44
flink-python/pyflink/table/sql_dialect.py	26
flink-python/pyflink/table/statement_set.py	19
flink-python/pyflink/table/table.py	159
flink-python/pyflink/table/table_config.py	80
flink-python/pyflink/table/table_environment.py	542
flink-python/pyflink/table/table_result.py	19
flink-python/pyflink/table/table_schema.py	61
flink-python/pyflink/table/types.py	1495
flink-python/pyflink/table/udf.py	186
flink-python/pyflink/table/utils.py	32
flink-python/pyflink/table/window.py	95
flink-python/pyflink/testing/__init__.py	1
flink-python/pyflink/testing/source_sink_utils.py	69
flink-python/pyflink/util/__init__.py	1
flink-python/pyflink/util/exceptions.py	83
flink-python/pyflink/util/utils.py	85
flink-python/pyflink/version.py	1
flink-python/setup.cfg	4
flink-python/setup.py	272
flink-python/src/main/java/org/apache/beam/runners/fnexecution/state/GrpcStateService.java	118
flink-python/src/main/java/org/apache/flink/api/common/python/PythonBridgeUtils.java	147
flink-python/src/main/java/org/apache/flink/api/common/python/pickle/ArrayConstructor.java	18
flink-python/src/main/java/org/apache/flink/api/common/python/pickle/ByteArrayConstructor.java	12
flink-python/src/main/java/org/apache/flink/client/cli/PythonProgramOptions.java	61
flink-python/src/main/java/org/apache/flink/client/python/PythonDriver.java	67
flink-python/src/main/java/org/apache/flink/client/python/PythonDriverOptions.java	33
flink-python/src/main/java/org/apache/flink/client/python/PythonDriverOptionsParserFactory.java	36
flink-python/src/main/java/org/apache/flink/client/python/PythonEnvUtils.java	234
flink-python/src/main/java/org/apache/flink/client/python/PythonFunctionFactory.java	124
flink-python/src/main/java/org/apache/flink/client/python/PythonGatewayServer.java	67
flink-python/src/main/java/org/apache/flink/client/python/PythonShellParser.java	228
flink-python/src/main/java/org/apache/flink/datastream/runtime/functions/python/DataStreamPythonFunction.java	23
flink-python/src/main/java/org/apache/flink/datastream/runtime/functions/python/DataStreamPythonFunctionInfo.java	18
flink-python/src/main/java/org/apache/flink/datastream/runtime/functions/python/PickledKeySelector.java	23
flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonReduceFunctionOperator.java	82
flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamPythonStatelessFunctionOperator.java	118
flink-python/src/main/java/org/apache/flink/datastream/runtime/operators/python/DataStreamTwoInputPythonStatelessFunctionOperator.java	163
flink-python/src/main/java/org/apache/flink/datastream/runtime/runners/python/beam/BeamDataStreamPythonStatelessFunctionRunner.java	57
flink-python/src/main/java/org/apache/flink/datastream/runtime/typeutils/python/PythonTypeUtils.java	237
flink-python/src/main/java/org/apache/flink/datastream/typeinfo/python/PickledByteArrayTypeInfo.java	54
flink-python/src/main/java/org/apache/flink/python/PythonConfig.java	86
flink-python/src/main/java/org/apache/flink/python/PythonFunctionRunner.java	11
flink-python/src/main/java/org/apache/flink/python/PythonOptions.java	109
flink-python/src/main/java/org/apache/flink/python/env/ProcessPythonEnvironment.java	18
flink-python/src/main/java/org/apache/flink/python/env/PythonDependencyInfo.java	77
flink-python/src/main/java/org/apache/flink/python/env/PythonEnvironment.java	5
flink-python/src/main/java/org/apache/flink/python/env/PythonEnvironmentManager.java	10
flink-python/src/main/java/org/apache/flink/python/env/beam/ProcessPythonEnvironmentManager.java	259
flink-python/src/main/java/org/apache/flink/python/metric/FlinkMetricContainer.java	205
flink-python/src/main/java/org/apache/flink/python/util/PythonConfigUtil.java	90
flink-python/src/main/java/org/apache/flink/python/util/PythonDependencyUtils.java	174
flink-python/src/main/java/org/apache/flink/python/util/PythonEnvironmentManagerUtils.java	160
flink-python/src/main/java/org/apache/flink/python/util/ZipUtils.java	84
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractOneInputPythonFunctionOperator.java	18
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractPythonFunctionOperatorBase.java	208
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/AbstractTwoInputPythonFunctionOperator.java	18
flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonFunctionRunner.java	187
flink-python/src/main/java/org/apache/flink/streaming/api/runners/python/beam/BeamPythonStatelessFunctionRunner.java	130
flink-python/src/main/java/org/apache/flink/table/descriptors/python/CustomFormatDescriptor.java	25
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowReader.java	6
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowUtils.java	783
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/ArrowWriter.java	34
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/ArrayFieldReader.java	50
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/ArrowFieldReader.java	15
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/BigIntFieldReader.java	13
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/BooleanFieldReader.java	13
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/DateFieldReader.java	19
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/DecimalFieldReader.java	14
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/DoubleFieldReader.java	13
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/FloatFieldReader.java	13
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/IntFieldReader.java	13
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/RowArrowReader.java	24
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/RowFieldReader.java	25
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/SmallIntFieldReader.java	13
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/TimeFieldReader.java	41
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/TimestampFieldReader.java	38
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/TinyIntFieldReader.java	13
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/VarBinaryFieldReader.java	13
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/readers/VarCharFieldReader.java	19
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/serializers/ArrowSerializer.java	68
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/serializers/RowArrowSerializer.java	24
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/serializers/RowDataArrowSerializer.java	24
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/AbstractArrowSourceFunction.java	143
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/AbstractArrowTableSource.java	27
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/ArrowSourceFunction.java	26
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/ArrowTableSource.java	16
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/RowArrowSourceFunction.java	26
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/sources/RowArrowTableSource.java	16
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowArrayColumnVector.java	28
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowBigIntColumnVector.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowBooleanColumnVector.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowDateColumnVector.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowDecimalColumnVector.java	21
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowDoubleColumnVector.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowFloatColumnVector.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowIntColumnVector.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowRowColumnVector.java	26
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowSmallIntColumnVector.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowTimeColumnVector.java	37
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowTimestampColumnVector.java	38
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowTinyIntColumnVector.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowVarBinaryColumnVector.java	21
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/ArrowVarCharColumnVector.java	21
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/vectors/RowDataArrowReader.java	26
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/ArrayWriter.java	69
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/ArrowFieldWriter.java	30
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/BigIntWriter.java	53
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/BooleanWriter.java	55
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/DateWriter.java	53
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/DecimalWriter.java	66
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/DoubleWriter.java	53
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/FloatWriter.java	53
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/IntWriter.java	53
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowArrayWriter.java	34
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowBigIntWriter.java	18
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowBooleanWriter.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowDateWriter.java	21
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowDecimalWriter.java	30
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowDoubleWriter.java	18
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowFloatWriter.java	18
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowIntWriter.java	18
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowRowWriter.java	42
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowSmallIntWriter.java	18
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowTimeWriter.java	45
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowTimestampWriter.java	39
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowTinyIntWriter.java	18
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowVarBinaryWriter.java	18
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowVarCharWriter.java	20
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/RowWriter.java	78
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/SmallIntWriter.java	53
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/TimeWriter.java	71
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/TimestampWriter.java	74
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/TinyIntWriter.java	53
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/VarBinaryWriter.java	53
flink-python/src/main/java/org/apache/flink/table/runtime/arrow/writers/VarCharWriter.java	54
flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/AbstractPythonScalarFunctionFlatMap.java	74
flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/AbstractPythonStatelessFunctionFlatMap.java	216
flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/PythonScalarFunctionFlatMap.java	55
flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/PythonTableFunctionFlatMap.java	116
flink-python/src/main/java/org/apache/flink/table/runtime/functions/python/arrow/ArrowPythonScalarFunctionFlatMap.java	84
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/AbstractStatelessFunctionOperator.java	152
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/AbstractPythonScalarFunctionOperator.java	57
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/AbstractRowDataPythonScalarFunctionOperator.java	74
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/AbstractRowPythonScalarFunctionOperator.java	54
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/PythonScalarFunctionOperator.java	50
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/RowDataPythonScalarFunctionOperator.java	50
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/ArrowPythonScalarFunctionOperator.java	91
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/scalar/arrow/RowDataArrowPythonScalarFunctionOperator.java	90
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/AbstractPythonTableFunctionOperator.java	65
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/PythonTableFunctionOperator.java	91
flink-python/src/main/java/org/apache/flink/table/runtime/operators/python/table/RowDataPythonTableFunctionOperator.java	103
flink-python/src/main/java/org/apache/flink/table/runtime/runners/python/beam/BeamTablePythonStatelessFunctionRunner.java	60
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/PythonTypeUtils.java	455
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/ArrayDataSerializer.java	129
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/BigDecSerializer.java	66
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DateSerializer.java	71
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/DecimalDataSerializer.java	131
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/MapDataSerializer.java	166
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/RowDataSerializer.java	164
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/StringSerializer.java	73
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/TimeSerializer.java	82
flink-python/src/main/java/org/apache/flink/table/runtime/typeutils/serializers/python/TimestampSerializer.java	143