apache / pulsar-connectors
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
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 218 files with 10,857 lines of code in files.
    • 218 files that are 366+ days old (10,857 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)
100% | 0% | 0% | 0% | 0%
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 218 files with 10,857 lines of code in files.
    • 218 files have been last changed 366+ days ago (10,857 lines of code)
    • 0 files have been last changed 181-365 days ago (0 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)
100% | 0% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, yaml, xml, md, properties, txt, json, gitignore
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
yaml100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
yaml100% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
pulsar-io100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
pulsar-io100% | 0% | 0% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
TwitterFireHose.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 125 6 2018-05-08 2020-03-27 14 7 lucperkins@gmail.com henry.yijieshen@gmail.com
TwitterFireHoseConfig.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 124 5 2018-05-08 2020-01-01 6 5 lucperkins@gmail.com vzhikserg@users.noreply.git...
KafkaSourceConfig.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 86 2 2018-05-08 2020-01-01 5 5 lucperkins@gmail.com vzhikserg@users.noreply.git...
RabbitMQSource.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 73 4 2018-05-08 2019-04-01 8 6 lucperkins@gmail.com sunfangbin@gmail.com
KafkaSinkConfig.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 70 2 2018-05-08 2020-01-01 5 4 lucperkins@gmail.com vzhikserg@users.noreply.git...
CassandraSinkConfig.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 48 2 2018-05-08 2020-01-01 3 3 lucperkins@gmail.com vzhikserg@users.noreply.git...
AerospikeSinkConfig.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 31 2 2018-05-08 2020-01-01 3 3 lucperkins@gmail.com vzhikserg@users.noreply.git...
KinesisSink.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 176 10 2018-06-07 2020-05-19 15 7 rdhabalia@apache.org maths22@gmail.com
KinesisSinkConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 54 2 2018-06-07 2019-09-05 6 3 rdhabalia@apache.org 35466513+david-streamlio@us...
AwsCredentialProviderPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 2018-06-07 2020-05-19 4 3 rdhabalia@apache.org maths22@gmail.com
KafkaAbstractSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 153 10 2018-06-08 2019-02-04 9 6 sanjeevrk@gmail.com sunfangbin@gmail.com
AerospikeAbstractSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 127 8 2018-06-08 2020-02-10 7 6 sanjeevrk@gmail.com abhilashmandaliya@gmail.com
CassandraAbstractSink.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 75 4 2018-06-08 2019-10-31 7 4 sanjeevrk@gmail.com mmerli@apache.org
KafkaAbstractSink.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 72 4 2018-06-08 2019-02-04 8 5 sanjeevrk@gmail.com sunfangbin@gmail.com
CassandraStringSink.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 17 1 2018-06-08 2018-11-27 5 3 sanjeevrk@gmail.com guosijie@gmail.com
AerospikeStringSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 10 1 2018-06-08 2018-09-06 5 4 sanjeevrk@gmail.com alahmed.se@gmail.com
KafkaStringSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 8 1 2018-06-08 2018-07-14 2 2 sanjeevrk@gmail.com mmerli@apache.org
Utils.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 160 4 2018-07-06 2020-09-30 5 3 rdhabalia@apache.org kellyfj@gmail.com
pulsar-io.yaml
in pulsar-io/kinesis/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/rabbitmq/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/kafka/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 4 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/twitter/src/main/resources/META-INF/services
 4 - 2018-07-08 2020-05-22 2 2 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/aerospike/src/main/resources/META-INF/services
 4 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/cassandra/src/main/resources/META-INF/services
 4 - 2018-07-08 2020-05-22 2 2 mmerli@apache.org sanjeevrk@gmail.com
EncryptionCtx.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 60 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
Message.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 45 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
EncryptionKey.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 44 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
KeyValue.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 33 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
CompressionType.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 9 1 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
ElasticSearchConfig.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 85 3 2018-09-10 2020-01-23 6 6 35466513+david-streamlio@us... yang.yang@elastic.co
pulsar-io.yaml
in pulsar-io/elastic-search/src/main/resources/META-INF/services
 4 - 2018-09-10 2020-05-22 3 3 35466513+david-streamlio@us... sanjeevrk@gmail.com
package-info.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 1 - 2018-09-10 2018-09-10 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
ElasticSearchSink.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 114 8 2018-09-18 2020-09-08 6 5 guosijie@gmail.com rxl@apache.org
KafkaBytesSink.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 30 2 2018-09-18 2018-11-25 2 1 guosijie@gmail.com guosijie@gmail.com
PulsarOffsetBackingStore.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 199 8 2018-10-03 2018-10-03 1 1 jiazhai@users.noreply.githu... jiazhai@users.noreply.githu...
KafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 108 6 2018-10-03 2020-05-28 9 6 jiazhai@users.noreply.githu... nathanm@instructure.com
PulsarKafkaWorkerConfig.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 34 2 2018-10-03 2019-03-19 2 2 jiazhai@users.noreply.githu... zhaijia@apache.org
PulsarIOSourceTaskContext.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 20 2 2018-10-03 2019-07-02 2 2 jiazhai@users.noreply.githu... 3407583+willome@users.norep...
KafkaBytesSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 29 1 2018-10-10 2018-11-25 2 1 guosijie@gmail.com guosijie@gmail.com
pulsar-io.yaml
in pulsar-io/kafka-connect-adaptor/src/main/resources/META-INF/services
 3 - 2018-10-29 2018-10-29 1 1 jiazhai@users.noreply.githu... jiazhai@users.noreply.githu...
CanalSourceConfig.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 65 2 2018-11-25 2020-01-01 4 4 eguangning@gmail.com vzhikserg@users.noreply.git...
canal-mysql-source-config.yaml
in pulsar-io/canal/src/main/resources
 9 - 2018-11-25 2018-11-25 1 1 eguangning@gmail.com eguangning@gmail.com
pulsar-io.yaml
in pulsar-io/canal/src/main/resources/META-INF/services
 4 - 2018-11-25 2020-05-22 3 2 eguangning@gmail.com sanjeevrk@gmail.com
AbstractHdfsConnector.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 165 13 2018-12-16 2019-12-20 3 3 35466513+david-streamlio@us... phreed@users.noreply.github...
AbstractHdfsConnector.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3
 165 13 2018-12-16 2019-12-20 3 3 35466513+david-streamlio@us... phreed@users.noreply.github...
HdfsAbstractSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 90 6 2018-12-16 2020-08-12 2 2 35466513+david-streamlio@us... xyzinfernity@163.com
HdfsAbstractSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink
 85 7 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractSequenceFileSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq
 58 5 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractSequenceFileSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq
 58 5 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsSinkConfig.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 55 3 2018-12-16 2020-08-12 3 3 35466513+david-streamlio@us... xyzinfernity@163.com
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
CompressionType.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 9 1 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
KeyValue.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 33 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
EncryptionKey.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 44 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
Message.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 45 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
EncryptionCtx.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis/fbs
 60 2 2018-07-13 2018-07-13 1 1 rdhabalia@apache.org rdhabalia@apache.org
KafkaStringSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 8 1 2018-06-08 2018-07-14 2 2 sanjeevrk@gmail.com mmerli@apache.org
AerospikeStringSink.java
in pulsar-io/aerospike/src/main/java/org/apache/pulsar/io/aerospike
 10 1 2018-06-08 2018-09-06 5 4 sanjeevrk@gmail.com alahmed.se@gmail.com
package-info.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 1 - 2018-09-10 2018-09-10 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
PulsarOffsetBackingStore.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 199 8 2018-10-03 2018-10-03 1 1 jiazhai@users.noreply.githu... jiazhai@users.noreply.githu...
pulsar-io.yaml
in pulsar-io/kafka-connect-adaptor/src/main/resources/META-INF/services
 3 - 2018-10-29 2018-10-29 1 1 jiazhai@users.noreply.githu... jiazhai@users.noreply.githu...
canal-mysql-source-config.yaml
in pulsar-io/canal/src/main/resources
 9 - 2018-11-25 2018-11-25 1 1 eguangning@gmail.com eguangning@gmail.com
KafkaBytesSource.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 29 1 2018-10-10 2018-11-25 2 1 guosijie@gmail.com guosijie@gmail.com
KafkaBytesSink.java
in pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka
 30 2 2018-09-18 2018-11-25 2 1 guosijie@gmail.com guosijie@gmail.com
CassandraStringSink.java
in pulsar-io/cassandra/src/main/java/org/apache/pulsar/io/cassandra
 17 1 2018-06-08 2018-11-27 5 3 sanjeevrk@gmail.com guosijie@gmail.com
package-info.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3
 1 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink
 1 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/text
 1 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq
 1 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 1 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 1 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text
 1 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq
 1 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
Compression.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3
 4 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
Compression.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 4 - 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsResources.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3
 23 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsResources.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 23 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
SecurityUtil.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3
 27 3 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
SecurityUtil.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2
 27 3 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractTextFileSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/text
 45 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsSyncThread.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink
 45 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractTextFileSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/text
 45 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsSyncThread.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 45 4 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractSequenceFileSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/seq
 58 5 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractSequenceFileSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/seq
 58 5 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
HdfsAbstractSink.java
in pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink
 85 7 2018-12-16 2018-12-16 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 1 - 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file/utils
 1 - 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
ProcessedFileThread.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 32 3 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
FileRecord.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 37 4 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
FileSource.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 38 2 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
FileConsumerThread.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 71 5 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
FileListingThread.java
in pulsar-io/file/src/main/java/org/apache/pulsar/io/file
 141 4 2018-12-27 2018-12-27 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
CanalByteSource.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 24 1 2019-01-02 2019-01-02 1 1 eguangning@gmail.com eguangning@gmail.com
CanalStringSource.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 45 2 2019-01-02 2019-01-02 1 1 eguangning@gmail.com eguangning@gmail.com
MessageUtils.java
in pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal
 116 2 2019-01-02 2019-01-02 1 1 eguangning@gmail.com eguangning@gmail.com
package-info.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty
 1 - 2019-01-11 2019-01-11 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/http
 1 - 2019-01-11 2019-01-11 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/server
 1 - 2019-01-11 2019-01-11 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter
 1 - 2019-01-11 2019-01-11 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
package-info.java
in pulsar-io/twitter/src/main/java/org/apache/pulsar/io/twitter/data
 1 - 2019-01-11 2019-01-11 1 1 35466513+david-streamlio@us... 35466513+david-streamlio@us...
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
AbstractKafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 207 10 2020-05-28 2020-05-28 1 1 nathanm@instructure.com nathanm@instructure.com
DynamoDBSourceConfig.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 184 7 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
DynamoDBSource.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 97 3 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
AbstractAwsConnector.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 84 4 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
StreamsRecordProcessor.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 77 5 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
StreamsRecord.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 50 2 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
STSAssumeRoleProviderPlugin.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 37 3 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
AwsCredentialProviderPlugin.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 26 - 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
AwsDefaultProviderChainPlugin.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 21 3 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
StreamsRecordProcessorFactory.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 17 2 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
pulsar-io.yaml
in pulsar-io/dynamodb/src/main/resources/META-INF/services
 3 - 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
JdbcUtils.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 181 14 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
JdbcAbstractSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 180 5 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
BaseJdbcAutoSchemaSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 75 3 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
JdbcSinkConfig.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 73 2 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
JdbcDriverType.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 37 1 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
ClickHouseJdbcAutoSchemaSink.java
in pulsar-io/jdbc/clickhouse/src/main/java/org/apache/pulsar/io/jdbc
 11 - 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
MariadbJdbcAutoSchemaSink.java
in pulsar-io/jdbc/mariadb/src/main/java/org/apache/pulsar/io/jdbc
 11 - 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
SqliteJdbcAutoSchemaSink.java
in pulsar-io/jdbc/sqlite/src/main/java/org/apache/pulsar/io/jdbc
 11 - 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
PostgresJdbcAutoSchemaSink.java
in pulsar-io/jdbc/postgres/src/main/java/org/apache/pulsar/io/jdbc
 11 - 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
pulsar-io.yaml
in pulsar-io/jdbc/sqlite/src/main/resources/META-INF/services
 4 - 2020-05-18 2020-05-22 2 2 vzhikserg@users.noreply.git... sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/jdbc/clickhouse/src/main/resources/META-INF/services
 3 - 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
pulsar-io.yaml
in pulsar-io/jdbc/mariadb/src/main/resources/META-INF/services
 3 - 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
pulsar-io.yaml
in pulsar-io/jdbc/postgres/src/main/resources/META-INF/services
 3 - 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
KafkaSchemaWrappedSchema.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/schema
 40 3 2020-04-30 2020-04-30 1 1 guangning@apache.org guangning@apache.org
InfluxDBSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 108 5 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
BatchSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb
 91 5 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
InfluxDBSinkConfig.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 87 3 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
InfluxDBSinkConfig.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 83 3 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
InfluxDBGenericRecordSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 57 1 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
InfluxDBAbstractSink.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 53 3 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
InfluxDBBuilderImpl.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 33 1 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
InfluxDBClientBuilderImpl.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 23 1 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
InfluxDBBuilder.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v1
 5 - 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
InfluxDBClientBuilder.java
in pulsar-io/influxdb/src/main/java/org/apache/pulsar/io/influxdb/v2
 5 - 2020-04-05 2020-04-05 1 1 roymatrix.lin@gmail.com roymatrix.lin@gmail.com
NettyUDPServerHandler.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp
 36 3 2019-12-14 2019-12-14 1 1 58692163+gbensa@users.norep... 58692163+gbensa@users.norep...
NettyTCPServerHandler.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp
 33 3 2019-12-14 2019-12-14 1 1 58692163+gbensa@users.norep... 58692163+gbensa@users.norep...
NettyTCPChannelInitializer.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp
 16 2 2019-12-14 2019-12-14 1 1 58692163+gbensa@users.norep... 58692163+gbensa@users.norep...
NettyUDPChannelInitializer.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp
 14 2 2019-12-14 2019-12-14 1 1 58692163+gbensa@users.norep... 58692163+gbensa@users.norep...
package-info.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/udp
 1 - 2019-12-14 2019-12-14 1 1 58692163+gbensa@users.norep... 58692163+gbensa@users.norep...
package-info.java
in pulsar-io/netty/src/main/java/org/apache/pulsar/io/netty/tcp
 1 - 2019-12-14 2019-12-14 1 1 58692163+gbensa@users.norep... 58692163+gbensa@users.norep...
package-info.java
in pulsar-io/netty/src/main/java
 1 - 2019-12-14 2019-12-14 1 1 58692163+gbensa@users.norep... 58692163+gbensa@users.norep...
debezium-mongodb-source-config.yaml
in pulsar-io/debezium/mongodb/src/main/resources
 14 - 2019-11-19 2019-11-19 1 1 localhost80@foxmail.com localhost80@foxmail.com
DebeziumMongoDbSource.java
in pulsar-io/debezium/mongodb/src/main/java/org/apache/pulsar/io/debezium/mongodb
 11 1 2019-11-19 2019-11-19 1 1 localhost80@foxmail.com localhost80@foxmail.com
pulsar-io.yaml
in pulsar-io/debezium/mongodb/src/main/resources/META-INF/services
 3 - 2019-11-19 2019-11-19 1 1 localhost80@foxmail.com localhost80@foxmail.com
MongoSource.java
in pulsar-io/mongo/src/main/java/org/apache/pulsar/io/mongodb
 111 4 2019-10-06 2019-11-06 2 2 bbonnin@gmail.com ke.like@outlook.com
STSAssumeRoleProviderPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 2019-09-28 2020-05-19 2 2 addisonj@gmail.com maths22@gmail.com
AwsDefaultProviderChainPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 2019-09-28 2020-05-19 2 2 addisonj@gmail.com maths22@gmail.com
KinesisSourceConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 157 6 2019-09-05 2020-05-19 3 3 35466513+david-streamlio@us... maths22@gmail.com
KinesisSource.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 103 3 2019-09-05 2020-05-19 3 3 35466513+david-streamlio@us... maths22@gmail.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
Utils.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 160 4 2018-07-06 2020-09-30 5 3 rdhabalia@apache.org kellyfj@gmail.com
ElasticSearchSink.java
in pulsar-io/elastic-search/src/main/java/org/apache/pulsar/io/elasticsearch
 114 8 2018-09-18 2020-09-08 6 5 guosijie@gmail.com rxl@apache.org
HdfsAbstractSink.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 90 6 2018-12-16 2020-08-12 2 2 35466513+david-streamlio@us... xyzinfernity@163.com
HdfsSinkConfig.java
in pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink
 55 3 2018-12-16 2020-08-12 3 3 35466513+david-streamlio@us... xyzinfernity@163.com
RedisAbstractConfig.java
in pulsar-io/redis/src/main/java/org/apache/pulsar/io/redis
 80 2 2019-03-12 2020-06-18 4 4 sunfangbin@gmail.com rdhabalia@apache.org
AbstractKafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 207 10 2020-05-28 2020-05-28 1 1 nathanm@instructure.com nathanm@instructure.com
KafkaConnectSource.java
in pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect
 108 6 2018-10-03 2020-05-28 9 6 jiazhai@users.noreply.githu... nathanm@instructure.com
RabbitMQAbstractConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 94 2 2019-04-01 2020-05-22 5 4 sunfangbin@gmail.com penghui@apache.org
RabbitMQSink.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 72 3 2019-04-02 2020-05-22 4 3 sunfangbin@gmail.com penghui@apache.org
RabbitMQSinkConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 46 3 2019-04-02 2020-05-22 4 4 sunfangbin@gmail.com penghui@apache.org
pulsar-io.yaml
in pulsar-io/kinesis/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/rabbitmq/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/kafka/src/main/resources/META-INF/services
 6 - 2018-07-08 2020-05-22 4 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/mongo/src/main/resources/META-INF/services
 6 - 2019-02-13 2020-05-22 4 3 bbonnin@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/flume/src/main/resources/META-INF/services
 5 - 2019-03-04 2020-05-22 2 2 eguangning@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/twitter/src/main/resources/META-INF/services
 4 - 2018-07-08 2020-05-22 2 2 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/hdfs2/src/main/resources/META-INF/services
 4 - 2018-12-16 2020-05-22 2 2 35466513+david-streamlio@us... sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/hdfs3/src/main/resources/META-INF/services
 4 - 2018-12-16 2020-05-22 2 2 35466513+david-streamlio@us... sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/file/src/main/resources/META-INF/services
 4 - 2018-12-27 2020-05-22 2 2 35466513+david-streamlio@us... sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/redis/src/main/resources/META-INF/services
 4 - 2019-04-02 2020-05-22 2 2 sunfangbin@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/canal/src/main/resources/META-INF/services
 4 - 2018-11-25 2020-05-22 3 2 eguangning@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/netty/src/main/resources/META-INF/services
 4 - 2018-12-16 2020-05-22 3 3 erenavsarogullari@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/elastic-search/src/main/resources/META-INF/services
 4 - 2018-09-10 2020-05-22 3 3 35466513+david-streamlio@us... sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/solr/src/main/resources/META-INF/services
 4 - 2019-04-01 2020-05-22 2 2 sunfangbin@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/jdbc/sqlite/src/main/resources/META-INF/services
 4 - 2020-05-18 2020-05-22 2 2 vzhikserg@users.noreply.git... sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/influxdb/src/main/resources/META-INF/services
 4 - 2019-04-11 2020-05-22 2 2 sunfangbin@gmail.com sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/aerospike/src/main/resources/META-INF/services
 4 - 2018-07-08 2020-05-22 3 3 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/cassandra/src/main/resources/META-INF/services
 4 - 2018-07-08 2020-05-22 2 2 mmerli@apache.org sanjeevrk@gmail.com
pulsar-io.yaml
in pulsar-io/hbase/src/main/resources/META-INF/services
 4 - 2019-02-01 2020-05-22 2 2 1269223860@qq.com sanjeevrk@gmail.com
DynamoDBSourceConfig.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 184 7 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
KinesisSink.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 176 10 2018-06-07 2020-05-19 15 7 rdhabalia@apache.org maths22@gmail.com
KinesisSourceConfig.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 157 6 2019-09-05 2020-05-19 3 3 35466513+david-streamlio@us... maths22@gmail.com
KinesisSource.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 103 3 2019-09-05 2020-05-19 3 3 35466513+david-streamlio@us... maths22@gmail.com
DynamoDBSource.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 97 3 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
AbstractAwsConnector.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 84 4 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
StreamsRecordProcessor.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 77 5 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
StreamsRecord.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 50 2 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
RabbitMQSourceConfig.java
in pulsar-io/rabbitmq/src/main/java/org/apache/pulsar/io/rabbitmq
 47 3 2019-04-01 2020-05-19 3 3 sunfangbin@gmail.com alex.rufo@teamcmp.com
STSAssumeRoleProviderPlugin.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 37 3 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
AwsCredentialProviderPlugin.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 26 - 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
AwsDefaultProviderChainPlugin.java
in pulsar-io/aws/src/main/java/org/apache/pulsar/io/aws
 21 3 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
StreamsRecordProcessorFactory.java
in pulsar-io/dynamodb/src/main/java/org/apache/pulsar/io/dynamodb
 17 2 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
STSAssumeRoleProviderPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 2019-09-28 2020-05-19 2 2 addisonj@gmail.com maths22@gmail.com
AwsCredentialProviderPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 2018-06-07 2020-05-19 4 3 rdhabalia@apache.org maths22@gmail.com
AwsDefaultProviderChainPlugin.java
in pulsar-io/kinesis/src/main/java/org/apache/pulsar/io/kinesis
 4 - 2019-09-28 2020-05-19 2 2 addisonj@gmail.com maths22@gmail.com
pulsar-io.yaml
in pulsar-io/dynamodb/src/main/resources/META-INF/services
 3 - 2020-05-19 2020-05-19 1 1 maths22@gmail.com maths22@gmail.com
JdbcUtils.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 181 14 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
JdbcAbstractSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 180 5 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
BaseJdbcAutoSchemaSink.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 75 3 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...
JdbcSinkConfig.java
in pulsar-io/jdbc/core/src/main/java/org/apache/pulsar/io/jdbc
 73 2 2020-05-18 2020-05-18 1 1 vzhikserg@users.noreply.git... vzhikserg@users.noreply.git...