This is an automated email from the ASF dual-hosted git repository.
snlee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from dbaac00 Fix errors happening due to parallel builds (#7172)
add 480395f Add Apache Pulsar low level and high level connector (#7026)
No new revisions were added by this update.
Summary of changes:
.../pinot-stream-ingestion/pinot-pulsar/pom.xml | 375 +++++++++
.../stream/pulsar/MessageIdStreamOffset.java | 72 ++
.../pulsar/MessageIdStreamOffsetFactory.java} | 20 +-
.../pinot/plugin/stream/pulsar/PulsarConfig.java | 83 ++
.../stream/pulsar/PulsarConsumerFactory.java} | 25 +-
.../plugin/stream/pulsar/PulsarMessageBatch.java | 86 ++
.../PulsarPartitionLevelConnectionHandler.java | 79 ++
.../pulsar/PulsarPartitionLevelConsumer.java | 138 ++++
.../stream/pulsar/PulsarStreamLevelConsumer.java} | 71 +-
.../pulsar/PulsarStreamLevelConsumerManager.java | 175 ++++
.../pulsar/PulsarStreamMetadataProvider.java | 158 ++++
.../plugin/stream/pulsar/PulsarConsumerTest.java | 191 +++++
.../stream/pulsar/PulsarStandaloneCluster.java | 132 +++
.../src/test/resources/standalone.properties | 898 +++++++++++++++++++++
pinot-plugins/pinot-stream-ingestion/pom.xml | 1 +
15 files changed, 2440 insertions(+), 64 deletions(-)
create mode 100644 pinot-plugins/pinot-stream-ingestion/pinot-pulsar/pom.xml
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/MessageIdStreamOffset.java
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisMsgOffsetFactory.java
=>
pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/MessageIdStreamOffsetFactory.java}
(67%)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarConfig.java
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisConsumerFactory.java
=>
pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarConsumerFactory.java}
(74%)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarMessageBatch.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarPartitionLevelConnectionHandler.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarPartitionLevelConsumer.java
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaStreamLevelConsumer.java
=>
pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamLevelConsumer.java}
(51%)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamLevelConsumerManager.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamMetadataProvider.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/test/java/org/apache/pinot/plugin/stream/pulsar/PulsarConsumerTest.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/test/java/org/apache/pinot/plugin/stream/pulsar/PulsarStandaloneCluster.java
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/test/resources/standalone.properties
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
