crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mkw...@apache.org
Subject crunch git commit: CRUNCH-611: Corrected files that were missing the APL headers.
Date Tue, 02 Aug 2016 20:58:39 GMT
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 <mkwhit@gmail.com>
Authored: Tue Aug 2 15:58:29 2016 -0500
Committer: Micah Whitacre <mkwhit@gmail.com>
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;


Mime
View raw message