Merge pull request #617 from j3-signalroom/615-refactor-the-code-to-d…

…ynamically-create-the-select-by-retrieving-the-columns-from-the-kafka-topic-schema-and-then-use-functional-programming-techniques-to-build-a-compound-expression-to-filter-non-null-values

Resolved #615.

python_ccaf/src/kickstarter/avro_flight_consolidator_ccaf_app.py

@@ -1,4 +1,4 @@
-from pyflink.table import (TableEnvironment, Schema, DataTypes, FormatDescriptor)
+from pyflink.table import TableEnvironment, Schema, DataTypes, FormatDescriptor
 from pyflink.table.catalog import ObjectPath
 from pyflink.table.confluent import ConfluentSettings, ConfluentTableDescriptor
 from pyflink.table.expressions import col, lit