File tree 1 file changed +32
-0
lines changed
seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/utils
1 file changed +32
-0
lines changed Original file line number Diff line number Diff line change
1
+ /*
2
+ * Licensed to the Apache Software Foundation (ASF) under one or more
3
+ * contributor license agreements. See the NOTICE file distributed with
4
+ * this work for additional information regarding copyright ownership.
5
+ * The ASF licenses this file to You under the Apache License, Version 2.0
6
+ * (the "License"); you may not use this file except in compliance with
7
+ * the License. You may obtain a copy of the License at
8
+ *
9
+ * http://www.apache.org/licenses/LICENSE-2.0
10
+ *
11
+ * Unless required by applicable law or agreed to in writing, software
12
+ * distributed under the License is distributed on an "AS IS" BASIS,
13
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14
+ * See the License for the specific language governing permissions and
15
+ * limitations under the License.
16
+ */
17
+
18
+ package org .apache .seatunnel .connectors .seatunnel .paimon .utils ;
19
+
20
+ import org .apache .seatunnel .api .common .JobContext ;
21
+ import org .apache .seatunnel .common .constants .JobMode ;
22
+
23
+ import lombok .extern .slf4j .Slf4j ;
24
+
25
+ /** Job env util */
26
+ @ Slf4j
27
+ public class JobContextUtil {
28
+
29
+ public static boolean isBatchJob (JobContext jobContext ) {
30
+ return jobContext .getJobMode ().equals (JobMode .BATCH );
31
+ }
32
+ }
You can’t perform that action at this time.
0 commit comments