path # lines of code pyproject.toml 6 setup.py 8 transcoder/__init__.py 2 transcoder/main.py 144 transcoder/Transcoder.py 184 transcoder/source/Source.py 19 transcoder/source/__init__.py 1 transcoder/source/file/__init__.py 5 transcoder/source/file/FileMessageSource.py 39 transcoder/source/file/PcapFileMessageSource.py 27 transcoder/source/file/CmeBinaryPacketFileMessageSource.py 48 transcoder/source/file/LengthDelimitedFileMessageSource.py 33 transcoder/source/file/LineDelimitedFileMessageSource.py 34 transcoder/source/LineEncoding.py 12 transcoder/source/SourceUtil.py 43 transcoder/version.py 1 transcoder/output/__init__.py 2 transcoder/output/json/JsonOutputManager.py 54 transcoder/output/json/__init__.py 1 transcoder/output/exception/PubSubTopicSchemaOutOfSyncError.py 1 transcoder/output/exception/__init__.py 5 transcoder/output/exception/OutputNotAvailableError.py 1 transcoder/output/exception/OutputManagerSchemaError.py 1 transcoder/output/exception/OutputFunctionNotDefinedError.py 1 transcoder/output/exception/BigQueryTableSchemaOutOfSyncError.py 1 transcoder/output/google_cloud/__init__.py 2 transcoder/output/google_cloud/PubSubOutputManager.py 207 transcoder/output/google_cloud/terraform/__init__.py 2 transcoder/output/google_cloud/terraform/GcpTerraformOutputManager.py 26 transcoder/output/google_cloud/terraform/BigQueryTerraformOutputManager.py 34 transcoder/output/google_cloud/terraform/PubSubTerraformOutputManager.py 26 transcoder/output/google_cloud/BigQueryOutputManager.py 100 transcoder/output/google_cloud/Constants.py 3 transcoder/output/diag/__init__.py 1 transcoder/output/diag/DiagnosticOutputManager.py 8 transcoder/output/length_delimited/__init__.py 1 transcoder/output/length_delimited/LengthDelimitedOutputManager.py 22 transcoder/output/OutputManager.py 68 transcoder/output/avro/__init__.py 2 transcoder/output/avro/AvroOutputManager.py 20 transcoder/output/avro/BaseAvroOutputManager.py 38 transcoder/output/avro/FastAvroOutputManager.py 16 transcoder/output/OutputUtil.py 57 transcoder/message/handler/__init__.py 4 transcoder/message/handler/MessageHandlerIntField.py 11 transcoder/message/handler/TimestampPullForwardHandler.py 20 transcoder/message/handler/MessageHandler.py 15 transcoder/message/handler/MessageHandlerFloatField.py 11 transcoder/message/handler/FilterHandler.py 24 transcoder/message/handler/MessageHandlerStringField.py 11 transcoder/message/handler/CmeBinaryPacketHandler.py 22 transcoder/message/handler/SequencerHandler.py 20 transcoder/message/NoParser.py 9 transcoder/message/__init__.py 2 transcoder/message/DatacastParser.py 74 transcoder/message/exception/__init__.py 2 transcoder/message/exception/MessageParserNotDefinedError.py 1 transcoder/message/exception/ParserFunctionNotDefinedError.py 1 transcoder/message/ParsedMessage.py 10 transcoder/message/factory/MessageFactory.py 16 transcoder/message/factory/__init__.py 8 transcoder/message/factory/MemxMessageFactory.py 12 transcoder/message/factory/CmeMessageFactory.py 12 transcoder/message/factory/exception/TemplateSchemaNotDefinedError.py 1 transcoder/message/factory/exception/__init__.py 1 transcoder/message/factory/exception/FactoryNotFoundError.py 1 transcoder/message/factory/ITCHMessageFactory.py 14 transcoder/message/factory/MDPMessageFactory.py 12 transcoder/message/MessageUtil.py 33 transcoder/message/DatacastGroup.py 48 transcoder/message/DatacastField.py 11 transcoder/message/DatacastSchema.py 6 transcoder/message/ErrorWriter.py 65 setup.cfg 55