Path	Lines of Code
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/Sink.java	10
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/config/SinkConfig.java	454
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io/BigQuery.java	201
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io/Gcs.java	124
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io/Input.java	6
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io/Pipe.java	65
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io/Pubsub.java	123
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io/PubsubLite.java	48
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/io/WriteWithErrors.java	32
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/transform/BlobIdToPubsubMessage.java	14
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/transform/BlobIdToString.java	7
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/transform/CompressPayload.java	33
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/transform/DecompressPayload.java	31
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/transform/DocumentTypePredicate.java	31
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/transform/PubsubMessageToTemplatedString.java	66
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/transform/StringToPubsubMessage.java	39
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/util/BatchException.java	22
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/util/BatchWrite.java	174
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/util/Env.java	72
ingestion-sink/src/main/java/com/mozilla/telemetry/ingestion/sink/util/TimedFuture.java	16
ingestion-sink/src/main/resources/log4j2.yaml	13