GoogleCloudPlatform / pubsub - File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary

Number of files: 76
Daily file updates (only one update per file and date counted): 724
First update: 2016-05-05
Latest update: 2025-02-07
Days between first and latest update: 3,201 (457 weeks, estimated 2,285 working days)
Active days (at least one file change): 268
Data:

Organized per file

File Change History Overall

File Age Distribution Overall

Days since first update

There are 76 files with 4,944 lines of code in files.

76 files that are 366+ days old (4,944 lines of code)
0 files that are 181-365 days old (0 lines of code)
0 files that are 91-180 days old (0 lines of code)
0 files that are 31-90 days old (0 lines of code)
0 files that are 1-30 days old (0 lines of code)

Legend:

366+

181-365

91-180

31-90

1-30

explore: grouped by folders | grouped by age

File Freshness Distribution Overall

Days since last update

There are 76 files with 4,944 lines of code in files.

70 files have been last changed 366+ days ago (4,506 lines of code)
6 files have been last changed 181-365 days ago (438 lines of code)
0 files have been last changed 91-180 days ago (0 lines of code)
0 files have been last changed 31-90 days ago (0 lines of code)
0 files have been last changed 1-30 days ago (0 lines of code)

Legend:

366+

181-365

91-180

31-90

1-30

explore: grouped by folders | grouped by freshness

File Change History per File Extension

java, py, js, go, md, xml, sh, properties, proto, json, txt, yaml, mod, gitignore

File Age Distribution per Extension

Days since first update

366+

181-365

91-180

31-90

1-30

File Freshness Distribution per Extension

Days since last update

366+

181-365

91-180

31-90

1-30

File Change History per Logical Decomposition

primary

primary (file age distribution)

Days since first update

366+

181-365

91-180

31-90

1-30

primary (file freshness distribution)

Days since last update

366+

181-365

91-180

31-90

1-30

Oldest Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
CloudPubSubSinkTask.java in kafka-connector/src/main/java/com/google/pubsub/kafka/sink	402	13	2016-09-12	2021-07-21	25	13	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSourceTask.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	325	11	2016-09-12	2021-07-21	38	18	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSourceConnector.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	281	9	2016-09-12	2021-07-21	19	10	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSinkConnector.java in kafka-connector/src/main/java/com/google/pubsub/kafka/sink	218	8	2016-09-12	2021-07-21	16	11	kamal.aboulhosn@gmail.com	samarth.singal@gmail.com
CloudPubSubGRPCSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	82	3	2016-09-12	2021-07-21	9	5	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubRoundRobinSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	39	3	2016-09-12	2021-03-22	7	5	kamal.aboulhosn@gmail.com	40498610+dpcollins-google@u...
ConnectorUtils.java in kafka-connector/src/main/java/com/google/pubsub/kafka/common	35	2	2016-09-12	2021-07-21	17	12	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	11	-	2016-09-12	2021-03-22	4	3	kamal.aboulhosn@gmail.com	40498610+dpcollins-google@u...
ConnectorCredentialsProvider.java in kafka-connector/src/main/java/com/google/pubsub/kafka/common	29	3	2018-11-30	2018-11-30	1	1	htn@aiven.io	htn@aiven.io
Prober.java in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober	616	38	2020-10-07	2023-02-01	7	3	kamal.aboulhosn@gmail.com	kamal.aboulhosn@gmail.com
OrderedProber.java in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober	272	9	2020-10-07	2020-10-07	1	1	kamal.aboulhosn@gmail.com	kamal.aboulhosn@gmail.com
ProberStarter.java in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober	156	1	2020-10-07	2022-04-18	5	4	kamal.aboulhosn@gmail.com	74616323+amfisher-404@users...
PubSubLiteSinkConnector.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	33	5	2020-11-15	2020-11-24	4	2	dpcollins@google.com	40498610+dpcollins-google@u...
PollerImpl.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	61	2	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
PubSubLiteSourceTask.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	47	5	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
ConfigDefs.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	41	2	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
PubSubLiteSourceConnector.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	34	5	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
PollerFactoryImpl.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	34	1	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
Poller.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	9	-	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
PollerFactory.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	5	-	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
Schemas.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	123	6	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
PubSubLiteSinkTask.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	117	7	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
PublisherFactoryImpl.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	31	1	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
ConfigDefs.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	19	2	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
Constants.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	9	1	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
PublisherFactory.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	7	-	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
copy_tool.py in kafka-connector	76	6	2020-12-01	2022-06-14	4	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
CloudPubsubProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	94	5	2021-02-24	2021-03-24	4	2	dpcollins@google.com	40498610+dpcollins-google@u...
KafkaProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	68	4	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
Compiler.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	66	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
TableSpec.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	38	3	2021-02-24	2021-06-23	6	3	dpcollins@google.com	samarth.singal@gmail.com
PubsubLiteProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	36	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
Rows.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	27	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
StandardSqlSource.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	20	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
StandardSqlSink.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	20	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
TableLoader.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	17	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
BigQueryProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	14	2	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
StandardSinkProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	5	-	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
StandardSourceProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	5	-	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
package-info.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	2	-	2021-02-24	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
StreamingPullSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	139	10	2021-03-09	2021-03-22	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
StreamingPullSubscriberFactory.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	6	-	2021-03-09	2021-03-22	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
AckBatchingSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	80	4	2021-03-16	2021-07-21	4	2	dpcollins@google.com	dpcollins@google.com
RunPipeline.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	39	4	2021-03-17	2021-06-23	5	3	dpcollins@google.com	samarth.singal@gmail.com
MakePtransform.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	18	2	2021-03-17	2021-03-24	2	2	dpcollins@google.com	dpcollins@google.com
TemplateMain.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	13	1	2021-03-17	2021-06-23	5	3	dpcollins@google.com	samarth.singal@gmail.com
StandardSource.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	10	-	2021-03-17	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
StandardSink.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	9	-	2021-03-17	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
package-info.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	2	-	2021-03-17	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
TemplateOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	31	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com

Files Not Recently Changed (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
ConnectorCredentialsProvider.java in kafka-connector/src/main/java/com/google/pubsub/kafka/common	29	3	2018-11-30	2018-11-30	1	1	htn@aiven.io	htn@aiven.io
OrderedProber.java in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober	272	9	2020-10-07	2020-10-07	1	1	kamal.aboulhosn@gmail.com	kamal.aboulhosn@gmail.com
PollerFactory.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	5	-	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
PublisherFactory.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	7	-	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
Poller.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	9	-	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
Constants.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	9	1	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
ConfigDefs.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	19	2	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
PublisherFactoryImpl.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	31	1	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
PubSubLiteSinkConnector.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	33	5	2020-11-15	2020-11-24	4	2	dpcollins@google.com	40498610+dpcollins-google@u...
PollerFactoryImpl.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	34	1	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
PubSubLiteSourceConnector.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	34	5	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
ConfigDefs.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	41	2	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
PubSubLiteSourceTask.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	47	5	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
PollerImpl.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/source	61	2	2020-11-19	2020-11-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
PubSubLiteSinkTask.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	117	7	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
Schemas.java in kafka-connector/src/main/java/com/google/pubsublite/kafka/sink	123	6	2020-11-24	2020-11-24	1	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
StreamingPullSubscriberFactory.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	6	-	2021-03-09	2021-03-22	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
CloudPubSubSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	11	-	2016-09-12	2021-03-22	4	3	kamal.aboulhosn@gmail.com	40498610+dpcollins-google@u...
CloudPubSubRoundRobinSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	39	3	2016-09-12	2021-03-22	7	5	kamal.aboulhosn@gmail.com	40498610+dpcollins-google@u...
StreamingPullSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	139	10	2021-03-09	2021-03-22	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
package-info.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	2	-	2021-02-24	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
package-info.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	2	-	2021-03-17	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
StandardSourceProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	5	-	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
StandardSinkProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	5	-	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
StandardSink.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	9	-	2021-03-17	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
StandardSource.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	10	-	2021-03-17	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
BigQueryProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	14	2	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
TableLoader.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	17	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
MakePtransform.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	18	2	2021-03-17	2021-03-24	2	2	dpcollins@google.com	dpcollins@google.com
StandardSqlSink.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	20	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
StandardSqlSource.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	20	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
Rows.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	27	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
PubsubLiteProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	36	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
Compiler.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	66	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
KafkaProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	68	4	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
CloudPubsubProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	94	5	2021-02-24	2021-03-24	4	2	dpcollins@google.com	40498610+dpcollins-google@u...
SqlStreamingOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	4	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
UITemplateOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	13	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
TemplateMain.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	13	1	2021-03-17	2021-06-23	5	3	dpcollins@google.com	samarth.singal@gmail.com
UITemplateMain.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	14	1	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
TemplateOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	31	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
TableSpec.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	38	3	2021-02-24	2021-06-23	6	3	dpcollins@google.com	samarth.singal@gmail.com
RunPipeline.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	39	4	2021-03-17	2021-06-23	5	3	dpcollins@google.com	samarth.singal@gmail.com
ConnectorUtils.java in kafka-connector/src/main/java/com/google/pubsub/kafka/common	35	2	2016-09-12	2021-07-21	17	12	kamal.aboulhosn@gmail.com	dpcollins@google.com
AckBatchingSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	80	4	2021-03-16	2021-07-21	4	2	dpcollins@google.com	dpcollins@google.com
CloudPubSubGRPCSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	82	3	2016-09-12	2021-07-21	9	5	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSinkConnector.java in kafka-connector/src/main/java/com/google/pubsub/kafka/sink	218	8	2016-09-12	2021-07-21	16	11	kamal.aboulhosn@gmail.com	samarth.singal@gmail.com
CloudPubSubSourceConnector.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	281	9	2016-09-12	2021-07-21	19	10	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSourceTask.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	325	11	2016-09-12	2021-07-21	38	18	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSinkTask.java in kafka-connector/src/main/java/com/google/pubsub/kafka/sink	402	13	2016-09-12	2021-07-21	25	13	kamal.aboulhosn@gmail.com	dpcollins@google.com

Most Recently Created Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
EmulatorEndpoint.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util	20	2	2024-03-14	2024-04-19	3	2	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubExample.java in flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink	69	1	2023-10-09	2024-04-19	5	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubSource.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink	183	11	2023-09-07	2024-05-29	12	4	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubNotifyingPullSubscriber.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	105	8	2023-09-07	2024-05-29	6	4	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubSplitReader.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	103	7	2023-09-07	2024-02-22	4	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubSink.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink	84	3	2023-09-07	2024-04-19	7	4	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubSplitEnumerator.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator	69	8	2023-09-07	2024-04-09	4	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubSourceReader.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	56	6	2023-09-07	2024-05-29	3	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubAckTracker.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	54	5	2023-09-07	2024-05-29	5	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
proto split.proto in flink-connector/flink-connector-gcp-pubsub/src/main/proto	32	-	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
SubscriptionSplit.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split	31	5	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubRecordEmitter.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	31	2	2023-09-07	2024-05-29	3	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubPublisherCache.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink	29	3	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubDeserializationSchema.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink	28	1	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubFlushablePublisher.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink	28	3	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubSinkWriter.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink	24	4	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubSerializationSchema.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink	23	1	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubCheckpointSerializer.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator	19	2	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
SubscriptionSplitSerializer.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split	19	2	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
SubscriptionSplitState.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split	10	2	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
NotifyingPullSubscriber.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	10	-	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
AckTracker.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	9	-	2023-09-07	2024-05-29	5	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
FlushablePublisher.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink	6	-	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
TemplateOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	31	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
UITemplateMain.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	14	1	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
UITemplateOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	13	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
SqlStreamingOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	4	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
RunPipeline.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	39	4	2021-03-17	2021-06-23	5	3	dpcollins@google.com	samarth.singal@gmail.com
MakePtransform.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	18	2	2021-03-17	2021-03-24	2	2	dpcollins@google.com	dpcollins@google.com
TemplateMain.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	13	1	2021-03-17	2021-06-23	5	3	dpcollins@google.com	samarth.singal@gmail.com
StandardSource.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	10	-	2021-03-17	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
StandardSink.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	9	-	2021-03-17	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
package-info.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	2	-	2021-03-17	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
AckBatchingSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	80	4	2021-03-16	2021-07-21	4	2	dpcollins@google.com	dpcollins@google.com
StreamingPullSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	139	10	2021-03-09	2021-03-22	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
StreamingPullSubscriberFactory.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	6	-	2021-03-09	2021-03-22	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
CloudPubsubProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	94	5	2021-02-24	2021-03-24	4	2	dpcollins@google.com	40498610+dpcollins-google@u...
KafkaProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	68	4	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
Compiler.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	66	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
TableSpec.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	38	3	2021-02-24	2021-06-23	6	3	dpcollins@google.com	samarth.singal@gmail.com
PubsubLiteProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	36	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
Rows.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	27	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
StandardSqlSource.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	20	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
StandardSqlSink.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	20	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
TableLoader.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	17	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
BigQueryProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	14	2	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
StandardSinkProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	5	-	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
StandardSourceProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	5	-	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
package-info.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	2	-	2021-02-24	2021-03-24	2	2	dpcollins@google.com	40498610+dpcollins-google@u...
copy_tool.py in kafka-connector	76	6	2020-12-01	2022-06-14	4	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...

Most Recently Changed Files (Top 50)

File	# lines	# units	created	last modified	# changes (days)	# contributors	first contributor	latest contributor
PubSubSource.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink	183	11	2023-09-07	2024-05-29	12	4	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubNotifyingPullSubscriber.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	105	8	2023-09-07	2024-05-29	6	4	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubSourceReader.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	56	6	2023-09-07	2024-05-29	3	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubAckTracker.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	54	5	2023-09-07	2024-05-29	5	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubRecordEmitter.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	31	2	2023-09-07	2024-05-29	3	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
AckTracker.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	9	-	2023-09-07	2024-05-29	5	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubSink.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink	84	3	2023-09-07	2024-04-19	7	4	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubExample.java in flink-connector/flink-examples-gcp-pubsub/pubsub-streaming/src/main/java/com/google/pubsub/flink	69	1	2023-10-09	2024-04-19	5	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
EmulatorEndpoint.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/util	20	2	2024-03-14	2024-04-19	3	2	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubSplitEnumerator.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator	69	8	2023-09-07	2024-04-09	4	3	mattkwong@google.com	matt-kwong@users.noreply.gi...
PubSubSplitReader.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	103	7	2023-09-07	2024-02-22	4	2	mattkwong@google.com	52459909+hannahrogers-googl...
proto split.proto in flink-connector/flink-connector-gcp-pubsub/src/main/proto	32	-	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
SubscriptionSplit.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split	31	5	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubPublisherCache.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink	29	3	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubDeserializationSchema.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink	28	1	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubFlushablePublisher.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink	28	3	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubSinkWriter.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink	24	4	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubSerializationSchema.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink	23	1	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
PubSubCheckpointSerializer.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/enumerator	19	2	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
SubscriptionSplitSerializer.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split	19	2	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
SubscriptionSplitState.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/split	10	2	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
NotifyingPullSubscriber.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/source/reader	10	-	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
FlushablePublisher.java in flink-connector/flink-connector-gcp-pubsub/src/main/java/com/google/pubsub/flink/internal/sink	6	-	2023-09-07	2024-02-22	2	2	mattkwong@google.com	52459909+hannahrogers-googl...
Prober.java in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober	616	38	2020-10-07	2023-02-01	7	3	kamal.aboulhosn@gmail.com	kamal.aboulhosn@gmail.com
copy_tool.py in kafka-connector	76	6	2020-12-01	2022-06-14	4	1	40498610+dpcollins-google@u...	40498610+dpcollins-google@u...
ProberStarter.java in ordering-keys-prober/src/main/java/com/google/cloud/pubsub/prober	156	1	2020-10-07	2022-04-18	5	4	kamal.aboulhosn@gmail.com	74616323+amfisher-404@users...
CloudPubSubSinkTask.java in kafka-connector/src/main/java/com/google/pubsub/kafka/sink	402	13	2016-09-12	2021-07-21	25	13	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSourceTask.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	325	11	2016-09-12	2021-07-21	38	18	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSourceConnector.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	281	9	2016-09-12	2021-07-21	19	10	kamal.aboulhosn@gmail.com	dpcollins@google.com
CloudPubSubSinkConnector.java in kafka-connector/src/main/java/com/google/pubsub/kafka/sink	218	8	2016-09-12	2021-07-21	16	11	kamal.aboulhosn@gmail.com	samarth.singal@gmail.com
CloudPubSubGRPCSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	82	3	2016-09-12	2021-07-21	9	5	kamal.aboulhosn@gmail.com	dpcollins@google.com
AckBatchingSubscriber.java in kafka-connector/src/main/java/com/google/pubsub/kafka/source	80	4	2021-03-16	2021-07-21	4	2	dpcollins@google.com	dpcollins@google.com
ConnectorUtils.java in kafka-connector/src/main/java/com/google/pubsub/kafka/common	35	2	2016-09-12	2021-07-21	17	12	kamal.aboulhosn@gmail.com	dpcollins@google.com
RunPipeline.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	39	4	2021-03-17	2021-06-23	5	3	dpcollins@google.com	samarth.singal@gmail.com
TableSpec.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	38	3	2021-02-24	2021-06-23	6	3	dpcollins@google.com	samarth.singal@gmail.com
TemplateOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	31	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
UITemplateMain.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	14	1	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
TemplateMain.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	13	1	2021-03-17	2021-06-23	5	3	dpcollins@google.com	samarth.singal@gmail.com
UITemplateOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	13	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
SqlStreamingOptions.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	4	-	2021-04-13	2021-06-23	3	3	dpcollins@google.com	samarth.singal@gmail.com
CloudPubsubProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	94	5	2021-02-24	2021-03-24	4	2	dpcollins@google.com	40498610+dpcollins-google@u...
KafkaProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	68	4	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
Compiler.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	66	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
PubsubLiteProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	36	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
Rows.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	27	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
StandardSqlSource.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	20	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
StandardSqlSink.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	20	1	2021-02-24	2021-03-24	3	2	dpcollins@google.com	40498610+dpcollins-google@u...
MakePtransform.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	18	2	2021-03-17	2021-03-24	2	2	dpcollins@google.com	dpcollins@google.com
TableLoader.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql	17	3	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com
BigQueryProvider.java in sql-streaming-copier/src/main/java/com/google/cloud/pubsub/sql/providers	14	2	2021-02-24	2021-03-24	3	2	dpcollins@google.com	dpcollins@google.com