conductor-framework

10Nhiệt

1Trả lời

Làm thế nào để thay thế Chrome bằng PhantomJS để sử dụng với Selenium và Conductor?

Tôi đang sử dụng thành công khung dẫn hướng để xóa dữ liệu khỏi một trang web. Tôi sử dụng trình duyệt Chrome và do đó tôi đã cài đặt chromedriver.exe trong thư mục gốc của dự án của tôi. Để tăng tốc

5Nhiệt

1Trả lời

Tại sao biến đổi làm các hiệu ứng phụ (println) chỉ một lần trong Streaming có cấu trúc?

Tại sao câu lệnh select được in mỗi lô nhưng chỉ hello world một lần? import org.apache.spark.sql.types._ val schema = StructType( StructField("id", LongType, nullable = false) :: StructFiel

7Nhiệt

1Trả lời

Giám sát cấu trúc Streaming

Tôi có một luồng có cấu trúc được thiết lập đang chạy tốt, nhưng tôi đã hy vọng theo dõi nó trong khi nó đang chạy. tôi đã xây dựng được một EventCollector class EventCollector extends StreamingQueryL

6Nhiệt

1Trả lời

Thực hiện các truy vấn trực tuyến riêng biệt trong phát trực tuyến có cấu trúc tia lửa

Tôi đang cố gắng tổng hợp luồng với hai cửa sổ khác nhau và in nó vào bảng điều khiển. Tuy nhiên chỉ có truy vấn trực tuyến đầu tiên đang được in. tenSecsQ không được in trên bảng điều khiển. SparkSes

5Nhiệt

2Trả lời

Spark Cấu trúc phát trực tuyến: nhiều bồn

1) Chúng tôi đang tiêu thụ từ kafka sử dụng luồng có cấu trúc và ghi dữ liệu đã xử lý được đặt thành s3. Chúng tôi cũng muốn ghi dữ liệu đã xử lý vào kafka di chuyển về phía trước, có thể thực hiện đi

5Nhiệt

1Trả lời

Streaming có cấu trúc thực thi các truy vấn trực tuyến riêng biệt (song song hoặc tuần tự) như thế nào?

Tôi đang viết một ứng dụng thử nghiệm tiêu thụ tin nhắn từ topcis của Kafka và sau đó đẩy dữ liệu vào S3 và vào các bảng RDBMS (luồng tương tự như được trình bày ở đây: https://databricks.com/blog/201