Trung tâm cá nhân
Bài viết phát hành
từ bỏ
Bài viết phổ biến của tác giả
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
29
4
Tôi đang sử dụng Flink v.1.4.0.
我希望能够在 Flink UI 中命名运算符。我知道要这样做，我只需要在 DataSet hoặc DataStream 上使用 .name() 方法。例如，像这样:
DataSet flinkDataSet = ...;
flinkDataSet
.map(new SomeTransformation())
.name("Transformation A");
我想知道的是，究竟是什么定义了运算符？它是 DataSet 的/DataStream 的 key 吗？或者元素类型？我知道如果我应用一个 MapFunction 与应用该函数的元素具有相同的返回类型，运算符将保持不变，但我注意到如果我应用一个 运算符通常会改变FlatMapFunction hoặc KeyBy hoặc GroupBy 操作，当然还有应用操作。
我问这个的原因是因为我想了解 Flink DAG 在 Flink UI 中的粒度，例如我可以说出每一个转变吗？或者运算符是由正在处理的数据集/数据流的类型定义的，因此我只能命名它们？例如，这行得通吗？
flinkDataSet
.map(new SomeTransformation())
.name("Transformation A")
.map(new SomeOtherTransformation())
.name("Transformation B");
或者第一个名字会被第二个名字覆盖吗？我当然可以试验并找出答案，但我也想了解原因。
1 Câu trả lời
就我使用的 name() 函数而言，您可以使用数据流或数据集 API 进行的每个转换都是一个操作，因此在您的第二种情况下，图形将如下所示
"Transformation A" -------> "Transformation B"
但是在 Flink dashborad 上，可以将这些任务分组到同一个任务中，如下所示:
----------------------- -----------------------
| SOURCE | ---> |"Transformation A" ->| ---> More operations
----------------------- |"Transformation B" |
-----------------------
关于java - 命名 Flink 操作符，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/49073433/
29
4
0
Tôi đang viết một phương thức Java với chữ ký sau. void Logger(Phương thức method, Object[] args); Nếu một phương thức (ví dụ ABC()) gọi phương thức Logger này, thì nó phải
Tôi mới làm quen với Java. Vấn đề của tôi là chương trình Java của tôi không tìm thấy tệp hình ảnh mà tôi đang cố gắng sử dụng làm JButton. (Hiện tại đoạn mã này không có tác dụng gì vì tôi chỉ muốn có được giao diện mong muốn của đoạn mã đầu tiên). Đây là mã lớp chính của tôi: packag
Được rồi, hôm nay tôi sẽ trả lời phỏng vấn và tôi đã viết mã Java trong nhiều năm. Trong cuộc phỏng vấn, anh ấy nói "Thu gom rác Java là một vấn đề khó khăn mà một số bạn của tôi đang cố gắng tìm ra. Còn bạn thì sao?". Cô ấy đang cố lừa dối tôi phải không? Hoặc toàn bộ cuộc sống của tôi
Bạn tôi đưa cho tôi một câu đố để giải. Nó diễn ra như thế này: Có 100 người. Mỗi người trong số họ, đến lượt mình, thực hiện những điều sau
Nếu tôi biên dịch một ứng dụng sử dụng mã Java 5 thành mã byte, thì các tệp .class kết quả có chạy được trên Java 1.4 không? Nếu cách sau có hiệu quả và tôi đang cố gắng sử dụng Java trong ứng dụng Java 1.4 của mình
Có một số câu hỏi về lý do tại sao Java không hỗ trợ các kiểu không dấu và một số câu hỏi về cách xử lý các kiểu không dấu. Tôi đã tìm kiếm và có vẻ như Scala cũng không hỗ trợ các kiểu dữ liệu không dấu. Các hạn chế là Java và S
Tôi chỉ muốn biết liệu bytecode được tạo trong một phiên bản Java có thể chạy trên các phiên bản Java khác không? Câu trả lời hay nhất Thông thường, bytecode có thể chạy trên các phiên bản Java mới hơn mà không cần sửa đổi. Nó sẽ không chạy trên các phiên bản cũ hơn trừ khi bạn sử dụng các tham số đặc biệt (
Tôi có một câu hỏi cơ bản về việc thực thi chương trình Java trong dấu nhắc lệnh. Trên một số máy, chúng ta cần chỉ định -cp. (đường dẫn lớp) thực thi chương trình java cùng lúc (test là tên tệp java và tệp .class tồn tại trong cùng một thư mục) jav
Tôi đã đọc StackOverflow một thời gian rồi và bây giờ tôi mới có đủ can đảm để đặt một câu hỏi. Tôi 20 tuổi và hiện đang theo học tại một trường đại học chuyên ngành CNTT ở quê nhà (Cluj-Napoca, Romania). Chỉ đủ để giới thiệu thôi :D. Về cơ bản, tôi có một ứng dụng kế toán.
Tôi có public JSONObject parseXML(String xml) { JSONObject jsonObject = XML.toJSONObject(xml);
Tôi đã triển khai một ngôn ngữ thông dịch đơn giản trong Java với kiểu dữ liệu động. Thật không may là tôi gặp phải vấn đề sau. Mã kiểm tra như sau: def main() { def ks = Map[[1, 2]].keySet()
Tiếp tục nhắc nhập một số từ 1 đến 10 - kết quả sẽ là thêm st, rd, th và nd vào số đó. Viết chương trình nhắc người dùng nhập bất kỳ số nguyên nào từ 1 đến 10, sau đó hiển thị số nguyên đó dưới dạng thứ tự có thêm hậu tố. công cộng
Tôi có DownloadFile.java này và nó tải xuống tệp như mong đợi: import java.io.*; import java.net.URL; public class DownloadFile {
Tôi muốn thêm độ trễ vào GUI. Tôi đặt 2 vòng lặp for rồi vẽ lại nhãn, nhưng 2 vòng lặp for này được thực thi lần lượt và nhãn được vẽ lại cho đến vòng lặp cuối cùng. Tôi có thể làm gì? đối với (int i = 0;
Tôi đang thực hiện một số thử nghiệm trên các mục danh sách của đối tượng Student, nhưng tôi thích tạo danh sách được mã hóa cứng trong đối tượng lớp Java và trích xuất dữ liệu từ đó thay vì kết nối với cơ sở dữ liệu và chọn các bản ghi trong tập kết quả. Tuy nhiên, đã lâu rồi tôi không làm điều này,
Tôi biết rằng việc tạo đối tượng được chia thành ba phần: khai báo khởi tạo khởi tạo classA{} classB mở rộng classA{} classA obj = new classB(1,1); để khởi tạo nó, bạn phải sử dụng
Tôi quan tâm đến việc xây dựng hệ thống theo dõi phương tiện sử dụng GPRS. Tuy nhiên, tôi có một số câu hỏi dành cho những người đã từng làm việc này: GPRS có phải là công nghệ tốt nhất không? Mọi người có biết vấn đề gì không? Tôi dự định sử dụng Java/Java EE - có công nghệ nào tốt hơn không? nếu như
Tôi có thể đảo ngược một mảng bằng phương pháp đệ quy, ví dụ: array = {1,2,3,4,5} array result = {5,4,3,2,1} nhưng kết quả của tôi vẫn là mảng đó, tôi không biết tại sao, vui lòng giúp tôi. lớp công khai Đệ quy {
Có cách chuẩn nào để thực hiện việc này không? Bao gồm mã nguồn Java - Mã kiểm thử - Tích hợp liên tục đơn vị chung Ant hoặc Maven (có thể kiểm soát hành trình) Triển khai công cụ kiểm soát phiên bản ClearCase lên máy chủ ứng dụng Cuối cùng, tôi hy vọng sẽ có một môi trường xây dựng và tích hợp tự động.
Tôi thậm chí còn không biết điều này có khả thi hay không, tôi thực sự nghi ngờ là có, nhưng nếu có thể, bạn có thể cho tôi biết cách thực hiện không? Tôi chỉ muốn biết cách in một số văn bản từ máy in. Bạn có ý tưởng nào không? Câu trả lời hay nhất Có những điều đơn giản hơn đang diễn ra ở đây. nhập javax.swin
Tôi là một lập trình viên xuất sắc, rất giỏi!