path	# lines of code	# active days	days since first update	days since last update	# commits	# contributors	first updated	last updated	first contributor	last contributor
flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink/PubSubExample.java	69	5	574	381	5	3	2023-10-09	2024-04-19	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util/EmulatorEndpoint.java	20	3	417	381	4	2	2024-03-14	2024-04-19	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSource.java	183	12	606	341	17	4	2023-09-07	2024-05-29	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubDeserializationSchema.java	28	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSerializationSchema.java	23	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink/PubSubFlushablePublisher.java	28	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink/PubSubPublisherCache.java	29	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink/PubSubSinkWriter.java	24	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink/FlushablePublisher.java	6	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator/PubSubCheckpointSerializer.java	19	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator/PubSubSplitEnumerator.java	69	4	606	391	4	3	2023-09-07	2024-04-09	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split/SubscriptionSplit.java	31	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split/SubscriptionSplitSerializer.java	19	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split/SubscriptionSplitState.java	10	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/NotifyingPullSubscriber.java	10	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSplitReader.java	103	4	606	438	5	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubSourceReader.java	56	3	606	341	3	3	2023-09-07	2024-05-29	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubRecordEmitter.java	31	3	606	341	3	3	2023-09-07	2024-05-29	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubAckTracker.java	54	5	606	341	5	3	2023-09-07	2024-05-29	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/PubSubNotifyingPullSubscriber.java	105	6	606	341	7	4	2023-09-07	2024-05-29	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader/AckTracker.java	9	5	606	341	5	3	2023-09-07	2024-05-29	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/PubSubSink.java	84	7	606	381	10	4	2023-09-07	2024-04-19	mattkwong@google.com	matt-kwong@users.noreply.github.com
flink-connector/flink-connector-gcp-pubsub/src/main/proto/split.proto	32	2	606	438	2	2	2023-09-07	2024-02-22	mattkwong@google.com	52459909+hannahrogers-google@users.noreply.github.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/SqlStreamingOptions.java	4	3	1483	1412	4	3	2021-04-13	2021-06-23	dpcollins@google.com	samarth.singal@gmail.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/Compiler.java	66	3	1531	1503	4	2	2021-02-24	2021-03-24	dpcollins@google.com	dpcollins@google.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/RunPipeline.java	39	5	1510	1412	6	3	2021-03-17	2021-06-23	dpcollins@google.com	samarth.singal@gmail.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TemplateMain.java	13	5	1510	1412	7	3	2021-03-17	2021-06-23	dpcollins@google.com	samarth.singal@gmail.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/UITemplateMain.java	14	3	1483	1412	4	3	2021-04-13	2021-06-23	dpcollins@google.com	samarth.singal@gmail.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TableLoader.java	17	3	1531	1503	4	2	2021-02-24	2021-03-24	dpcollins@google.com	dpcollins@google.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TableSpec.java	38	6	1531	1412	8	3	2021-02-24	2021-06-23	dpcollins@google.com	samarth.singal@gmail.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/Rows.java	27	3	1531	1503	4	2	2021-02-24	2021-03-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSqlSource.java	20	3	1531	1503	5	2	2021-02-24	2021-03-24	dpcollins@google.com	dpcollins@google.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSource.java	10	2	1510	1503	3	2	2021-03-17	2021-03-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSinkProvider.java	5	3	1531	1503	4	2	2021-02-24	2021-03-24	dpcollins@google.com	dpcollins@google.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/PubsubLiteProvider.java	36	3	1531	1503	7	2	2021-02-24	2021-03-24	dpcollins@google.com	dpcollins@google.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/KafkaProvider.java	68	3	1531	1503	5	2	2021-02-24	2021-03-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/CloudPubsubProvider.java	94	4	1531	1503	7	2	2021-02-24	2021-03-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSourceProvider.java	5	3	1531	1503	4	2	2021-02-24	2021-03-24	dpcollins@google.com	dpcollins@google.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/BigQueryProvider.java	14	3	1531	1503	5	2	2021-02-24	2021-03-24	dpcollins@google.com	dpcollins@google.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSink.java	9	2	1510	1503	3	2	2021-03-17	2021-03-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/StandardSqlSink.java	20	3	1531	1503	3	2	2021-02-24	2021-03-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers/package-info.java	2	2	1510	1503	2	2	2021-03-17	2021-03-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/MakePtransform.java	18	2	1510	1503	3	2	2021-03-17	2021-03-24	dpcollins@google.com	dpcollins@google.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/TemplateOptions.java	31	3	1483	1412	4	3	2021-04-13	2021-06-23	dpcollins@google.com	samarth.singal@gmail.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/UITemplateOptions.java	13	3	1483	1412	4	3	2021-04-13	2021-06-23	dpcollins@google.com	samarth.singal@gmail.com
sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/package-info.java	2	2	1531	1503	2	2	2021-02-24	2021-03-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/ProberStarter.java	156	5	1671	1113	6	4	2020-10-07	2022-04-18	kamal.aboulhosn@gmail.com	74616323+amfisher-404@users.noreply.github.com
ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/Prober.java	616	7	1671	824	8	3	2020-10-07	2023-02-01	kamal.aboulhosn@gmail.com	kamal.aboulhosn@gmail.com
ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober/OrderedProber.java	272	1	1671	1671	1	1	2020-10-07	2020-10-07	kamal.aboulhosn@gmail.com	kamal.aboulhosn@gmail.com
kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorCredentialsProvider.java	29	1	2348	2348	1	1	2018-11-30	2018-11-30	htn@aiven.io	htn@aiven.io
kafka-connector/src/main/java/com/google/pubsub/kafka/common/ConnectorUtils.java	35	17	3157	1384	26	12	2016-09-12	2021-07-21	kamal.aboulhosn@gmail.com	dpcollins@google.com
kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkTask.java	402	25	3157	1384	37	13	2016-09-12	2021-07-21	kamal.aboulhosn@gmail.com	dpcollins@google.com
kafka-connector/src/main/java/com/google/pubsub/kafka/sink/CloudPubSubSinkConnector.java	218	16	3157	1384	19	11	2016-09-12	2021-07-21	kamal.aboulhosn@gmail.com	samarth.singal@gmail.com
kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubRoundRobinSubscriber.java	39	7	3157	1505	8	5	2016-09-12	2021-03-22	kamal.aboulhosn@gmail.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceTask.java	325	38	3157	1384	52	18	2016-09-12	2021-07-21	kamal.aboulhosn@gmail.com	dpcollins@google.com
kafka-connector/src/main/java/com/google/pubsub/kafka/source/AckBatchingSubscriber.java	80	4	1511	1384	5	2	2021-03-16	2021-07-21	dpcollins@google.com	dpcollins@google.com
kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubGRPCSubscriber.java	82	9	3157	1384	11	5	2016-09-12	2021-07-21	kamal.aboulhosn@gmail.com	dpcollins@google.com
kafka-connector/src/main/java/com/google/pubsub/kafka/source/StreamingPullSubscriber.java	139	3	1518	1505	3	2	2021-03-09	2021-03-22	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSourceConnector.java	281	19	3157	1384	25	10	2016-09-12	2021-07-21	kamal.aboulhosn@gmail.com	dpcollins@google.com
kafka-connector/src/main/java/com/google/pubsub/kafka/source/CloudPubSubSubscriber.java	11	4	3157	1505	4	3	2016-09-12	2021-03-22	kamal.aboulhosn@gmail.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsub/kafka/source/StreamingPullSubscriberFactory.java	6	2	1518	1505	2	2	2021-03-09	2021-03-22	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactoryImpl.java	31	1	1623	1623	1	1	2020-11-24	2020-11-24	40498610+dpcollins-google@users.noreply.github.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Schemas.java	123	1	1623	1623	1	1	2020-11-24	2020-11-24	40498610+dpcollins-google@users.noreply.github.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PublisherFactory.java	7	1	1623	1623	1	1	2020-11-24	2020-11-24	40498610+dpcollins-google@users.noreply.github.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/Constants.java	9	1	1623	1623	1	1	2020-11-24	2020-11-24	40498610+dpcollins-google@users.noreply.github.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/ConfigDefs.java	19	1	1623	1623	1	1	2020-11-24	2020-11-24	40498610+dpcollins-google@users.noreply.github.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkTask.java	117	1	1623	1623	1	1	2020-11-24	2020-11-24	40498610+dpcollins-google@users.noreply.github.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/sink/PubSubLiteSinkConnector.java	33	4	1632	1623	6	2	2020-11-15	2020-11-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PubSubLiteSourceConnector.java	34	2	1628	1623	3	2	2020-11-19	2020-11-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerFactory.java	5	2	1628	1623	3	2	2020-11-19	2020-11-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/source/ConfigDefs.java	41	2	1628	1623	3	2	2020-11-19	2020-11-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerImpl.java	61	2	1628	1623	3	2	2020-11-19	2020-11-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PollerFactoryImpl.java	34	2	1628	1623	3	2	2020-11-19	2020-11-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/source/Poller.java	9	2	1628	1623	3	2	2020-11-19	2020-11-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/src/main/java/com/google/pubsublite/kafka/source/PubSubLiteSourceTask.java	47	2	1628	1623	3	2	2020-11-19	2020-11-24	dpcollins@google.com	40498610+dpcollins-google@users.noreply.github.com
kafka-connector/copy_tool.py	76	4	1616	1056	5	1	2020-12-01	2022-06-14	40498610+dpcollins-google@users.noreply.github.com	40498610+dpcollins-google@users.noreply.github.com