You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by sn...@apache.org on 2021/07/19 17:09:32 UTC
[incubator-pinot] branch master updated (dbaac00 -> 480395f)
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: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org