tencent cloud

Stream Compute Service

Releases Notes and Announcements
Release Notes
Product Introduction
Overview
Strengths
Use Cases
Purchase Guide
Billing Overview
Billing Mode
Refund
Configuration Adjustments
Getting Started
Preparations
Creating a Private Cluster
Creating a SQL Job
Creating a JAR Job
Creating an ETL Job
Creating a Python Job
Operation Guide
Managing Jobs
Developing Jobs
Monitoring Jobs
Job Logs
Events and Diagnosis
Managing Metadata
Managing Checkpoints
Tuning Jobs
Managing Dependencies
Managing Clusters
Managing Permissions
SQL Developer Guide
Overview
Glossary and Data Types
DDL Statements
DML Statements
Merging MySQL CDC Sources
Connectors
SET Statement
Operators and Built-in Functions
Identifiers and Reserved Words
Python Developer Guide
ETL Developer Guide
Overview
Glossary
Connectors
FAQ
Contact Us
DocumentationStream Compute ServiceOperation GuideDeveloping JobsDeveloping Jobs in Batches

Developing Jobs in Batches

PDF
Focus Mode
Font Size
Last updated: 2023-11-08 10:09:02
Stream Compute Service supports development of batch jobs of the following types: JAR and Python.

JAR job

The following example shows how to configure the batch job execution mode in the JAR job code.
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setRuntimeMode(RuntimeExecutionMode.BATCH);
1. Change RuntimeExecutionMode.STREAMING to RuntimeExecutionMode.BATCH in a streaming job.
2. Package the modified job into a .jar file and upload it to Dependencies in the platform.
3. Use the uploaded .jar file to complete the development of the JAR batch job in the platform.

Python job

The following example shows how to configure the batch job execution mode in the Python job code.
env_settings = EnvironmentSettings.new_instance().in_batch_mode().use_blink_planner().build()
table_env = TableEnvironment.create(env_settings)
1. Change EnvironmentSettings.new_instance().in_streaming_mode() to EnvironmentSettings.new_instance().in_batch_mode() in a streaming job. For details, see Intro to the Python Table API.
2. Package the modified job into a .py file and upload it to Dependencies in the platform.
3. Use the uploaded .py file to complete the development of the Python batch job in the platform.
Previous Topic: Job OperationsNext Topic: Advanced Job Parameters

Help and Support

Was this page helpful?

Help us improve! Rate your documentation experience in 5 mins.

Feedback