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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
java.util.List<E> kvs_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
java.util.List<E> keys_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
PhysicalPlans.PhysicalPlan pplan_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
PhysicalPlans.PhysicalPlan newPplan_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
HeronTuples.HeronTupleSet set_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Metrics.MetricPublisher publisher_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
TopologyMaster.TMasterLocation tmaster_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
Common.Status status_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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.ObjectStreamException
com.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