CustomStreamGrouping delegate
Scheme scheme
SpoutOutputCollector collector
java.lang.String[] words
java.util.Random rand
IBasicBolt delegate
IRichBolt delegate
TopologyContext topologyContextImpl
OutputCollectorImpl outputCollectorImpl
IRichSpout delegate
TopologyContext topologyContextImpl
SpoutOutputCollectorImpl spoutOutputCollectorImpl
Fields delegate
IBasicBolt bolt
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
TopologyAPI.Component comp_
java.util.List<E> inputs_
java.util.List<E> outputs_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object name_
java.lang.Object javaClassName_
com.google.protobuf.ByteString javaObject_
TopologyAPI.Config config_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
java.util.List<E> kvs_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object key_
java.lang.Object value_
com.google.protobuf.ByteString javaSerializedValue_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
TopologyAPI.StreamId stream_
TopologyAPI.Grouping gtype_
TopologyAPI.StreamSchema groupingFields_
com.google.protobuf.ByteString customGroupingJavaObject_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
TopologyAPI.StreamId stream_
TopologyAPI.StreamSchema schema_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
TopologyAPI.Component comp_
java.util.List<E> outputs_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object id_
java.lang.Object componentName_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
java.util.List<E> keys_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object key_
TopologyAPI.Type type_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object id_
java.lang.Object name_
java.util.List<E> spouts_
java.util.List<E> bolts_
TopologyAPI.TopologyState state_
TopologyAPI.Config topologyConfig_
byte memoizedIsInitialized
int memoizedSerializedSize
Scheme scheme
java.util.List<E> fields
java.util.Map<K,V> mIndex
protected java.lang.Object readResolve()
throws java.io.ObjectStreamException
java.io.ObjectStreamException - If unable to deserializeSpoutOutputCollector collector
java.lang.String[] words
java.util.Random rand
OutputCollector collector
long nItems
long startTime
long nItems
long startTime
long nItems
java.util.List<E> taskIds
long nItems
long startTime
long nItems
long startTime
SpoutOutputCollector collector
java.lang.String[] words
java.util.Random rand
OutputCollector collector
long nItems
long startTime
boolean emit
SpoutOutputCollector collector
java.lang.String[] words
java.util.Random rand
OutputCollector collector
long nItems
long startTime
SpoutOutputCollector collector
java.lang.String[] words
java.util.Random rand
OutputCollector collector
java.util.Map<K,V> countMap
java.lang.String[] words
java.util.Random rnd
SpoutOutputCollector collector
OutputCollector collector
int sum
Fields fields
Fields fields
OutputCollector collector
int received
java.lang.String propName
java.lang.Object propValue
java.lang.String path
java.io.BufferedWriter bw
OutputCollector collector
java.util.HashMap<K,V> buffer
OutputCollector collector
java.util.HashMap<K,V> cache
java.lang.String propName
OutputCollector collector
java.util.HashMap<K,V> cache
SpoutOutputCollector collector
int emitted
java.lang.String[] toSend
java.io.BufferedReader br
SpoutOutputCollector collector
java.lang.String[] paths
java.io.BufferedReader br
SpoutOutputCollector collector
java.lang.String[] paths
java.io.BufferedReader br
SpoutOutputCollector collector
java.lang.String[] paths
java.lang.String httpPostUrl
java.util.List<E> result
IRichBolt delegateBolt
int terminalsToReceive
long tuplesReceived
long tuplesProcessed
Tuple currentTupleProcessing
OutputCollector collector
IRichSpout delegateSpout
boolean isDone
long tuplesToComplete
SpoutOutputCollector spoutOutputCollector
int maxExecutions
java.lang.String localFilePath
java.io.BufferedWriter bw
int nItems
CustomObject[] inputObjects
java.lang.String name
java.lang.Integer age
SpoutOutputCollector collector
int emitted
CustomObject[] inputObjects
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object topologyName_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object topologyName_
int containerIndex_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object topologyName_
java.lang.Object httpEndpoint_
com.google.protobuf.LazyStringList jobPageLink_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
PhysicalPlans.PhysicalPlan pplan_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
PhysicalPlans.PhysicalPlan newPplan_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
PhysicalPlans.Instance instance_
java.lang.Object topologyName_
java.lang.Object topologyId_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
PhysicalPlans.PhysicalPlan pplan_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object topologyName_
java.lang.Object topologyId_
java.lang.Object stmgr_
java.lang.Object messageId_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object topologyName_
java.lang.Object topologyId_
java.lang.Object stmgr_
java.lang.Object messageId_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object topologyName_
java.lang.Object topologyId_
java.lang.Object stmgr_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
HeronTuples.HeronTupleSet set_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
int taskId_
HeronTuples.HeronTupleSet set_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.StatusCode status_
java.lang.Object message_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object topologyName_
java.lang.Object topologyId_
long submissionTime_
java.lang.Object submissionUser_
java.lang.Object cluster_
java.lang.Object environ_
java.lang.Object role_
ExecutionEnvironment.HeronReleaseState releaseState_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object releaseUsername_
java.lang.Object releaseTag_
java.lang.Object releaseVersion_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.util.List<E> roots_
long ackedtuple_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
java.util.List<E> acks_
java.util.List<E> fails_
java.util.List<E> emits_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
long key_
java.util.List<E> roots_
java.util.List<E> values_
java.util.List<E> destTaskIds_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
TopologyAPI.StreamId stream_
java.util.List<E> tuples_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
HeronTuples.HeronDataTupleSet data_
HeronTuples.HeronControlTupleSet control_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
int taskid_
long key_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object stacktrace_
java.lang.Object lasttime_
java.lang.Object firsttime_
int count_
java.lang.Object logging_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object name_
java.lang.Object value_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object hostname_
int port_
java.lang.Object componentName_
java.lang.Object instanceId_
int instanceIndex_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
java.util.List<E> metrics_
java.util.List<E> exceptions_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Metrics.MetricPublisher publisher_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
TopologyMaster.TMasterLocation tmaster_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object instanceId_
java.lang.Object stmgrId_
PhysicalPlans.InstanceInfo info_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
int taskId_
int componentIndex_
java.lang.Object componentName_
com.google.protobuf.LazyStringList params_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
TopologyAPI.Topology topology_
java.util.List<E> stmgrs_
java.util.List<E> instances_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object id_
java.lang.Object hostName_
int dataPort_
java.lang.Object localEndpoint_
java.lang.Object cwd_
int pid_
int shellPort_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object echoRequest_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object echoResponse_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object componentName_
com.google.protobuf.LazyStringList instances_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
java.util.List<E> exceptions_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object componentName_
java.lang.Object instanceId_
java.lang.Object name_
java.lang.Object value_
long timestamp_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
long start_
long end_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object componentName_
com.google.protobuf.LazyStringList instanceId_
com.google.protobuf.LazyStringList metric_
long interval_
TopologyMaster.MetricInterval explicitInterval_
boolean minutely_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
java.util.List<E> metric_
long interval_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object name_
java.lang.Object value_
java.util.List<E> intervalValues_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object value_
TopologyMaster.MetricInterval interval_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object instanceId_
java.util.List<E> metric_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
java.util.List<E> metrics_
java.util.List<E> exceptions_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
long heartbeatTime_
Stats.StMgrStats stats_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
PhysicalPlans.StMgr stmgr_
java.util.List<E> instances_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
PhysicalPlans.PhysicalPlan pplan_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object componentName_
java.lang.Object hostname_
java.lang.Object instanceId_
java.lang.Object stacktrace_
java.lang.Object lasttime_
java.lang.Object firsttime_
int count_
java.lang.Object logging_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace()
throws java.io.ObjectStreamException
java.io.ObjectStreamExceptioncom.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
java.lang.Object topologyName_
java.lang.Object topologyId_
java.lang.Object host_
int controllerPort_
int masterPort_
int statsPort_
byte memoizedIsInitialized
int memoizedSerializedSize
OutputCollector outputCollector
int tupleExecuted
java.lang.String[] toSend
SpoutOutputCollector outputCollector
int emitted
CustomStreamGrouping delegate
Scheme scheme
SpoutOutputCollector collector
java.lang.String[] words
java.util.Random rand
IBasicBolt delegate
IRichBolt delegate
TopologyContext topologyContextImpl
OutputCollectorImpl outputCollectorImpl
IRichSpout delegate
TopologyContext topologyContextImpl
SpoutOutputCollectorImpl spoutOutputCollectorImpl
Fields delegate