Scalable Stream Processing - Spark Streaming and Flink
computation as a series of very small, deterministic batch jobs. • Chops up the live stream into batches of X seconds. • Treats each batch as RDDs and processes them using RDD operations. • Discretized computation as a series of very small, deterministic batch jobs. • Chops up the live stream into batches of X seconds. • Treats each batch as RDDs and processes them using RDD operations. • Discretized computation as a series of very small, deterministic batch jobs. • Chops up the live stream into batches of X seconds. • Treats each batch as RDDs and processes them using RDD operations. • Discretized0 码力 | 113 页 | 1.22 MB | 1 年前3Celery 2.4 Documentation
. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 260 10.23 celery.contrib.batches . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 262 10.24 celery passing tests. 9.13.3 Fixes • celeryev was trying to create the pidfile twice. • celery.contrib.batches: Fixed problem where tasks failed silently (Issue #393). • Fixed an issue where logging objects user-friendly error message if the result backend name is unknown (Issue #349). • celery.contrib.batches: Now sets loglevel and logfile in the task request so task.get_logger works with batch tasks (Issue0 码力 | 395 页 | 1.54 MB | 1 年前3firebird wire protocol
. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 25 8. Batches . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . Generic response — where Object id is the array handle. Chapter 7. Arrays 26 Chapter 8. Batches Statement batches were introduced in protocol v16 (Firebird 4.0). 8.1. Create Client Int32 Operation values (formatted message repeats 'Number of messages' times) Server Generic response Chapter 8. Batches 27 8.3. Execute batch Client Int32 Operation code (op_batch_exec) Int32 Statement handle0 码力 | 40 页 | 213.15 KB | 1 年前3Celery 3.1 Documentation
deserialization when using the JSON serializer (Issue #1987). • Eventlet: Fixes crash when celery.contrib.batches attempted to cancel a non-existing timer (Issue #1984). • Can now import celery.version_info_t, it regularly (for responsiveness), but not too often (for performance). 2.14.26 celery.contrib.batches Experimental task class that buffers messages and processes them as a list. Warning: For this to Celery Documentation, Release 3.1.25 # Flush after 100 messages, or 10 seconds. @app.task(base=Batches, flush_every=100, flush_interval=10) def count_click(requests): from collections import Counter0 码力 | 607 页 | 2.27 MB | 1 年前3Apache Kyuubi 1.9.0-SNAPSHOT Documentation
3.2 or higher versions. Upgrading from Kyuubi 1.8.0 to 1.8.1 • Since Kyuubi 1.8.1, for DELETE /batches/${batchId}, hive.server2.proxy.user is not needed in the request parameters. • Since Kyuubi 1.8 Request Parameters Response Body Batch Resource GET /batches Returns all the batches. Request Parameters Response Body POST /batches Create a new batch. 122 Chapter 3. What’s Next Kyuubi, Release created Batch object. POST /batches (with uploading resource) Create a new batch with uploading resource file. Example of using curl command to send POST request to /v1/batches in multipart-formdata media0 码力 | 220 页 | 3.93 MB | 1 年前3Apache Kyuubi 1.8.1 Documentation
Kyuubi Migration Guide Upgrading from Kyuubi 1.8.0 to 1.8.1 • Since Kyuubi 1.8.1, for DELETE /batches/${batchId}, hive.server2.proxy.user is not needed in the request parameters. • Since Kyuubi 1.8 Request Parameters Response Body Batch Resource GET /batches Returns all the batches. Request Parameters Response Body POST /batches Create a new batch. 3.7. Clients 123 Kyuubi, Release 1.8 created Batch object. POST /batches (with uploading resource) Create a new batch with uploading resource file. Example of using curl command to send POST request to /v1/batches in multipart-formdata media0 码力 | 222 页 | 3.84 MB | 1 年前3Spring Framwork Data Access v5.3.36 SNAPSHOT
. . . . . . . . . . . . . . . . . . . . . . . . . . 95 3.5.3. Batch Operations with Multiple Batches. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 98 3.6. performance if you batch multiple calls to the same prepared statement. By grouping updates into batches, you limit the number of round trips to the database. 3.5.1. Basic Batch Operations with JdbcTemplate Batch Operations with Multiple Batches The preceding example of a batch update deals with batches that are so large that you want to break them up into several smaller batches. You can do this with the methods0 码力 | 197 页 | 2.76 MB | 1 年前3Apache Kyuubi 1.7.0-rc1 Documentation
Request Parameters Response Body Batch Resource GET /batches Returns all the batches. Request Parameters Response Body POST /batches Create a new batch. 3.6. Clients 117 Kyuubi, Release 1.7 created Batch object. POST /batches (with uploading resource) Create a new batch with uploading resource file. Example of using curl command to send POST request to /v1/batches in multipart-formdata media uploading resource file from local path. curl --location --request POST 'http://localhost:10099/api/v1/batches' \ --form 'batchRequest="{\"batchType\":\"SPARK\",\"className\":\"org.apache.spark.examples. ˓→SparkPi\"0 码力 | 206 页 | 3.78 MB | 1 年前3Apache Kyuubi 1.7.3 Documentation
Request Parameters Response Body Batch Resource GET /batches Returns all the batches. Request Parameters Response Body POST /batches Create a new batch. 120 Chapter 3. What’s Next Kyuubi, Release created Batch object. POST /batches (with uploading resource) Create a new batch with uploading resource file. Example of using curl command to send POST request to /v1/batches in multipart-formdata media uploading resource file from local path. curl --location --request POST 'http://localhost:10099/api/v1/batches' \ --form 'batchRequest="{\"batchType\":\"SPARK\",\"className\":\"org.apache.spark.examples. ˓→SparkPi\"0 码力 | 211 页 | 3.79 MB | 1 年前3Apache Kyuubi 1.7.1-rc0 Documentation
Request Parameters Response Body Batch Resource GET /batches Returns all the batches. Request Parameters Response Body POST /batches Create a new batch. 3.6. Clients 119 Kyuubi, Release 1.7 created Batch object. POST /batches (with uploading resource) Create a new batch with uploading resource file. Example of using curl command to send POST request to /v1/batches in multipart-formdata media uploading resource file from local path. curl --location --request POST 'http://localhost:10099/api/v1/batches' \ --form 'batchRequest="{\"batchType\":\"SPARK\",\"className\":\"org.apache.spark.examples. ˓→SparkPi\"0 码力 | 208 页 | 3.78 MB | 1 年前3
共 533 条
- 1
- 2
- 3
- 4
- 5
- 6
- 54