This is an automated email from the ASF dual-hosted git repository. nehapawar pushed a commit to branch sharded_consumer_type_support_with_kinesis in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
The following commit(s) were added to refs/heads/sharded_consumer_type_support_with_kinesis by this push: new efbeea2 LIcense headers efbeea2 is described below commit efbeea2bf8159eb7299292929a57c47345feb341 Author: Neha Pawar <neha.pawa...@gmail.com> AuthorDate: Mon Jan 11 17:21:04 2021 -0800 LIcense headers --- .../plugin/stream/kinesis/KinesisMsgOffsetFactory.java | 18 ++++++++++++++++++ .../stream/kinesis/KinesisStreamMetadataProvider.java | 18 ++++++++++++++++++ .../plugin/stream/kinesis/KinesisConsumerTest.java | 10 ++++++---- .../org/apache/pinot/spi/stream/LongMsgOffset.java | 9 ++++----- 4 files changed, 46 insertions(+), 9 deletions(-) diff --git a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisMsgOffsetFactory.java b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisMsgOffsetFactory.java index 8f6b932..5cd57c9 100644 --- a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisMsgOffsetFactory.java +++ b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisMsgOffsetFactory.java @@ -1,3 +1,21 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ package org.apache.pinot.plugin.stream.kinesis; import java.io.IOException; diff --git a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisStreamMetadataProvider.java b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisStreamMetadataProvider.java index 1083969..b22bbe4 100644 --- a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisStreamMetadataProvider.java +++ b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/main/java/org/apache/pinot/plugin/stream/kinesis/KinesisStreamMetadataProvider.java @@ -1,3 +1,21 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ package org.apache.pinot.plugin.stream.kinesis; import java.io.IOException; diff --git a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/test/java/org/apache/pinot/plugin/stream/kinesis/KinesisConsumerTest.java b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/test/java/org/apache/pinot/plugin/stream/kinesis/KinesisConsumerTest.java index 57baae9..f9ed779 100644 --- a/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/test/java/org/apache/pinot/plugin/stream/kinesis/KinesisConsumerTest.java +++ b/pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/test/java/org/apache/pinot/plugin/stream/kinesis/KinesisConsumerTest.java @@ -1,4 +1,4 @@ -package org.apache.pinot.plugin.stream.kinesis; /** +/** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this work for additional information @@ -16,6 +16,7 @@ package org.apache.pinot.plugin.stream.kinesis; /** * specific language governing permissions and limitations * under the License. */ +package org.apache.pinot.plugin.stream.kinesis; import java.io.IOException; import java.util.HashMap; @@ -44,8 +45,7 @@ public class KinesisConsumerTest { for (Shard shard : shardList) { System.out.println("SHARD: " + shard.shardId()); - KinesisConsumer kinesisConsumer = - new KinesisConsumer(kinesisConfig); + KinesisConsumer kinesisConsumer = new KinesisConsumer(kinesisConfig); System.out.println( "Kinesis Checkpoint Range: < " + shard.sequenceNumberRange().startingSequenceNumber() + ", " + shard .sequenceNumberRange().endingSequenceNumber() + " >"); @@ -57,7 +57,9 @@ public class KinesisConsumerTest { System.out.println("Found " + n + " messages "); for (int i = 0; i < n; i++) { - System.out.println("SEQ-NO: " + kinesisRecordsBatch.getMessageOffsetAtIndex(i) + ", DATA: " + kinesisRecordsBatch.getMessageAtIndex(i)); + System.out.println( + "SEQ-NO: " + kinesisRecordsBatch.getMessageOffsetAtIndex(i) + ", DATA: " + kinesisRecordsBatch + .getMessageAtIndex(i)); } kinesisConsumer.close(); } diff --git a/pinot-spi/src/main/java/org/apache/pinot/spi/stream/LongMsgOffset.java b/pinot-spi/src/main/java/org/apache/pinot/spi/stream/LongMsgOffset.java index e8fa275..a5fa722 100644 --- a/pinot-spi/src/main/java/org/apache/pinot/spi/stream/LongMsgOffset.java +++ b/pinot-spi/src/main/java/org/apache/pinot/spi/stream/LongMsgOffset.java @@ -1,8 +1,3 @@ -package org.apache.pinot.spi.stream; - -import com.google.common.annotations.VisibleForTesting; - - /** * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file @@ -21,6 +16,10 @@ import com.google.common.annotations.VisibleForTesting; * specific language governing permissions and limitations * under the License. */ +package org.apache.pinot.spi.stream; + +import com.google.common.annotations.VisibleForTesting; + public class LongMsgOffset implements StreamPartitionMsgOffset { private final long _offset; --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org For additional commands, e-mail: commits-h...@pinot.apache.org