package baidu.bigflow.service
Get desktop application:
View/edit binary Protocol Buffers messages
service BigflowService
service.proto:173rpc register_pipeline (, )
service.proto:174message
service.proto:71optional pipeline = 1
optional string pipeline_id = 2
rpc unregister_pipeline (, )
service.proto:175message
service.proto:76optional string pipeline_id = 1
rpc launch (, )
service.proto:176message
service.proto:21optional string pipeline_id = 1
optional logical_plan = 2
optional resource = 3
repeated string hadoop_commit_args = 4
optional bytes pipeline_context = 5
rpc suspend (, )
service.proto:177message
service.proto:29optional string pipeline_id = 1
optional logical_plan = 2
repeated string hadoop_commit_args = 3
rpc kill (, )
service.proto:178message
service.proto:35optional string pipeline_id = 1
optional logical_plan = 2
repeated string hadoop_commit_args = 3
rpc get_status (, )
service.proto:179message
service.proto:45optional string pipeline_id = 1
optional logical_plan = 2
repeated string hadoop_commit_args = 3
message
service.proto:51optional status = 1
optional GetStatusResponse.Status app_status = 2
rpc write_local_seqfile (, )
service.proto:180message
service.proto:80optional string file_path = 1
repeated bytes key = 2
repeated bytes value = 3
rpc tmp_local_path (, )
service.proto:186rpc tmp_hdfs_path (, )
service.proto:187rpc hadoop_commit (, )
service.proto:188message
service.proto:112optional string hadoop_client_path = 1
optional string hadoop_config_path = 2
repeated string args = 3
rpc get_toft_style_path (, )
service.proto:189message
service.proto:100optional string input_path = 1
optional string hadoop_conf_path = 2
optional string fs_defaultfs = 3
optional string hadoop_job_ugi = 4
rpc is_node_cached (, )
service.proto:190message
service.proto:107optional string pipeline_id = 1
optional string node_id = 2
message
service.proto:95optional status = 1
optional bool response = 2
rpc get_cached_data (, )
service.proto:191message
service.proto:118optional string pipeline_id = 1
optional string node_id = 2
message
service.proto:123optional status = 1
repeated keys_value = 2
rpc get_meta_info (, )
service.proto:192message
service.proto:133optional bytes config = 1
message
service.proto:137repeated bytes field_name = 1
optional bytes serialized_context = 2
rpc get_counters (, )
service.proto:193message
service.proto:142optional string pipeline_id = 1
message
service.proto:146optional status = 1
repeated string name = 2
repeated uint64 value = 3
rpc reset_counter (, )
service.proto:194message
service.proto:152optional string pipeline_id = 1
optional string name = 2
message
service.proto:157optional status = 1
rpc reset_all_counters (, )
service.proto:195message
service.proto:161optional string pipeline_id = 1
message
service.proto:165optional status = 1
Used in:
AM_SUBMIT = 0
AM_ALLOCATE = 1
AM_RUN = 2
AM_KILL = 3
AM_FAIL = 4
AM_UNKNOWN = 5
APP_SUBMIT = 100
APP_ALLOCATE = 101
APP_RUN = 102
APP_KILL = 103
APP_FAIL = 104
APP_UNKNOWN = 105
message
service.proto:128Used in:
repeated bytes key = 1
optional bytes value = 2
message
service.proto:16Used in: , , , , , , ,
optional bool success = 1
optional string reason = 2
message
service.proto:86Used as request type in: BigflowService.default_fs_defaultfs, BigflowService.default_hadoop_client_path, BigflowService.default_hadoop_config_path, BigflowService.default_hadoop_job_ugi, BigflowService.default_spark_home_path, BigflowService.tmp_hdfs_path, BigflowService.tmp_local_path
optional string request = 1
message
service.proto:90Used as response type in: BigflowService.default_fs_defaultfs, BigflowService.default_hadoop_client_path, BigflowService.default_hadoop_config_path, BigflowService.default_hadoop_job_ugi, BigflowService.default_spark_home_path, BigflowService.get_toft_style_path, BigflowService.tmp_hdfs_path, BigflowService.tmp_local_path
optional status = 1
optional bytes response = 2
message
service.proto:41Used as response type in: BigflowService.hadoop_commit, BigflowService.kill, BigflowService.launch, BigflowService.register_pipeline, BigflowService.suspend, BigflowService.unregister_pipeline, BigflowService.write_local_seqfile
optional status = 1