You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@griffin.apache.org by gu...@apache.org on 2018/08/30 07:54:10 UTC
incubator-griffin git commit: fix license header
Repository: incubator-griffin
Updated Branches:
refs/heads/master 11ff412a5 -> 3922a90a8
fix license header
Author: William Guo <gu...@apache.org>
Closes #404 from guoyuepeng/fix_service_header.
Project: http://git-wip-us.apache.org/repos/asf/incubator-griffin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-griffin/commit/3922a90a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-griffin/tree/3922a90a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-griffin/diff/3922a90a
Branch: refs/heads/master
Commit: 3922a90a8aecfda84dbb5872fa7b844558c2075f
Parents: 11ff412
Author: William Guo <gu...@apache.org>
Authored: Thu Aug 30 15:54:03 2018 +0800
Committer: William Guo <gu...@apache.org>
Committed: Thu Aug 30 15:54:03 2018 +0800
----------------------------------------------------------------------
.../griffin/core/job/BatchJobOperatorImpl.java | 19 +++++
.../apache/griffin/core/job/entity/JobType.java | 19 +++++
.../griffin/core/job/repo/StreamingJobRepo.java | 19 +++++
.../resources/application-docker.properties | 76 ++++++++++++++++++++
.../core/job/FileExistPredicatorTest.java | 18 +++++
.../core/job/entity/JobScheduleTest.java | 18 +++++
6 files changed, 169 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java
----------------------------------------------------------------------
diff --git a/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java b/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java
index 5b2f816..0210822 100644
--- a/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java
+++ b/service/src/main/java/org/apache/griffin/core/job/BatchJobOperatorImpl.java
@@ -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.griffin.core.job;
import static org.apache.griffin.core.exception.GriffinExceptionMessage.INVALID_CONNECTOR_NAME;
http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java
----------------------------------------------------------------------
diff --git a/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java b/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java
index aa73c65..c76b0ee 100644
--- a/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java
+++ b/service/src/main/java/org/apache/griffin/core/job/entity/JobType.java
@@ -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.griffin.core.job.entity;
public enum JobType {
http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java
----------------------------------------------------------------------
diff --git a/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java b/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java
index a6b198b..866eed2 100644
--- a/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java
+++ b/service/src/main/java/org/apache/griffin/core/job/repo/StreamingJobRepo.java
@@ -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.griffin.core.job.repo;
import org.apache.griffin.core.job.entity.StreamingJob;
http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/main/resources/application-docker.properties
----------------------------------------------------------------------
diff --git a/service/src/main/resources/application-docker.properties b/service/src/main/resources/application-docker.properties
new file mode 100644
index 0000000..06e21b7
--- /dev/null
+++ b/service/src/main/resources/application-docker.properties
@@ -0,0 +1,76 @@
+#
+# 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.
+#
+
+spring.datasource.url = jdbc:postgresql://10.148.215.23:35432/quartz?autoReconnect=true&useSSL=false
+spring.datasource.username = griffin
+spring.datasource.password = 123456
+spring.jpa.generate-ddl=true
+
+spring.datasource.driver-class-name = org.postgresql.Driver
+
+spring.jpa.show-sql = true
+
+# Hive metastore
+hive.metastore.uris = thrift://10.148.215.23:39083
+hive.metastore.dbname = default
+hive.hmshandler.retry.attempts = 15
+hive.hmshandler.retry.interval = 2000ms
+# Hive cache time
+cache.evict.hive.fixedRate.in.milliseconds = 900000
+
+# Kafka schema registry
+kafka.schema.registry.url = http://localhost:8081
+
+# Update job instance state at regular intervals
+jobInstance.fixedDelay.in.milliseconds = 60000
+# Expired time of job instance which is 7 days that is 604800000 milliseconds.Time unit only supports milliseconds
+jobInstance.expired.milliseconds = 604800000
+
+# schedule predicate job every 5 minutes and repeat 12 times at most
+#interval time unit s:second m:minute h:hour d:day,only support these four units
+predicate.job.interval = 5m
+predicate.job.repeat.count = 12
+
+# external properties directory location
+external.config.location =
+
+# external BATCH or STREAMING env
+external.env.location =
+
+# login strategy ("default" or "ldap")
+login.strategy = default
+
+# ldap
+ldap.url = ldap://hostname:port
+ldap.email = @example.com
+ldap.searchBase = DC=org,DC=example
+ldap.searchPattern = (sAMAccountName={0})
+
+# elasticsearch
+elasticsearch.host = 10.148.215.23
+elasticsearch.port = 39200
+elasticsearch.scheme = http
+# elasticsearch.user = user
+# elasticsearch.password = password
+
+# livy
+livy.uri=http://10.148.215.23:38998/batches
+
+# yarn url
+yarn.uri=http://10.148.215.23:38088
http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java
----------------------------------------------------------------------
diff --git a/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java b/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java
index af981e3..44adc6c 100644
--- a/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java
+++ b/service/src/test/java/org/apache/griffin/core/job/FileExistPredicatorTest.java
@@ -1,3 +1,21 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership. The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied. See the License for the
+specific language governing permissions and limitations
+under the License.
+*/
package org.apache.griffin.core.job;
import static org.junit.Assert.assertFalse;
http://git-wip-us.apache.org/repos/asf/incubator-griffin/blob/3922a90a/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java
----------------------------------------------------------------------
diff --git a/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java b/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java
index d90c405..2ac93b5 100644
--- a/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java
+++ b/service/src/test/java/org/apache/griffin/core/job/entity/JobScheduleTest.java
@@ -1,3 +1,21 @@
+/*
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements. See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership. The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License. You may obtain a copy of the License at
+
+ http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied. See the License for the
+specific language governing permissions and limitations
+under the License.
+*/
package org.apache.griffin.core.job.entity;