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 className_
com.google.protobuf.ByteString serializedObject_
TopologyAPI.Config config_
TopologyAPI.ComponentObjectSpec spec_
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 serializedValue_
TopologyAPI.ConfigValueType type_
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 customGroupingObject_
TopologyAPI.CustomGroupingObjectType type_
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
java.lang.String[] sentences
java.util.Random rnd
SpoutOutputCollector collector
java.util.Map<K,V> counts
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
boolean appendSequenceId
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
java.lang.String topologyStartedStateUrl
long tuplesToAck
SpoutOutputCollector spoutOutputCollector
boolean hasSetStarted
int maxExecutions
java.util.Map<K,V> pendingMessages
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_
PackingPlans.PackingPlan currentPackingPlan_
PackingPlans.PackingPlan proposedPackingPlan_
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_
HeronTuples.HeronTupleSet2 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_
int taskId_
com.google.protobuf.ByteString 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_
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_
HeronTuples.HeronDataTupleSet2 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.MetricsCacheLocation metricscache_
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_
int id_
java.util.List<E> instancePlans_
PackingPlans.Resource requiredResource_
PackingPlans.Resource scheduledResource_
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_
int taskId_
int componentIndex_
PackingPlans.Resource resource_
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.util.List<E> containerPlans_
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
int bitField0_
double cpu_
long ram_
long disk_
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
int bitField0_
java.lang.Object topologyName_
java.lang.Object topologyId_
java.lang.Object host_
int controllerPort_
int masterPort_
int statsPort_
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
byte memoizedIsInitialized
int memoizedSerializedSize
protected java.lang.Object writeReplace() throws java.io.ObjectStreamException
java.io.ObjectStreamException
com.google.protobuf.UnknownFieldSet unknownFields
com.google.protobuf.LazyStringList registeredStmgrs_
com.google.protobuf.LazyStringList absentStmgrs_
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
TopologyAPI.Topology topology
Config config
PackingPlan packingPlan
PackingPlan oldPackingPlan
java.util.Map<K,V> changeRequests
CustomStreamGrouping delegate
java.lang.String host
int port
long retryInitialDelayMs
double retryDelayMultiplier
long retryDelayMaxMs
int retryLimit
java.util.Queue<E> waiting
java.util.Map<K,V> records
BrokerHosts hosts
java.lang.String topic
java.lang.String clientId
int fetchSizeBytes
int socketTimeoutMs
int fetchMaxWait
int bufferSizeBytes
MultiScheme scheme
boolean ignoreZkOffsets
long startOffsetTime
long maxOffsetBehind
boolean useStartOffsetTimeIfOffsetOutOfRange
int metricsTimeBucketSizeInSecs
int minFetchByte
SpoutConfig spoutConfig
SpoutOutputCollector collector
PartitionCoordinator coordinator
DynamicPartitionConnections connections
ZkState state
long lastUpdateMs
int currPartitionIndex
Broker host
int partition
java.lang.String topic
java.lang.Boolean bUseTopicNameForPartitionPathId
java.util.List<E> zkServers
java.lang.Integer zkPort
java.lang.String zkRoot
java.lang.String id
java.lang.String outputStreamId
long stateUpdateIntervalMs
java.lang.String failedMsgRetryManagerClass
long retryInitialDelayMs
double retryDelayMultiplier
long retryDelayMaxMs
int retryLimit
GlobalPartitionInformation partitionInformation
java.lang.String brokerZkStr
java.lang.String brokerZkPath
int refreshFreqSecs
java.util.Map<K,V> partitionMap
java.lang.String myTopic
java.lang.Boolean bUseTopicNameForPartitionPathId
Scheme scheme
java.lang.String stream
java.util.List<E> values
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