Skip to content

Commit 145d008

Browse files
blackcode1blackcode1
committed
1
1 parent e80fb9b commit 145d008

File tree

74 files changed

+3670
-468
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

74 files changed

+3670
-468
lines changed

‎StreamProject/.idea/.gitignore‎

Lines changed: 0 additions & 2 deletions
This file was deleted.

‎StreamProject/.idea/StreamProject.iml‎

Lines changed: 0 additions & 2 deletions
This file was deleted.

‎StreamProject/.idea/vcs.xml‎

Lines changed: 0 additions & 6 deletions
This file was deleted.

‎StreamProject/.idea/workspace.xml‎

Lines changed: 1279 additions & 0 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

‎StreamProject/Engine.xml‎

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,12 @@
11
<root>
22
<flinkpath>/home/ubuntu/flink-1.9.1</flinkpath>
3-
<flinkurl>http://192.168.3.34:8081</flinkurl>
3+
<flinkurl>http://192.168.3.33:8081</flinkurl>
44
<flinkjarpath>/home/ubuntu/jar/StreamProject-1.0-SNAPSHOT.jar </flinkjarpath>
55
<flinksavepath>file://home/ubuntu/save</flinksavepath>
66
<engineurl>http://192.168.3.32:8000</engineurl>
77
<xmlrootpath>/home/ubuntu/engine/xml/</xmlrootpath>
88
<enginesavepath>/home/ubuntu/engine.db</enginesavepath>
9+
<stateurl>192.168.3.32,192.168.3.33,192.168.3.34</stateurl>
910
<hearttime>60000</hearttime>
1011
<datasets>
1112
<dataset type="stream" use="test">
@@ -21,6 +22,8 @@
2122
<topic>LocalTest</topic>
2223
<dataid>JSONObject</dataid>
2324
<group>asd</group>
25+
<offset>0</offset>
26+
<starttime>0</starttime>
2427
</dataset>
2528
<dataset type="stream" use="log">
2629
<uuid>log</uuid>
@@ -35,6 +38,8 @@
3538
<topic>EngineHeart</topic>
3639
<dataid>JSONObject</dataid>
3740
<group>asd</group>
41+
<offset>0</offset>
42+
<starttime>0</starttime>
3843
</dataset>
3944
<dataset type="relation">
4045
<uuid>conflist</uuid>

‎StreamProject/dependency-reduced-pom.xml‎

Lines changed: 0 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -23,16 +23,6 @@
2323
<goal>shade</goal>
2424
</goals>
2525
<configuration>
26-
<filters>
27-
<filter>
28-
<artifact>*:*</artifact>
29-
<excludes>
30-
<exclude>META-INF/*.SF</exclude>
31-
<exclude>META-INF/*.DSA</exclude>
32-
<exclude>META-INF/*.RSA</exclude>
33-
</excludes>
34-
</filter>
35-
</filters>
3626
<transformers>
3727
<transformer>
3828
<mainClass>StreamProjectInit.RunProject</mainClass>
@@ -44,14 +34,5 @@
4434
</plugin>
4535
</plugins>
4636
</build>
47-
<dependencies>
48-
<dependency>
49-
<groupId>com.microsoft.sqlserver</groupId>
50-
<artifactId>sqljdbc4</artifactId>
51-
<version>4.0</version>
52-
<scope>system</scope>
53-
<systemPath>${project.basedir}/lib/sqljdbc4.jar</systemPath>
54-
</dependency>
55-
</dependencies>
5637
</project>
5738

‎StreamProject/lib/sqljdbc4.jar‎

-525 KB
Binary file not shown.

‎StreamProject/pom.xml‎

Lines changed: 7 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -60,6 +60,11 @@
6060
<artifactId>fastjson</artifactId>
6161
<version>1.2.47</version>
6262
</dependency>
63+
<dependency>
64+
<groupId>ty</groupId>
65+
<artifactId>pub-interface</artifactId>
66+
<version>4.4</version>
67+
</dependency>
6368
<dependency>
6469
<groupId>org.apache.kafka</groupId>
6570
<artifactId>kafka_2.12</artifactId>
@@ -79,8 +84,6 @@
7984
<groupId>com.microsoft.sqlserver</groupId>
8085
<artifactId>sqljdbc4</artifactId>
8186
<version>4.0</version>
82-
<scope>system</scope>
83-
<systemPath>${project.basedir}/lib/sqljdbc4.jar</systemPath>
8487
</dependency>
8588
<dependency>
8689
<groupId>com.google.guava</groupId>
@@ -105,12 +108,12 @@
105108
<dependency>
106109
<groupId>org.apache.iotdb</groupId>
107110
<artifactId>iotdb-jdbc</artifactId>
108-
<version>0.9.0</version>
111+
<version>0.11.1</version>
109112
</dependency>
110113
<dependency>
111114
<groupId>org.apache.iotdb</groupId>
112115
<artifactId>iotdb-session</artifactId>
113-
<version>0.9.0</version>
116+
<version>0.11.1</version>
114117
</dependency>
115118
</dependencies>
116119

@@ -136,16 +139,6 @@
136139
<goal>shade</goal>
137140
</goals>
138141
<configuration>
139-
<filters>
140-
<filter>
141-
<artifact>*:*</artifact>
142-
<excludes>
143-
<exclude>META-INF/*.SF</exclude>
144-
<exclude>META-INF/*.DSA</exclude>
145-
<exclude>META-INF/*.RSA</exclude>
146-
</excludes>
147-
</filter>
148-
</filters>
149142
<transformers>
150143
<transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
151144
<mainClass>StreamProjectInit.RunProject</mainClass>

‎StreamProject/pytest.py‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
# coding=utf-8
2+
from sys import argv
3+
4+
def sum(x, y):
5+
print(x+y)
6+
return
7+
8+
num1 = argv[1]
9+
num2 = argv[2]
10+
sum(num1, num2)

‎StreamProject/pytest2.py‎

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
# coding=utf-8
2+
import sys
3+
sys.path.append('D:/FlinkProject/StreamProject')
4+
sys.path.append('C:/ProgramData/Anaconda3/lib/site-packages')
5+
from sum import sum
6+
import numpy
7+
8+
res = int(x) + int(y)
9+
print(res)
10+
sum(res, y)

0 commit comments

Comments
 (0)