diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadException.java b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadException.java index f00e17114c4..1ee743fb8f1 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadException.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadException.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.tools.predownload; public class PredownloadException extends RuntimeException { diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadMetrics.java b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadMetrics.java index d410991c36c..24d1ec31d64 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadMetrics.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadMetrics.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.tools.predownload; import java.util.concurrent.TimeUnit; diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadScheduler.java b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadScheduler.java index a7f59ec717a..1251862289c 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadScheduler.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/PredownloadScheduler.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.tools.predownload; import com.google.common.annotations.VisibleForTesting; @@ -244,7 +262,6 @@ public PredownloadCompleteReason downloadSegments() { }, _executor); // TODO: add future.orTimeout() to handle per segment downloading timeout - // Right now not able to use due to monorepo incapability with JAVA9+ syntax futures.add(future); } @@ -311,7 +328,6 @@ private File getTmpSegmentDataDir(SegmentInfo segmentInfo) if (tableInfo == null) { throw new PredownloadException("Table info not found for segment: " + segmentInfo.getSegmentName()); } - // TableDataManagerConfig is removed in 1.1: https://github.com/apache/pinot/pull/12189 String tableDataDir = tableInfo.getInstanceDataManagerConfig().getInstanceDataDir() + File.separator + tableInfo.getTableConfig() .getTableName(); diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/SegmentInfo.java b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/SegmentInfo.java index 90b34c6491a..b9266fba492 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/SegmentInfo.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/SegmentInfo.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.tools.predownload; import io.netty.util.internal.StringUtil; diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/StatusRecorder.java b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/StatusRecorder.java index 7e1667ea12f..9edca9faf60 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/StatusRecorder.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/StatusRecorder.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.tools.predownload; import com.google.common.annotations.VisibleForTesting; diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/TableInfo.java b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/TableInfo.java index b7fa2083886..709d97c7f7f 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/TableInfo.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/TableInfo.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.tools.predownload; import java.io.File; diff --git a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/ZKClient.java b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/ZKClient.java index 566b70ef448..9ab6534e176 100644 --- a/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/ZKClient.java +++ b/pinot-tools/src/main/java/org/apache/pinot/tools/predownload/ZKClient.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.tools.predownload; import java.util.ArrayList; diff --git a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/PredownloadSchedulerTest.java b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/PredownloadSchedulerTest.java index 2b6086c1823..3dac17e73fd 100644 --- a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/PredownloadSchedulerTest.java +++ b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/PredownloadSchedulerTest.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.tools.predownload; import java.io.File; diff --git a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/SegmentInfoTest.java b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/SegmentInfoTest.java index cb42714f7ca..d211442fb51 100644 --- a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/SegmentInfoTest.java +++ b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/SegmentInfoTest.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.tools.predownload; import org.apache.pinot.common.metadata.segment.SegmentZKMetadata; diff --git a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/StatusRecorderTest.java b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/StatusRecorderTest.java index 67bfb1e52b7..461ac276dbe 100644 --- a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/StatusRecorderTest.java +++ b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/StatusRecorderTest.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.tools.predownload; import java.io.File; diff --git a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/TableInfoTest.java b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/TableInfoTest.java index 6e5c8bdf92c..9058b2e81e0 100644 --- a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/TableInfoTest.java +++ b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/TableInfoTest.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.tools.predownload; import java.io.IOException; diff --git a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/TestUtil.java b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/TestUtil.java index 8b0a6a5c0f9..0fde65641e9 100644 --- a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/TestUtil.java +++ b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/TestUtil.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.tools.predownload; import org.apache.pinot.common.metadata.segment.SegmentZKMetadata; diff --git a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/ZKClientTest.java b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/ZKClientTest.java index 9faa6a39f85..cdd6b8409a9 100644 --- a/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/ZKClientTest.java +++ b/pinot-tools/src/test/java/org/apache/pinot/tools/predownload/ZKClientTest.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.tools.predownload; import java.util.Arrays;