[shardingsphere-elasticjob] branch master updated: Update example (#1307)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere-elasticjob.git


The following commit(s) were added to refs/heads/master by this push:
     new 8e51e59  Update example (#1307)
8e51e59 is described below

commit 8e51e59e501483c6e09c0351ca8225f33f6262ee
Author: Liang Zhang <terrym...@163.com>
AuthorDate: Fri Jul 31 15:38:16 2020 +0800

    Update example (#1307)
---
 .../apache/shardingsphere/elasticjob/lite/example/JavaMain.java   | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/examples/elasticjob-example-lite-java/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/JavaMain.java
 
b/examples/elasticjob-example-lite-java/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/JavaMain.java
index 0019d50..b93b79d 100644
--- 
a/examples/elasticjob-example-lite-java/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/JavaMain.java
+++ 
b/examples/elasticjob-example-lite-java/src/main/java/org/apache/shardingsphere/elasticjob/lite/example/JavaMain.java
@@ -61,7 +61,7 @@ public final class JavaMain {
     // CHECKSTYLE:ON
         EmbedZookeeperServer.start(EMBED_ZOOKEEPER_PORT);
         CoordinatorRegistryCenter regCenter = setUpRegistryCenter();
-        TracingConfiguration tracingConfig = new TracingConfiguration<>("RDB", 
setUpEventTraceDataSource());
+        TracingConfiguration<DataSource> tracingConfig = new 
TracingConfiguration<>("RDB", setUpEventTraceDataSource());
         setUpSimpleJob(regCenter, tracingConfig);
         setUpDataflowJob(regCenter, tracingConfig);
         setUpScriptJob(regCenter, tracingConfig);
@@ -83,18 +83,18 @@ public final class JavaMain {
         return result;
     }
     
-    private static void setUpSimpleJob(final CoordinatorRegistryCenter 
regCenter, final TracingConfiguration tracingConfig) {
+    private static void setUpSimpleJob(final CoordinatorRegistryCenter 
regCenter, final TracingConfiguration<DataSource> tracingConfig) {
         new ScheduleJobBootstrap(regCenter, new JavaSimpleJob(), 
JobConfiguration.newBuilder("javaSimpleJob", 3)
                 .cron("0/5 * * * * 
?").shardingItemParameters("0=Beijing,1=Shanghai,2=Guangzhou").build(), 
tracingConfig).schedule();
     }
     
-    private static void setUpDataflowJob(final CoordinatorRegistryCenter 
regCenter, final TracingConfiguration tracingConfig) {
+    private static void setUpDataflowJob(final CoordinatorRegistryCenter 
regCenter, final TracingConfiguration<DataSource> tracingConfig) {
         new ScheduleJobBootstrap(regCenter, new JavaDataflowJob(), 
JobConfiguration.newBuilder("javaDataflowElasticJob", 3)
                 .cron("0/5 * * * * 
?").shardingItemParameters("0=Beijing,1=Shanghai,2=Guangzhou")
                 .setProperty(DataflowJobProperties.STREAM_PROCESS_KEY, 
Boolean.TRUE.toString()).build(), tracingConfig).schedule();
     }
     
-    private static void setUpScriptJob(final CoordinatorRegistryCenter 
regCenter, final TracingConfiguration tracingConfig) throws IOException {
+    private static void setUpScriptJob(final CoordinatorRegistryCenter 
regCenter, final TracingConfiguration<DataSource> tracingConfig) throws 
IOException {
         new ScheduleJobBootstrap(regCenter, "SCRIPT", 
JobConfiguration.newBuilder("scriptElasticJob", 3)
                 .cron("0/5 * * * * 
?").setProperty(ScriptJobProperties.SCRIPT_KEY, 
buildScriptCommandLine()).build(), tracingConfig).schedule();
     }