http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/core/TimedQualifier.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/core/TimedQualifier.scala b/s2counter_core/src/main/scala/s2/counter/core/TimedQualifier.scala index b763bc2..e845746 100644 --- a/s2counter_core/src/main/scala/s2/counter/core/TimedQualifier.scala +++ b/s2counter_core/src/main/scala/s2/counter/core/TimedQualifier.scala @@ -1,3 +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 + * + * 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 s2.counter.core import java.text.SimpleDateFormat
http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/core/v1/BytesUtilV1.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/core/v1/BytesUtilV1.scala b/s2counter_core/src/main/scala/s2/counter/core/v1/BytesUtilV1.scala index 1b70f63..32668de 100644 --- a/s2counter_core/src/main/scala/s2/counter/core/v1/BytesUtilV1.scala +++ b/s2counter_core/src/main/scala/s2/counter/core/v1/BytesUtilV1.scala @@ -1,3 +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 + * + * 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 s2.counter.core.v1 import org.apache.hadoop.hbase.util.Bytes http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageAsyncHBase.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageAsyncHBase.scala b/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageAsyncHBase.scala index 6aae3cd..6437a04 100644 --- a/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageAsyncHBase.scala +++ b/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageAsyncHBase.scala @@ -1,3 +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 + * + * 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 s2.counter.core.v1 import java.util http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageHBase.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageHBase.scala b/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageHBase.scala index b946f0a..ea81b28 100644 --- a/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageHBase.scala +++ b/s2counter_core/src/main/scala/s2/counter/core/v1/ExactStorageHBase.scala @@ -1,3 +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 + * + * 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 s2.counter.core.v1 import com.typesafe.config.Config http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/core/v1/RankingStorageRedis.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/core/v1/RankingStorageRedis.scala b/s2counter_core/src/main/scala/s2/counter/core/v1/RankingStorageRedis.scala index ea15a9c..f6b153f 100644 --- a/s2counter_core/src/main/scala/s2/counter/core/v1/RankingStorageRedis.scala +++ b/s2counter_core/src/main/scala/s2/counter/core/v1/RankingStorageRedis.scala @@ -1,3 +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 + * + * 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 s2.counter.core.v1 import java.lang http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/core/v2/BytesUtilV2.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/core/v2/BytesUtilV2.scala b/s2counter_core/src/main/scala/s2/counter/core/v2/BytesUtilV2.scala index f839221..0691f5b 100644 --- a/s2counter_core/src/main/scala/s2/counter/core/v2/BytesUtilV2.scala +++ b/s2counter_core/src/main/scala/s2/counter/core/v2/BytesUtilV2.scala @@ -1,3 +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 + * + * 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 s2.counter.core.v2 import org.apache.hadoop.hbase.util._ http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/core/v2/ExactStorageGraph.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/core/v2/ExactStorageGraph.scala b/s2counter_core/src/main/scala/s2/counter/core/v2/ExactStorageGraph.scala index e7b674a..89d3b00 100644 --- a/s2counter_core/src/main/scala/s2/counter/core/v2/ExactStorageGraph.scala +++ b/s2counter_core/src/main/scala/s2/counter/core/v2/ExactStorageGraph.scala @@ -1,3 +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 + * + * 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 s2.counter.core.v2 import com.kakao.s2graph.core.mysqls.Label http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/core/v2/GraphOperation.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/core/v2/GraphOperation.scala b/s2counter_core/src/main/scala/s2/counter/core/v2/GraphOperation.scala index 0f43a52..3fafbf5 100644 --- a/s2counter_core/src/main/scala/s2/counter/core/v2/GraphOperation.scala +++ b/s2counter_core/src/main/scala/s2/counter/core/v2/GraphOperation.scala @@ -1,3 +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 + * + * 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 s2.counter.core.v2 import com.typesafe.config.Config http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/core/v2/RankingStorageGraph.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/core/v2/RankingStorageGraph.scala b/s2counter_core/src/main/scala/s2/counter/core/v2/RankingStorageGraph.scala index 4bed8ab..74d7454 100644 --- a/s2counter_core/src/main/scala/s2/counter/core/v2/RankingStorageGraph.scala +++ b/s2counter_core/src/main/scala/s2/counter/core/v2/RankingStorageGraph.scala @@ -1,3 +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 + * + * 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 s2.counter.core.v2 import com.kakao.s2graph.core.GraphUtil http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/decay/DecayFormula.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/decay/DecayFormula.scala b/s2counter_core/src/main/scala/s2/counter/decay/DecayFormula.scala index 66e1b93..f3cbf0f 100644 --- a/s2counter_core/src/main/scala/s2/counter/decay/DecayFormula.scala +++ b/s2counter_core/src/main/scala/s2/counter/decay/DecayFormula.scala @@ -1,3 +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 + * + * 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 s2.counter.decay /** http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/decay/ExpDecayFormula.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/decay/ExpDecayFormula.scala b/s2counter_core/src/main/scala/s2/counter/decay/ExpDecayFormula.scala index 6de9f69..47eefde 100644 --- a/s2counter_core/src/main/scala/s2/counter/decay/ExpDecayFormula.scala +++ b/s2counter_core/src/main/scala/s2/counter/decay/ExpDecayFormula.scala @@ -1,3 +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 + * + * 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 s2.counter.decay /** http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/counter/package.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/counter/package.scala b/s2counter_core/src/main/scala/s2/counter/package.scala index 40a9e41..3fc77ae 100644 --- a/s2counter_core/src/main/scala/s2/counter/package.scala +++ b/s2counter_core/src/main/scala/s2/counter/package.scala @@ -1,3 +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 + * + * 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 s2 /** http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/helper/CounterAdmin.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/helper/CounterAdmin.scala b/s2counter_core/src/main/scala/s2/helper/CounterAdmin.scala index 8547bc8..11c65fc 100644 --- a/s2counter_core/src/main/scala/s2/helper/CounterAdmin.scala +++ b/s2counter_core/src/main/scala/s2/helper/CounterAdmin.scala @@ -1,3 +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 + * + * 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 s2.helper import com.kakao.s2graph.core.mysqls.Label http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/helper/DistributedScanner.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/helper/DistributedScanner.scala b/s2counter_core/src/main/scala/s2/helper/DistributedScanner.scala index dcf4d03..fa961f9 100644 --- a/s2counter_core/src/main/scala/s2/helper/DistributedScanner.scala +++ b/s2counter_core/src/main/scala/s2/helper/DistributedScanner.scala @@ -1,3 +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 + * + * 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 s2.helper import java.util http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/helper/HashShardingJedis.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/helper/HashShardingJedis.scala b/s2counter_core/src/main/scala/s2/helper/HashShardingJedis.scala index 395486d..ac2343a 100644 --- a/s2counter_core/src/main/scala/s2/helper/HashShardingJedis.scala +++ b/s2counter_core/src/main/scala/s2/helper/HashShardingJedis.scala @@ -1,3 +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 + * + * 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 s2.helper import com.typesafe.config.Config http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/helper/Management.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/helper/Management.scala b/s2counter_core/src/main/scala/s2/helper/Management.scala index 266caba..bb4709d 100644 --- a/s2counter_core/src/main/scala/s2/helper/Management.scala +++ b/s2counter_core/src/main/scala/s2/helper/Management.scala @@ -1,3 +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 + * + * 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 s2.helper import com.typesafe.config.Config http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/helper/WithHBase.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/helper/WithHBase.scala b/s2counter_core/src/main/scala/s2/helper/WithHBase.scala index ae3ff1e..1ffa609 100644 --- a/s2counter_core/src/main/scala/s2/helper/WithHBase.scala +++ b/s2counter_core/src/main/scala/s2/helper/WithHBase.scala @@ -1,3 +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 + * + * 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 s2.helper import com.stumbleupon.async.{Callback, Deferred} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/helper/WithRedis.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/helper/WithRedis.scala b/s2counter_core/src/main/scala/s2/helper/WithRedis.scala index 2046577..1dddd03 100644 --- a/s2counter_core/src/main/scala/s2/helper/WithRedis.scala +++ b/s2counter_core/src/main/scala/s2/helper/WithRedis.scala @@ -1,3 +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 + * + * 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 s2.helper import com.typesafe.config.Config http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/models/CachedDBModel.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/models/CachedDBModel.scala b/s2counter_core/src/main/scala/s2/models/CachedDBModel.scala index 5da0265..0872906 100644 --- a/s2counter_core/src/main/scala/s2/models/CachedDBModel.scala +++ b/s2counter_core/src/main/scala/s2/models/CachedDBModel.scala @@ -1,3 +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 + * + * 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 s2.models import s2.util.{CollectionCache, CollectionCacheConfig} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/models/Counter.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/models/Counter.scala b/s2counter_core/src/main/scala/s2/models/Counter.scala index e26e071..7620e5d 100644 --- a/s2counter_core/src/main/scala/s2/models/Counter.scala +++ b/s2counter_core/src/main/scala/s2/models/Counter.scala @@ -1,3 +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 + * + * 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 s2.models import com.typesafe.config.Config http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/models/DBModel.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/models/DBModel.scala b/s2counter_core/src/main/scala/s2/models/DBModel.scala index 6cb34b9..37ffaf9 100644 --- a/s2counter_core/src/main/scala/s2/models/DBModel.scala +++ b/s2counter_core/src/main/scala/s2/models/DBModel.scala @@ -1,3 +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 + * + * 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 s2.models import com.typesafe.config.Config http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/util/CartesianProduct.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/util/CartesianProduct.scala b/s2counter_core/src/main/scala/s2/util/CartesianProduct.scala index 2077e3f..0de1cff 100644 --- a/s2counter_core/src/main/scala/s2/util/CartesianProduct.scala +++ b/s2counter_core/src/main/scala/s2/util/CartesianProduct.scala @@ -1,3 +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 + * + * 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 s2.util /** http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/util/CollectionCache.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/util/CollectionCache.scala b/s2counter_core/src/main/scala/s2/util/CollectionCache.scala index 122f87a..92624bc 100644 --- a/s2counter_core/src/main/scala/s2/util/CollectionCache.scala +++ b/s2counter_core/src/main/scala/s2/util/CollectionCache.scala @@ -1,3 +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 + * + * 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 s2.util import java.net.InetAddress http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/util/FunctionParser.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/util/FunctionParser.scala b/s2counter_core/src/main/scala/s2/util/FunctionParser.scala index 2454b0f..b3c8f5b 100644 --- a/s2counter_core/src/main/scala/s2/util/FunctionParser.scala +++ b/s2counter_core/src/main/scala/s2/util/FunctionParser.scala @@ -1,3 +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 + * + * 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 s2.util /** http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/util/Hashes.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/util/Hashes.scala b/s2counter_core/src/main/scala/s2/util/Hashes.scala index 2edbcd8..b36817c 100644 --- a/s2counter_core/src/main/scala/s2/util/Hashes.scala +++ b/s2counter_core/src/main/scala/s2/util/Hashes.scala @@ -1,3 +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 + * + * 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 s2.util import org.apache.hadoop.hbase.util.Bytes http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/util/ReduceMapValue.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/util/ReduceMapValue.scala b/s2counter_core/src/main/scala/s2/util/ReduceMapValue.scala index 9c13fa0..3b24750 100644 --- a/s2counter_core/src/main/scala/s2/util/ReduceMapValue.scala +++ b/s2counter_core/src/main/scala/s2/util/ReduceMapValue.scala @@ -1,3 +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 + * + * 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 s2.util /** http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/util/Retry.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/util/Retry.scala b/s2counter_core/src/main/scala/s2/util/Retry.scala index d1f7213..946f300 100644 --- a/s2counter_core/src/main/scala/s2/util/Retry.scala +++ b/s2counter_core/src/main/scala/s2/util/Retry.scala @@ -1,3 +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 + * + * 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 s2.util import scala.annotation.tailrec http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/util/SplitBytes.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/util/SplitBytes.scala b/s2counter_core/src/main/scala/s2/util/SplitBytes.scala index a5ca998..739a838 100644 --- a/s2counter_core/src/main/scala/s2/util/SplitBytes.scala +++ b/s2counter_core/src/main/scala/s2/util/SplitBytes.scala @@ -1,3 +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 + * + * 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 s2.util /** http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/main/scala/s2/util/UnitConverter.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/main/scala/s2/util/UnitConverter.scala b/s2counter_core/src/main/scala/s2/util/UnitConverter.scala index fb0b0d0..059d465 100644 --- a/s2counter_core/src/main/scala/s2/util/UnitConverter.scala +++ b/s2counter_core/src/main/scala/s2/util/UnitConverter.scala @@ -1,3 +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 + * + * 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 s2.util /** http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/test/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/s2counter_core/src/test/resources/log4j.properties b/s2counter_core/src/test/resources/log4j.properties old mode 100755 new mode 100644 index 4af1b0c..afb3cef --- a/s2counter_core/src/test/resources/log4j.properties +++ b/s2counter_core/src/test/resources/log4j.properties @@ -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 +# +# 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. + log4j.rootLogger=${root.logger} root.logger=WARN,console log4j.appender.console=org.apache.log4j.ConsoleAppender http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/test/scala/s2/counter/core/RankingCounterSpec.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/test/scala/s2/counter/core/RankingCounterSpec.scala b/s2counter_core/src/test/scala/s2/counter/core/RankingCounterSpec.scala index dd6a6bf..09d42d4 100644 --- a/s2counter_core/src/test/scala/s2/counter/core/RankingCounterSpec.scala +++ b/s2counter_core/src/test/scala/s2/counter/core/RankingCounterSpec.scala @@ -1,3 +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 + * + * 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 s2.counter.core import com.kakao.s2graph.core.mysqls.Label http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/test/scala/s2/models/CounterModelSpec.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/test/scala/s2/models/CounterModelSpec.scala b/s2counter_core/src/test/scala/s2/models/CounterModelSpec.scala index dff55ef..fa24fa5 100644 --- a/s2counter_core/src/test/scala/s2/models/CounterModelSpec.scala +++ b/s2counter_core/src/test/scala/s2/models/CounterModelSpec.scala @@ -1,3 +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 + * + * 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 s2.models import com.typesafe.config.ConfigFactory http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_core/src/test/scala/s2/models/CounterSpec.scala ---------------------------------------------------------------------- diff --git a/s2counter_core/src/test/scala/s2/models/CounterSpec.scala b/s2counter_core/src/test/scala/s2/models/CounterSpec.scala index a03c70e..18eb76f 100644 --- a/s2counter_core/src/test/scala/s2/models/CounterSpec.scala +++ b/s2counter_core/src/test/scala/s2/models/CounterSpec.scala @@ -1,3 +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 + * + * 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 s2.models import org.specs2.mutable.Specification http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/config/StreamingConfig.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/config/StreamingConfig.scala b/s2counter_loader/src/main/scala/s2/config/StreamingConfig.scala index 0880bdd..26c486f 100644 --- a/s2counter_loader/src/main/scala/s2/config/StreamingConfig.scala +++ b/s2counter_loader/src/main/scala/s2/config/StreamingConfig.scala @@ -1,3 +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 + * + * 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 s2.config /** http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/CounterBulkLoader.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/CounterBulkLoader.scala b/s2counter_loader/src/main/scala/s2/counter/CounterBulkLoader.scala index 2843022..b950b66 100644 --- a/s2counter_loader/src/main/scala/s2/counter/CounterBulkLoader.scala +++ b/s2counter_loader/src/main/scala/s2/counter/CounterBulkLoader.scala @@ -1,3 +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 + * + * 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 s2.counter import com.kakao.s2graph.core.{Graph, GraphUtil} @@ -75,4 +94,4 @@ object CounterBulkLoader extends SparkApp with WithKafka { CounterFunctions.updateRankingCounter(part, acc) } } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/EraseDailyCounter.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/EraseDailyCounter.scala b/s2counter_loader/src/main/scala/s2/counter/EraseDailyCounter.scala index 71784fa..278fb3d 100644 --- a/s2counter_loader/src/main/scala/s2/counter/EraseDailyCounter.scala +++ b/s2counter_loader/src/main/scala/s2/counter/EraseDailyCounter.scala @@ -1,3 +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 + * + * 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 s2.counter import java.text.SimpleDateFormat http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlFunctions.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlFunctions.scala b/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlFunctions.scala index cefce65..5daf329 100644 --- a/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlFunctions.scala +++ b/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlFunctions.scala @@ -1,3 +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 + * + * 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 s2.counter.core import com.kakao.s2graph.core.{Edge, Graph, GraphUtil} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlItem.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlItem.scala b/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlItem.scala index 1b0f3cd..c5f072c 100644 --- a/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlItem.scala +++ b/s2counter_loader/src/main/scala/s2/counter/core/CounterEtlItem.scala @@ -1,3 +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 + * + * 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 s2.counter.core import org.slf4j.LoggerFactory http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/core/CounterFunctions.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/core/CounterFunctions.scala b/s2counter_loader/src/main/scala/s2/counter/core/CounterFunctions.scala index 32e3d0c..709d690 100644 --- a/s2counter_loader/src/main/scala/s2/counter/core/CounterFunctions.scala +++ b/s2counter_loader/src/main/scala/s2/counter/core/CounterFunctions.scala @@ -1,3 +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 + * + * 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 s2.counter.core import com.kakao.s2graph.core.GraphUtil http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/core/DimensionProps.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/core/DimensionProps.scala b/s2counter_loader/src/main/scala/s2/counter/core/DimensionProps.scala index 98bc750..bc155a0 100644 --- a/s2counter_loader/src/main/scala/s2/counter/core/DimensionProps.scala +++ b/s2counter_loader/src/main/scala/s2/counter/core/DimensionProps.scala @@ -1,3 +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 + * + * 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 s2.counter.core import com.kakao.s2graph.core.mysqls.{Bucket, Experiment, Service} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/stream/EtlStreaming.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/stream/EtlStreaming.scala b/s2counter_loader/src/main/scala/s2/counter/stream/EtlStreaming.scala index 03c42b5..6ec9123 100644 --- a/s2counter_loader/src/main/scala/s2/counter/stream/EtlStreaming.scala +++ b/s2counter_loader/src/main/scala/s2/counter/stream/EtlStreaming.scala @@ -1,3 +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 + * + * 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 s2.counter.stream import com.kakao.s2graph.core.{Graph, GraphUtil} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/stream/ExactCounterStreaming.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/stream/ExactCounterStreaming.scala b/s2counter_loader/src/main/scala/s2/counter/stream/ExactCounterStreaming.scala index 2b8ba21..9a2922d 100644 --- a/s2counter_loader/src/main/scala/s2/counter/stream/ExactCounterStreaming.scala +++ b/s2counter_loader/src/main/scala/s2/counter/stream/ExactCounterStreaming.scala @@ -1,3 +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 + * + * 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 s2.counter.stream import kafka.serializer.StringDecoder http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/stream/GraphToETLStreaming.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/stream/GraphToETLStreaming.scala b/s2counter_loader/src/main/scala/s2/counter/stream/GraphToETLStreaming.scala index 39654d3..d2de9be 100644 --- a/s2counter_loader/src/main/scala/s2/counter/stream/GraphToETLStreaming.scala +++ b/s2counter_loader/src/main/scala/s2/counter/stream/GraphToETLStreaming.scala @@ -1,3 +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 + * + * 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 s2.counter.stream import com.kakao.s2graph.core.GraphUtil http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/counter/stream/RankingCounterStreaming.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/counter/stream/RankingCounterStreaming.scala b/s2counter_loader/src/main/scala/s2/counter/stream/RankingCounterStreaming.scala index 4c0b927..0e9e53d 100644 --- a/s2counter_loader/src/main/scala/s2/counter/stream/RankingCounterStreaming.scala +++ b/s2counter_loader/src/main/scala/s2/counter/stream/RankingCounterStreaming.scala @@ -1,3 +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 + * + * 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 s2.counter.stream import kafka.serializer.StringDecoder http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/main/scala/s2/models/DefaultCounterModel.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/main/scala/s2/models/DefaultCounterModel.scala b/s2counter_loader/src/main/scala/s2/models/DefaultCounterModel.scala index 9cbe212..e30eb35 100644 --- a/s2counter_loader/src/main/scala/s2/models/DefaultCounterModel.scala +++ b/s2counter_loader/src/main/scala/s2/models/DefaultCounterModel.scala @@ -1,3 +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 + * + * 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 s2.models import s2.config.S2ConfigFactory http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/test/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/test/resources/log4j.properties b/s2counter_loader/src/test/resources/log4j.properties old mode 100755 new mode 100644 index ac1e66e..b4d4b33 --- a/s2counter_loader/src/test/resources/log4j.properties +++ b/s2counter_loader/src/test/resources/log4j.properties @@ -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 +# +# 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. + log4j.rootLogger=${root.logger} root.logger=WARN,console log4j.appender.console=org.apache.log4j.ConsoleAppender http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/test/scala/s2/counter/core/CounterEtlFunctionsSpec.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/test/scala/s2/counter/core/CounterEtlFunctionsSpec.scala b/s2counter_loader/src/test/scala/s2/counter/core/CounterEtlFunctionsSpec.scala index 520b30f..bd492be 100644 --- a/s2counter_loader/src/test/scala/s2/counter/core/CounterEtlFunctionsSpec.scala +++ b/s2counter_loader/src/test/scala/s2/counter/core/CounterEtlFunctionsSpec.scala @@ -1,3 +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 + * + * 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 s2.counter.core import com.typesafe.config.ConfigFactory http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/test/scala/s2/counter/core/DimensionPropsTest.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/test/scala/s2/counter/core/DimensionPropsTest.scala b/s2counter_loader/src/test/scala/s2/counter/core/DimensionPropsTest.scala index b658d05..a8e03a6 100644 --- a/s2counter_loader/src/test/scala/s2/counter/core/DimensionPropsTest.scala +++ b/s2counter_loader/src/test/scala/s2/counter/core/DimensionPropsTest.scala @@ -1,3 +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 + * + * 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 s2.counter.core import org.scalatest.{FunSuite, Matchers} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/s2counter_loader/src/test/scala/s2/counter/stream/RankingCounterStreamingSpec.scala ---------------------------------------------------------------------- diff --git a/s2counter_loader/src/test/scala/s2/counter/stream/RankingCounterStreamingSpec.scala b/s2counter_loader/src/test/scala/s2/counter/stream/RankingCounterStreamingSpec.scala index 434673d..30fc636 100644 --- a/s2counter_loader/src/test/scala/s2/counter/stream/RankingCounterStreamingSpec.scala +++ b/s2counter_loader/src/test/scala/s2/counter/stream/RankingCounterStreamingSpec.scala @@ -1,3 +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 + * + * 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 s2.counter.stream import com.kakao.s2graph.core.mysqls.Label http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/script/test.sh ---------------------------------------------------------------------- diff --git a/script/test.sh b/script/test.sh index ed08307..eba3934 100644 --- a/script/test.sh +++ b/script/test.sh @@ -1,4 +1,20 @@ #!/usr/bin/env bash +# 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. # create service. curl -XPOST localhost:9000/graphs/createService -H 'Content-Type: Application/json' -d ' {"serviceName": "s2graph", "compressionAlgorithm" : "gz"} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/main/scala/kafka/KafkaHelper.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/kafka/KafkaHelper.scala b/spark/src/main/scala/kafka/KafkaHelper.scala index af96ef5..0609f58 100644 --- a/spark/src/main/scala/kafka/KafkaHelper.scala +++ b/spark/src/main/scala/kafka/KafkaHelper.scala @@ -1,3 +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 + * + * 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 kafka import java.net.InetAddress http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDFunctions.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDFunctions.scala b/spark/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDFunctions.scala index 56be543..884a963 100644 --- a/spark/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDFunctions.scala +++ b/spark/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDFunctions.scala @@ -1,3 +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 + * + * 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.spark.streaming.kafka import org.apache.spark.Logging http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/main/scala/org/apache/spark/streaming/kafka/StreamHelper.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/org/apache/spark/streaming/kafka/StreamHelper.scala b/spark/src/main/scala/org/apache/spark/streaming/kafka/StreamHelper.scala index 782f87f..607ee96 100644 --- a/spark/src/main/scala/org/apache/spark/streaming/kafka/StreamHelper.scala +++ b/spark/src/main/scala/org/apache/spark/streaming/kafka/StreamHelper.scala @@ -1,3 +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 + * + * 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.spark.streaming.kafka import kafka.KafkaHelper http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/main/scala/s2/config/S2ConfigFactory.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/s2/config/S2ConfigFactory.scala b/spark/src/main/scala/s2/config/S2ConfigFactory.scala index 7666cdc..59dd733 100644 --- a/spark/src/main/scala/s2/config/S2ConfigFactory.scala +++ b/spark/src/main/scala/s2/config/S2ConfigFactory.scala @@ -1,3 +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 + * + * 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 s2.config import com.typesafe.config.{Config, ConfigFactory} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/main/scala/s2/spark/HashMapParam.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/s2/spark/HashMapParam.scala b/spark/src/main/scala/s2/spark/HashMapParam.scala index a84c687..2a696ea 100644 --- a/spark/src/main/scala/s2/spark/HashMapParam.scala +++ b/spark/src/main/scala/s2/spark/HashMapParam.scala @@ -1,3 +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 + * + * 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 s2.spark import org.apache.spark.serializer.JavaSerializer @@ -52,4 +71,4 @@ object HashMapParam { def apply[K, V](op: (V, V) => V): HashMapParam[K, V] = { new HashMapParam[K, V](op) } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/main/scala/s2/spark/RDDUtil.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/s2/spark/RDDUtil.scala b/spark/src/main/scala/s2/spark/RDDUtil.scala index c5a371a..86416e9 100644 --- a/spark/src/main/scala/s2/spark/RDDUtil.scala +++ b/spark/src/main/scala/s2/spark/RDDUtil.scala @@ -1,3 +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 + * + * 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 s2.spark import org.apache.spark.rdd.RDD http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/main/scala/s2/spark/SparkApp.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/s2/spark/SparkApp.scala b/spark/src/main/scala/s2/spark/SparkApp.scala index e27b7ec..bb96641 100644 --- a/spark/src/main/scala/s2/spark/SparkApp.scala +++ b/spark/src/main/scala/s2/spark/SparkApp.scala @@ -1,3 +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 + * + * 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 s2.spark import kafka.serializer.StringDecoder http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/main/scala/s2/spark/SubscriberListener.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/s2/spark/SubscriberListener.scala b/spark/src/main/scala/s2/spark/SubscriberListener.scala index 9e156a7..a3b201b 100644 --- a/spark/src/main/scala/s2/spark/SubscriberListener.scala +++ b/spark/src/main/scala/s2/spark/SubscriberListener.scala @@ -1,3 +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 + * + * 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 s2.spark import org.apache.spark.Logging http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/main/scala/s2/spark/WithKafka.scala ---------------------------------------------------------------------- diff --git a/spark/src/main/scala/s2/spark/WithKafka.scala b/spark/src/main/scala/s2/spark/WithKafka.scala index 9bd5944..7a23ccd 100644 --- a/spark/src/main/scala/s2/spark/WithKafka.scala +++ b/spark/src/main/scala/s2/spark/WithKafka.scala @@ -1,3 +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 + * + * 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 s2.spark import java.util.Properties @@ -66,4 +85,4 @@ trait WithKafka { groupId } -} \ No newline at end of file +} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/test/scala/s2/spark/SparkAppTest.scala ---------------------------------------------------------------------- diff --git a/spark/src/test/scala/s2/spark/SparkAppTest.scala b/spark/src/test/scala/s2/spark/SparkAppTest.scala index 6bf2482..2511e1a 100644 --- a/spark/src/test/scala/s2/spark/SparkAppTest.scala +++ b/spark/src/test/scala/s2/spark/SparkAppTest.scala @@ -1,3 +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 + * + * 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 s2.spark import org.scalatest.{FunSuite, Matchers} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/spark/src/test/scala/s2/spark/TestStreamingSpec.scala ---------------------------------------------------------------------- diff --git a/spark/src/test/scala/s2/spark/TestStreamingSpec.scala b/spark/src/test/scala/s2/spark/TestStreamingSpec.scala index bf15618..d7b9e95 100644 --- a/spark/src/test/scala/s2/spark/TestStreamingSpec.scala +++ b/spark/src/test/scala/s2/spark/TestStreamingSpec.scala @@ -1,3 +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 + * + * 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 s2.spark import org.apache.spark.streaming.{Seconds, StreamingContext} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/test.sh ---------------------------------------------------------------------- diff --git a/test.sh b/test.sh index deadae4..ecb6425 100644 --- a/test.sh +++ b/test.sh @@ -1,3 +1,19 @@ +# 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. curl -XPOST localhost:9000/graphs/edges/insert -H 'Content-Type: Application/json' -d ' [ {"timestamp": 1447493110829, "from": 7007, "to": "700710007abc", "label": "s2graph_label_test_2", "props": {"time": 10}} http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/8c04784a/test/benchmark/BenchmarkCommon.scala ---------------------------------------------------------------------- diff --git a/test/benchmark/BenchmarkCommon.scala b/test/benchmark/BenchmarkCommon.scala index cd465e8..e53bf1a 100644 --- a/test/benchmark/BenchmarkCommon.scala +++ b/test/benchmark/BenchmarkCommon.scala @@ -1,3 +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 + * + * 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 benchmark import org.specs2.mutable.Specification
