mozilla / gcp-ingestion
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 4% | 36% | 24% | 35%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 5% | 33% | 24% | 36%
py0% | 0% | 63% | 19% | 17%
in0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
ingestion-core0% | 34% | 0% | 40% | 24%
ingestion-beam0% | 0% | 38% | 20% | 40%
ingestion-edge0% | 0% | 61% | 18% | 19%
ingestion-sink0% | 0% | 41% | 26% | 31%
custom_docs_theme0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
PubsubMessageToObjectNode.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform
534 46
SinkConfig.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/config
454 30
flush_manager.py
in ingestion-edge/ingestion_edge
437 14
MessageScrubber.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
424 13
Write.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/io
421 13
ParseReportingUrl.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
414 19
ParsePayload.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
374 15
GuidedJsonDecoder.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/avro
295 29
ParseUri.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
278 16
pubsub_emulator.py
in ingestion-edge
254 16
SinkOptions.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/options
237 3
ParseAmplitudeEvents.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude
236 8
GeoCityLookup.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
203 9
BigQuery.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io
201 21
PipelineMetadataStore.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/schema
189 12
ParseUserAgent.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
186 7
BatchWrite.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/util
174 6
NestedMetadata.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform
171 14
Read.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/io
159 8
KeyByBigQueryTableDestination.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
142 4
SchemaStore.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/schema
139 10
HashClientInfo.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ipprivacy
134 5
SendRequest.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude
129 6
AmplitudeEvent.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude
128 3
LabelSpikes.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
127 6
Gcs.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io
124 11
Pubsub.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io
123 9
NormalizeAttributes.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
122 9
PubsubMessageToTableRow.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
122 16
Json.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/util
118 17
GeoIspLookup.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
114 7
publish.py
in ingestion-edge/ingestion_edge
109 4
FilterByDocType.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
105 6
DynamicPathTemplate.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/util
102 6
flush.py
in ingestion-edge/ingestion_edge
102 4
SendRequest.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
100 4
ErrorOutputType.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/options
97 7
AmplitudePublisher.java
in ingestion-beam/src/main/java/com/mozilla/telemetry
95 4
PubsubConstraints.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
88 7
BigQuerySchemaStore.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/schema
88 8
ExtractClientIdAndDropPayload.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ipprivacy
87 3
Constant.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core
87 4
SponsoredInteraction.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
86 3
ContextualServicesReporter.java
in ingestion-beam/src/main/java/com/mozilla/telemetry
84 3
BuildReportingUrl.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
82 7
RepublishPerChannel.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/republisher
80 8
ParseLogEntry.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
80 1
FailureMessage.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
80 9
AggregateImpressions.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
79 5
RepublishPerDocType.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/republisher
75 7
Files With Most Units (Top 50)
File# lines# units
PubsubMessageToObjectNode.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform
534 46
SinkConfig.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/config
454 30
GuidedJsonDecoder.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/avro
295 29
BigQuery.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io
201 21
ParseReportingUrl.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
414 19
Json.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/util
118 17
ParseUri.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
278 16
PubsubMessageToTableRow.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
122 16
pubsub_emulator.py
in ingestion-edge
254 16
ParsePayload.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
374 15
NestedMetadata.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/transform
171 14
flush_manager.py
in ingestion-edge/ingestion_edge
437 14
Env.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/util
72 14
MessageScrubber.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
424 13
Write.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/io
421 13
PipelineMetadataStore.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/schema
189 12
Gcs.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io
124 11
SchemaStore.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/schema
139 10
GeoCityLookup.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
203 9
NormalizeAttributes.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
122 9
FailureMessage.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
80 9
Pubsub.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io
123 9
RepublishPerChannel.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/republisher
80 8
ParseAmplitudeEvents.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude
236 8
OutputType.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/options
62 8
Read.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/io
159 8
Json.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/util
70 8
BigQuerySchemaStore.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/schema
88 8
RepublishPerDocType.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/republisher
75 7
RepublishPerNamespace.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/republisher
66 7
ParseUserAgent.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
186 7
GeoIspLookup.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
114 7
ErrorOutputType.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/options
97 7
PubsubConstraints.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
88 7
BuildReportingUrl.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
82 7
DerivedAttributesMap.java
in ingestion-core/src/main/java/com/mozilla/telemetry/ingestion/core/util
56 7
Pipe.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io
65 7
PubsubMessageToTemplatedString.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/transform
66 7
SendRequest.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude
129 6
FilterByDocType.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude
63 6
LabelSpikes.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
127 6
FilterByDocType.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/contextualservices
105 6
DynamicPathTemplate.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/util
102 6
BatchWrite.java
in ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/util
174 6
ParseProxy.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
74 5
HashClientInfo.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder/ipprivacy
134 5
SanitizeAttributes.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/decoder
62 5
InputType.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/options
36 5
OutputFileFormat.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/options
37 5
DecompressPayload.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/transforms
64 5
Files With Long Lines (Top 3)

There are 3 files with lines longer than 120 characters. In total, there are 4 long lines.

File# lines# units# long lines
SendRequest.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/amplitude
129 6 2
SinkOptions.java
in ingestion-beam/src/main/java/com/mozilla/telemetry/options
237 3 1
in
requirements.in
in ingestion-edge
31 - 1