Repository: crunch Updated Branches: refs/heads/master 157ae25b4 -> 597eadd65
CRUNCH-611: Corrected files that were missing the APL headers. Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/597eadd6 Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/597eadd6 Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/597eadd6 Branch: refs/heads/master Commit: 597eadd6570226f518aa0f97ee61c9d4dbc133e9 Parents: 157ae25 Author: Micah Whitacre <[email protected]> Authored: Tue Aug 2 15:58:29 2016 -0500 Committer: Micah Whitacre <[email protected]> Committed: Tue Aug 2 15:58:29 2016 -0500 ---------------------------------------------------------------------- .../crunch/kafka/offset/AbstractOffsetReader.java | 17 +++++++++++++++++ .../crunch/kafka/offset/AbstractOffsetWriter.java | 17 +++++++++++++++++ .../apache/crunch/kafka/offset/OffsetReader.java | 17 +++++++++++++++++ .../apache/crunch/kafka/offset/OffsetWriter.java | 17 +++++++++++++++++ .../kafka/offset/hdfs/HDFSOffsetReader.java | 17 +++++++++++++++++ .../kafka/offset/hdfs/HDFSOffsetWriter.java | 17 +++++++++++++++++ .../apache/crunch/kafka/offset/hdfs/Offsets.java | 17 +++++++++++++++++ .../kafka/offset/hdfs/HDFSOffsetReaderTest.java | 18 +++++++++++++++++- .../kafka/offset/hdfs/HDFSOffsetWriterTest.java | 17 +++++++++++++++++ .../crunch/kafka/offset/hdfs/OffsetsTest.java | 17 +++++++++++++++++ 10 files changed, 170 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetReader.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetReader.java b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetReader.java index 0856c64..e1a4883 100644 --- a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetReader.java +++ b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetReader.java @@ -1,3 +1,20 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset; import org.apache.kafka.common.TopicPartition; http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetWriter.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetWriter.java b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetWriter.java index 493a499..a7d3c49 100644 --- a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetWriter.java +++ b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/AbstractOffsetWriter.java @@ -1,3 +1,20 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset; import org.apache.kafka.common.TopicPartition; http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetReader.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetReader.java b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetReader.java index 4d4056b..b58dc27 100644 --- a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetReader.java +++ b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetReader.java @@ -1,3 +1,20 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset; import org.apache.kafka.common.TopicPartition; http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetWriter.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetWriter.java b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetWriter.java index 0f0056e..73816b3 100644 --- a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetWriter.java +++ b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/OffsetWriter.java @@ -1,3 +1,20 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset; import org.apache.kafka.common.TopicPartition; http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReader.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReader.java b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReader.java index a497570..9f84d0d 100644 --- a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReader.java +++ b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReader.java @@ -1,3 +1,20 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset.hdfs; http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriter.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriter.java b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriter.java index 9762d1d..f65529b 100644 --- a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriter.java +++ b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriter.java @@ -1,3 +1,20 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset.hdfs; import com.fasterxml.jackson.databind.ObjectMapper; http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/Offsets.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/Offsets.java b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/Offsets.java index e5c80e0..78034c1 100644 --- a/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/Offsets.java +++ b/crunch-kafka/src/main/java/org/apache/crunch/kafka/offset/hdfs/Offsets.java @@ -1,3 +1,20 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset.hdfs; import com.fasterxml.jackson.annotation.JsonIgnoreProperties; http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReaderTest.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReaderTest.java b/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReaderTest.java index faead74..a5b30c8 100644 --- a/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReaderTest.java +++ b/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetReaderTest.java @@ -1,6 +1,22 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset.hdfs; -import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.crunch.kafka.offset.OffsetReader; import org.apache.crunch.kafka.offset.OffsetWriter; import org.apache.hadoop.conf.Configuration; http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriterTest.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriterTest.java b/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriterTest.java index 70922d8..b555a41 100644 --- a/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriterTest.java +++ b/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/HDFSOffsetWriterTest.java @@ -1,3 +1,20 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset.hdfs; http://git-wip-us.apache.org/repos/asf/crunch/blob/597eadd6/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/OffsetsTest.java ---------------------------------------------------------------------- diff --git a/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/OffsetsTest.java b/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/OffsetsTest.java index e976da8..caad686 100644 --- a/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/OffsetsTest.java +++ b/crunch-kafka/src/test/java/org/apache/crunch/kafka/offset/hdfs/OffsetsTest.java @@ -1,3 +1,20 @@ +/** + * 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 + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * 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.crunch.kafka.offset.hdfs; import com.fasterxml.jackson.databind.ObjectMapper;
