Uses of Class
org.apache.storm.tuple.Fields

Packages that use Fields

Package	Description
org.apache.storm.cassandra.bolt
org.apache.storm.cassandra.trident.state
org.apache.storm.daemon
org.apache.storm.daemon.worker
org.apache.storm.drpc
org.apache.storm.elasticsearch
org.apache.storm.elasticsearch.trident	ElasticSearch Trident example classes.
org.apache.storm.eventhubs.spout
org.apache.storm.eventhubs.trident
org.apache.storm.flux.examples
org.apache.storm.grouping
org.apache.storm.hbase.bolt.mapper
org.apache.storm.hbase.trident.mapper
org.apache.storm.hdfs.bolt.format
org.apache.storm.hdfs.trident
org.apache.storm.hdfs.trident.format
org.apache.storm.hive.bolt.mapper
org.apache.storm.hive.trident
org.apache.storm.jdbc.mapper
org.apache.storm.jms.example
org.apache.storm.jms.trident
org.apache.storm.kafka.spout
org.apache.storm.kafka.spout.internal
org.apache.storm.kafka.spout.trident
org.apache.storm.kafka.spout.trident.internal
org.apache.storm.kinesis.spout
org.apache.storm.mqtt
org.apache.storm.mqtt.examples	MQTT examples.
org.apache.storm.mqtt.mappers
org.apache.storm.opentsdb
org.apache.storm.pmml.model
org.apache.storm.pmml.model.jpmml
org.apache.storm.rocketmq.spout.scheme
org.apache.storm.solr.spout
org.apache.storm.spout
org.apache.storm.sql.kafka
org.apache.storm.sql.runtime.serde.avro
org.apache.storm.sql.runtime.serde.csv
org.apache.storm.sql.runtime.serde.json
org.apache.storm.sql.runtime.serde.tsv
org.apache.storm.st.topology.window.data
org.apache.storm.starter.bolt
org.apache.storm.starter.spout
org.apache.storm.streams
org.apache.storm.task
org.apache.storm.testing
org.apache.storm.topology
org.apache.storm.trident
org.apache.storm.trident.fluent
org.apache.storm.trident.operation
org.apache.storm.trident.operation.impl
org.apache.storm.trident.planner
org.apache.storm.trident.planner.processor
org.apache.storm.trident.spout
org.apache.storm.trident.state.map
org.apache.storm.trident.testing
org.apache.storm.trident.tuple
org.apache.storm.trident.util
org.apache.storm.trident.windowing
org.apache.storm.tuple

Uses of Fields in org.apache.storm.cassandra.bolt

Methods in org.apache.storm.cassandra.bolt with parameters of type Fields

Modifier and Type	Method and Description
BaseCassandraBolt	BaseCassandraBolt.withOutputFields(Fields fields) Configures this bolt with the given fields as outputfields with stream id as Utils.DEFAULT_STREAM_ID.
BaseCassandraBolt	BaseCassandraBolt.withStreamOutputFields(String stream, Fields fields) Configures this bolt given fields as outputfields for the given stream.

Uses of Fields in org.apache.storm.cassandra.trident.state

Methods in org.apache.storm.cassandra.trident.state that return Fields

Modifier and Type	Method and Description
Fields	SimpleTuple.getFields()
Fields	OpaqueTupleStateMapper.getStateFields()
Fields	NonTransactionalTupleStateMapper.getStateFields()
Fields	SimpleStateMapper.getStateFields()
Fields	StateMapper.getStateFields()
Fields	TransactionalTupleStateMapper.getStateFields()
Fields	SerializedStateMapper.getStateFields()

Methods in org.apache.storm.cassandra.trident.state with parameters of type Fields

Modifier and Type	Method and Description
List<Object>	SimpleTuple.select(Fields selector)
CassandraBackingMap.Options<T>	CassandraBackingMap.Options.withKeys(Fields keyFields)

Constructors in org.apache.storm.cassandra.trident.state with parameters of type Fields

Constructor and Description
NonTransactionalTupleStateMapper(Fields fields)
OpaqueTupleStateMapper(String currTxIdField, String currPrefix, String prevPrefix, Fields fields)
SimpleStateMapper(Fields fields, StateType stateType)
SimpleTuple(Fields keyFields, List<Object>... values)
SimpleTuple(Fields keyFields, List<Object> values)
TransactionalTupleStateMapper(String txIdField, Fields fields)
TridentAyncCQLResultSetValuesMapper(Fields outputDeclaredFields, Semaphore throttle)
TridentResultSetValuesMapper(Fields outputDeclaredFields)

Uses of Fields in org.apache.storm.daemon

Methods in org.apache.storm.daemon with parameters of type Fields

Modifier and Type	Method and Description
static LoadAwareCustomStreamGrouping	GrouperFactory.mkGrouper(WorkerTopologyContext context, String componentId, String streamId, Fields outFields, Grouping thriftGrouping, List<Integer> unsortedTargetTasks, Map<String,Object> topoConf)

Constructors in org.apache.storm.daemon with parameters of type Fields

Constructor and Description
FieldsGrouper(Fields outFields, Grouping thriftGrouping)

Uses of Fields in org.apache.storm.daemon.worker

Methods in org.apache.storm.daemon.worker that return types with arguments of type Fields

Modifier and Type	Method and Description
Map<String,Map<String,Fields>>	WorkerState.getComponentToStreamToFields()

Uses of Fields in org.apache.storm.drpc

Methods in org.apache.storm.drpc with parameters of type Fields

Modifier and Type	Method and Description
LinearDRPCInputDeclarer	LinearDRPCInputDeclarer.fieldsGrouping(Fields fields)
LinearDRPCInputDeclarer	LinearDRPCInputDeclarer.fieldsGrouping(String streamId, Fields fields)
LinearDRPCInputDeclarer	LinearDRPCInputDeclarer.partialKeyGrouping(Fields fields)
LinearDRPCInputDeclarer	LinearDRPCInputDeclarer.partialKeyGrouping(String streamId, Fields fields)

Uses of Fields in org.apache.storm.elasticsearch

Methods in org.apache.storm.elasticsearch that return Fields

Modifier and Type	Method and Description
Fields	DefaultEsLookupResultOutput.fields()
Fields	EsLookupResultOutput.fields() Fields to be declared for output.

Uses of Fields in org.apache.storm.elasticsearch.trident

Methods in org.apache.storm.elasticsearch.trident that return Fields

Modifier and Type	Method and Description
Fields	TridentEsTopology.FixedBatchSpout.getOutputFields() Gets the output fields.

Uses of Fields in org.apache.storm.eventhubs.spout

Methods in org.apache.storm.eventhubs.spout that return Fields

Modifier and Type	Method and Description
Fields	EventDataScheme.getOutputFields()
Fields	BinaryEventDataScheme.getOutputFields()
Fields	IEventDataScheme.getOutputFields() Retrieve the Fields that are present on tuples created by this object.
Fields	StringEventDataScheme.getOutputFields()

Uses of Fields in org.apache.storm.eventhubs.trident

Methods in org.apache.storm.eventhubs.trident that return Fields

Modifier and Type	Method and Description
Fields	TransactionalTridentEventHubSpout.getOutputFields()
Fields	OpaqueTridentEventHubSpout.getOutputFields()

Uses of Fields in org.apache.storm.flux.examples

Methods in org.apache.storm.flux.examples that return Fields

Modifier and Type	Method and Description
Fields	OnlyValueRecordTranslator.getFieldsFor(String stream)

Uses of Fields in org.apache.storm.grouping

Constructors in org.apache.storm.grouping with parameters of type Fields

Constructor and Description
PartialKeyGrouping(Fields fields)
PartialKeyGrouping(Fields fields, PartialKeyGrouping.AssignmentCreator assignmentCreator)
PartialKeyGrouping(Fields fields, PartialKeyGrouping.AssignmentCreator assignmentCreator, PartialKeyGrouping.TargetSelector targetSelector)

Uses of Fields in org.apache.storm.hbase.bolt.mapper

Methods in org.apache.storm.hbase.bolt.mapper with parameters of type Fields

Modifier and Type	Method and Description
SimpleHBaseMapper	SimpleHBaseMapper.withColumnFields(Fields columnFields)
SimpleHBaseMapper	SimpleHBaseMapper.withCounterFields(Fields counterFields)

Uses of Fields in org.apache.storm.hbase.trident.mapper

Methods in org.apache.storm.hbase.trident.mapper with parameters of type Fields

Modifier and Type	Method and Description
SimpleTridentHBaseMapper	SimpleTridentHBaseMapper.withColumnFields(Fields columnFields)
SimpleTridentHBaseMapper	SimpleTridentHBaseMapper.withCounterFields(Fields counterFields)

Uses of Fields in org.apache.storm.hdfs.bolt.format

Methods in org.apache.storm.hdfs.bolt.format with parameters of type Fields

Modifier and Type	Method and Description
DelimitedRecordFormat	DelimitedRecordFormat.withFields(Fields fields) Only output the specified fields.

Uses of Fields in org.apache.storm.hdfs.trident

Methods in org.apache.storm.hdfs.trident that return Fields

Modifier and Type	Method and Description
Fields	FixedBatchSpout.getOutputFields()

Constructors in org.apache.storm.hdfs.trident with parameters of type Fields

Constructor and Description
FixedBatchSpout(Fields fields, int maxBatchSize, List<Object>... outputs)

Uses of Fields in org.apache.storm.hdfs.trident.format

Methods in org.apache.storm.hdfs.trident.format with parameters of type Fields

Modifier and Type	Method and Description
DelimitedRecordFormat	DelimitedRecordFormat.withFields(Fields fields) Only output the specified fields.

Uses of Fields in org.apache.storm.hive.bolt.mapper

Methods in org.apache.storm.hive.bolt.mapper with parameters of type Fields

Modifier and Type	Method and Description
DelimitedRecordHiveMapper	DelimitedRecordHiveMapper.withColumnFields(Fields columnFields)
JsonRecordHiveMapper	JsonRecordHiveMapper.withColumnFields(Fields columnFields)
DelimitedRecordHiveMapper	DelimitedRecordHiveMapper.withPartitionFields(Fields partitionFields)
JsonRecordHiveMapper	JsonRecordHiveMapper.withPartitionFields(Fields partitionFields)

Uses of Fields in org.apache.storm.hive.trident

Methods in org.apache.storm.hive.trident that return Fields

Modifier and Type	Method and Description
Fields	TridentHiveTopology.FixedBatchSpout.getOutputFields()

Uses of Fields in org.apache.storm.jdbc.mapper

Constructors in org.apache.storm.jdbc.mapper with parameters of type Fields

Constructor and Description
SimpleJdbcLookupMapper(Fields outputFields, List<Column> queryColumns)

Uses of Fields in org.apache.storm.jms.example

Constructors in org.apache.storm.jms.example with parameters of type Fields

Constructor and Description
GenericBolt(String name, boolean autoAck, boolean autoAnchor, Fields declaredFields) Constructs a new GenericBolt instance.

Uses of Fields in org.apache.storm.jms.trident

Methods in org.apache.storm.jms.trident that return Fields

Modifier and Type	Method and Description
Fields	TridentJmsSpout.getOutputFields()

Uses of Fields in org.apache.storm.kafka.spout

Fields in org.apache.storm.kafka.spout declared as Fields

Modifier and Type	Field and Description
static Fields	DefaultRecordTranslator.FIELDS

Methods in org.apache.storm.kafka.spout that return Fields

Modifier and Type	Method and Description
Fields	ByTopicRecordTranslator.getFieldsFor(String stream)
Fields	SimpleRecordTranslator.getFieldsFor(String stream)
Fields	DefaultRecordTranslator.getFieldsFor(String stream)
Fields	RecordTranslator.getFieldsFor(String stream) Get the fields associated with a stream.

Methods in org.apache.storm.kafka.spout with parameters of type Fields

Modifier and Type	Method and Description
ByTopicRecordTranslator<K,V>	ByTopicRecordTranslator.forTopic(String topic, Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields) Configure a translator for a given topic with tuples to be emitted to the default stream.
ByTopicRecordTranslator<K,V>	ByTopicRecordTranslator.forTopic(String topic, Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields, String stream) Configure a translator for a given topic.

Constructors in org.apache.storm.kafka.spout with parameters of type Fields

Constructor and Description
ByTopicRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields) Create a simple record translator that will use func to extract the fields of the tuple, named by fields, and emit them to the default stream.
ByTopicRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields, String stream) Create a simple record translator that will use func to extract the fields of the tuple, named by fields, and emit them to stream.
SimpleRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields)
SimpleRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields, String stream) Creates a SimpleRecordTranslator.

Uses of Fields in org.apache.storm.kafka.spout.internal

Methods in org.apache.storm.kafka.spout.internal with parameters of type Fields

Modifier and Type	Method and Description
T	CommonKafkaSpoutConfig.Builder.setRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields) Configure a translator with tuples to be emitted on the default stream.
T	CommonKafkaSpoutConfig.Builder.setRecordTranslator(Func<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,List<Object>> func, Fields fields, String stream) Configure a translator with tuples to be emitted to a given stream.

Uses of Fields in org.apache.storm.kafka.spout.trident

Methods in org.apache.storm.kafka.spout.trident that return Fields

Modifier and Type	Method and Description
Fields	KafkaTridentSpoutOpaque.getOutputFields()
Fields	KafkaTridentSpoutTransactional.getOutputFields()

Uses of Fields in org.apache.storm.kafka.spout.trident.internal

Methods in org.apache.storm.kafka.spout.trident.internal that return Fields

Modifier and Type	Method and Description
<K,V> Fields	OutputFieldsExtractor.getOutputFields(KafkaTridentSpoutConfig<K,V> kafkaSpoutConfig) Extract the output fields from the config.

Uses of Fields in org.apache.storm.kinesis.spout

Methods in org.apache.storm.kinesis.spout that return Fields

Modifier and Type	Method and Description
Fields	RecordToTupleMapper.getOutputFields() Retrieve the names of fields.

Uses of Fields in org.apache.storm.mqtt

Methods in org.apache.storm.mqtt that return Fields

Modifier and Type	Method and Description
Fields	MqttMessageMapper.outputFields() Returns the list of output fields this Mapper produces.

Uses of Fields in org.apache.storm.mqtt.examples

Methods in org.apache.storm.mqtt.examples that return Fields

Modifier and Type	Method and Description
Fields	CustomMessageMapper.outputFields() Gets the output fields.

Uses of Fields in org.apache.storm.mqtt.mappers

Methods in org.apache.storm.mqtt.mappers that return Fields

Modifier and Type	Method and Description
Fields	StringMessageMapper.outputFields()
Fields	ByteArrayMessageMapper.outputFields()

Uses of Fields in org.apache.storm.opentsdb

Fields in org.apache.storm.opentsdb declared as Fields

Modifier and Type	Field and Description
static Fields	MetricGenSpout.DEFAULT_METRIC_FIELDS

Methods in org.apache.storm.opentsdb that return Fields

Modifier and Type	Method and Description
Fields	MetricGenBatchSpout.getOutputFields()

Uses of Fields in org.apache.storm.pmml.model

Methods in org.apache.storm.pmml.model that return types with arguments of type Fields

Modifier and Type	Method and Description
Map<String,? extends Fields>	ModelOutputs.streamFields() Stream fields.

Uses of Fields in org.apache.storm.pmml.model.jpmml

Methods in org.apache.storm.pmml.model.jpmml that return types with arguments of type Fields

Modifier and Type	Method and Description
Map<String,? extends Fields>	JpmmlModelOutputs.streamFields()

Constructor parameters in org.apache.storm.pmml.model.jpmml with type arguments of type Fields

Constructor and Description
JpmmlModelOutputs(Map<String,? extends Fields> declaredFields)

Uses of Fields in org.apache.storm.rocketmq.spout.scheme

Methods in org.apache.storm.rocketmq.spout.scheme that return Fields

Modifier and Type	Method and Description
Fields	StringScheme.getOutputFields()

Uses of Fields in org.apache.storm.solr.spout

Methods in org.apache.storm.solr.spout that return Fields

Modifier and Type	Method and Description
Fields	SolrFieldsSpout.getOutputFields()
Fields	SolrJsonSpout.getOutputFields()

Uses of Fields in org.apache.storm.spout

Methods in org.apache.storm.spout that return Fields

Modifier and Type	Method and Description
Fields	RawMultiScheme.getOutputFields()
Fields	MultiScheme.getOutputFields()
Fields	SchemeAsMultiScheme.getOutputFields()
Fields	RawScheme.getOutputFields()
Fields	Scheme.getOutputFields()

Uses of Fields in org.apache.storm.sql.kafka

Methods in org.apache.storm.sql.kafka that return Fields

Modifier and Type	Method and Description
Fields	RecordTranslatorSchemeAdapter.getFieldsFor(String stream)

Uses of Fields in org.apache.storm.sql.runtime.serde.avro

Methods in org.apache.storm.sql.runtime.serde.avro that return Fields

Modifier and Type	Method and Description
Fields	AvroScheme.getOutputFields()

Uses of Fields in org.apache.storm.sql.runtime.serde.csv

Methods in org.apache.storm.sql.runtime.serde.csv that return Fields

Modifier and Type	Method and Description
Fields	CsvScheme.getOutputFields()

Uses of Fields in org.apache.storm.sql.runtime.serde.json

Methods in org.apache.storm.sql.runtime.serde.json that return Fields

Modifier and Type	Method and Description
Fields	JsonScheme.getOutputFields()

Uses of Fields in org.apache.storm.sql.runtime.serde.tsv

Methods in org.apache.storm.sql.runtime.serde.tsv that return Fields

Modifier and Type	Method and Description
Fields	TsvScheme.getOutputFields()

Uses of Fields in org.apache.storm.st.topology.window.data

Methods in org.apache.storm.st.topology.window.data that return Fields

Modifier and Type	Method and Description
static Fields	TimeData.getFields()

Uses of Fields in org.apache.storm.starter.bolt

Constructors in org.apache.storm.starter.bolt with parameters of type Fields

Constructor and Description
SingleJoinBolt(Fields outFields)

Uses of Fields in org.apache.storm.starter.spout

Methods in org.apache.storm.starter.spout that return Fields

Modifier and Type	Method and Description
Fields	RandomNumberGeneratorSpout.getOutputFields()

Constructors in org.apache.storm.starter.spout with parameters of type Fields

Constructor and Description
RandomNumberGeneratorSpout(Fields fields, int batchSize, int maxNumber)

Uses of Fields in org.apache.storm.streams

Fields in org.apache.storm.streams declared as Fields

Modifier and Type	Field and Description
protected static Fields	Stream.KEY
protected static Fields	Stream.KEY_VALUE
protected static Fields	Stream.VALUE

Methods in org.apache.storm.streams that return Fields

Modifier and Type	Method and Description
static Fields	StreamUtil.getPunctuationFields()

Methods in org.apache.storm.streams with parameters of type Fields

Modifier and Type	Method and Description
protected Stream<T>	Stream.partitionBy(Fields fields, int parallelism)

Constructors in org.apache.storm.streams with parameters of type Fields

Constructor and Description
ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields)
ProcessorNode(Processor<?> processor, String outputStream, Fields outputFields, boolean preservesKey)

Uses of Fields in org.apache.storm.task

Methods in org.apache.storm.task that return Fields

Modifier and Type	Method and Description
Fields	GeneralTopologyContext.getComponentOutputFields(GlobalStreamId id) Gets the declared output fields for the specified global stream id.
Fields	GeneralTopologyContext.getComponentOutputFields(String componentId, String streamId) Gets the declared output fields for the specified component/stream.
Fields	TopologyContext.getThisOutputFields(String streamId) Gets the declared output fields for the specified stream id for the component this task is a part of.

Constructor parameters in org.apache.storm.task with type arguments of type Fields

Constructor and Description
GeneralTopologyContext(StormTopology topology, Map<String,Object> topoConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, String stormId)
TopologyContext(StormTopology topology, Map<String,Object> topoConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, Map<String,Long> blobToLastKnownVersionShared, String stormId, String codeDir, String pidDir, Integer taskId, Integer workerPort, List<Integer> workerTasks, Map<String,Object> defaultResources, Map<String,Object> userResources, Map<String,Object> executorData, Map<Integer,Map<Integer,Map<String,IMetric>>> registeredMetrics, AtomicBoolean openOrPrepareWasCalled, StormMetricRegistry metricRegistry)
WorkerTopologyContext(StormTopology topology, Map<String,Object> topoConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, String stormId, String codeDir, String pidDir, Integer workerPort, List<Integer> workerTasks, Map<String,Object> defaultResources, Map<String,Object> userResources)
WorkerTopologyContext(StormTopology topology, Map<String,Object> topoConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, String stormId, String codeDir, String pidDir, Integer workerPort, List<Integer> workerTasks, Map<String,Object> defaultResources, Map<String,Object> userResources, AtomicReference<Map<Integer,NodeInfo>> taskToNodePort, String assignmentId)

Uses of Fields in org.apache.storm.testing

Methods in org.apache.storm.testing that return Fields

Modifier and Type	Method and Description
Fields	TestPlannerSpout.getOutputFields()
Fields	TestPlannerBolt.getOutputFields()
Fields	TestGlobalCount.getOutputFields()
Fields	TestEventOrderCheckBolt.getOutputFields()

Constructors in org.apache.storm.testing with parameters of type Fields

Constructor and Description
FeederSpout(Fields outFields)
FixedTupleSpout(List tuples, Fields fields)
IdentityBolt(Fields fields)
PrepareBatchBolt(Fields outFields)
TestPlannerSpout(Fields outFields)
TestPlannerSpout(Fields outFields, boolean isDistributed)

Uses of Fields in org.apache.storm.topology

Methods in org.apache.storm.topology with parameters of type Fields

Modifier and Type	Method and Description
void	OutputFieldsGetter.declare(boolean direct, Fields fields)
void	OutputFieldsDeclarer.declare(boolean direct, Fields fields)
void	OutputFieldsGetter.declare(Fields fields)
void	OutputFieldsDeclarer.declare(Fields fields) Uses default stream id.
void	OutputFieldsGetter.declareStream(String streamId, boolean direct, Fields fields)
void	OutputFieldsDeclarer.declareStream(String streamId, boolean direct, Fields fields)
void	OutputFieldsGetter.declareStream(String streamId, Fields fields)
void	OutputFieldsDeclarer.declareStream(String streamId, Fields fields)
T	InputDeclarer.fieldsGrouping(String componentId, Fields fields) The stream is partitioned by the fields specified in the grouping.
BoltDeclarer	TopologyBuilder.BoltGetter.fieldsGrouping(String componentId, Fields fields)
T	InputDeclarer.fieldsGrouping(String componentId, String streamId, Fields fields) The stream is partitioned by the fields specified in the grouping.
BoltDeclarer	TopologyBuilder.BoltGetter.fieldsGrouping(String componentId, String streamId, Fields fields)
T	InputDeclarer.partialKeyGrouping(String componentId, Fields fields) Tuples are passed to two hashing functions and each target task is decided based on the comparison of the state of candidate nodes.
BoltDeclarer	TopologyBuilder.BoltGetter.partialKeyGrouping(String componentId, Fields fields)
T	InputDeclarer.partialKeyGrouping(String componentId, String streamId, Fields fields) Tuples are passed to two hashing functions and each target task is decided based on the comparison of the state of candidate nodes.
BoltDeclarer	TopologyBuilder.BoltGetter.partialKeyGrouping(String componentId, String streamId, Fields fields)

Uses of Fields in org.apache.storm.trident

Methods in org.apache.storm.trident that return Fields

Modifier and Type	Method and Description
Fields	Stream.getOutputFields()

Methods in org.apache.storm.trident with parameters of type Fields

Modifier and Type	Method and Description
Stream	Stream.aggregate(Aggregator agg, Fields functionFields)
Stream	Stream.aggregate(CombinerAggregator agg, Fields functionFields)
Stream	Stream.aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
Stream	Stream.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
Stream	Stream.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
Stream	Stream.aggregate(ReducerAggregator agg, Fields functionFields)
Stream	Stream.each(Fields inputFields, Filter filter)
Stream	Stream.each(Fields inputFields, Function function, Fields functionFields)
Stream	Stream.each(Function function, Fields functionFields)
Stream	Stream.filter(Fields inputFields, Filter filter) Returns a stream consisting of the elements of this stream that match the given filter.
Stream	Stream.flatMap(FlatMapFunction function, Fields outputFields) Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided mapping function to each value.
GroupedStream	Stream.groupBy(Fields fields) Grouping Operation.
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinOutFieldsMode mode)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type, JoinOutFieldsMode mode)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed, JoinOutFieldsMode mode)
Stream	TridentTopology.join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields)
Stream	TridentTopology.join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinOutFieldsMode mode)
Stream	TridentTopology.join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinType type)
Stream	TridentTopology.join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, JoinType type, JoinOutFieldsMode mode)
Stream	TridentTopology.join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed)
Stream	TridentTopology.join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed, JoinOutFieldsMode mode)
Stream	Stream.map(MapFunction function, Fields outputFields) Returns a stream consisting of the result of applying the given mapping function to the values of this stream.
Stream	TridentTopology.merge(Fields outputFields, List<Stream> streams)
Stream	TridentTopology.merge(Fields outputFields, Stream... streams)
Stream	TridentTopology.multiReduce(Fields inputFields1, GroupedStream s1, Fields inputFields2, GroupedStream s2, GroupedMultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(Fields inputFields1, Stream s1, Fields inputFields2, Stream s2, MultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(GroupedStream s1, GroupedStream s2, GroupedMultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<Fields> inputFields, List<GroupedStream> groupedStreams, GroupedMultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<Fields> inputFields, List<Stream> streams, MultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<GroupedStream> streams, GroupedMultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<Stream> streams, MultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(Stream s1, Stream s2, MultiReducer function, Fields outputFields)
Stream	Stream.partitionAggregate(Aggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(CombinerAggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
Stream	Stream.partitionAggregate(ReducerAggregator agg, Fields functionFields)
Stream	Stream.partitionBy(Fields fields) Repartitioning Operation.
TridentState	Stream.partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater)
TridentState	Stream.partitionPersist(StateFactory stateFactory, Fields inputFields, StateUpdater updater, Fields functionFields)
TridentState	Stream.partitionPersist(StateFactory stateFactory, StateUpdater updater, Fields functionFields)
TridentState	Stream.partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater)
TridentState	Stream.partitionPersist(StateSpec stateSpec, Fields inputFields, StateUpdater updater, Fields functionFields)
TridentState	Stream.partitionPersist(StateSpec stateSpec, StateUpdater updater, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	Stream.persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields)
Stream	Stream.project(Fields keepFields) Filters out fields from a stream, resulting in a Stream containing only the fields specified by keepFields.
Stream	Stream.slidingWindow(BaseWindowedBolt.Duration windowDuration, BaseWindowedBolt.Duration slidingInterval, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window which slides at duration of slidingInterval and completes a window at windowDuration.
Stream	Stream.slidingWindow(int windowCount, int slideCount, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a sliding window with every windowCount of tuples and slides the window after slideCount.
Stream	Stream.stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
Stream	Stream.stateQuery(TridentState state, QueryFunction function, Fields functionFields)
Stream	Stream.tumblingWindow(BaseWindowedBolt.Duration windowDuration, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a window that tumbles at duration of windowDuration.
Stream	Stream.tumblingWindow(int windowCount, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of tuples which are aggregated results of a tumbling window with every windowCount of tuples.
Stream	Stream.window(WindowConfig windowConfig, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns a stream of aggregated results based on the given window configuration which uses inmemory windowing tuple store.
Stream	Stream.window(WindowConfig windowConfig, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, Fields functionFields) Returns stream of aggregated results based on the given window configuration.

Method parameters in org.apache.storm.trident with type arguments of type Fields

Modifier and Type	Method and Description
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinOutFieldsMode mode)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type, JoinOutFieldsMode mode)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed, JoinOutFieldsMode mode)
Stream	TridentTopology.multiReduce(List<Fields> inputFields, List<GroupedStream> groupedStreams, GroupedMultiReducer function, Fields outputFields)
Stream	TridentTopology.multiReduce(List<Fields> inputFields, List<Stream> streams, MultiReducer function, Fields outputFields)

Uses of Fields in org.apache.storm.trident.fluent

Methods in org.apache.storm.trident.fluent that return Fields

Modifier and Type	Method and Description
Fields	GroupedStream.getGroupFields()
Fields	IAggregatableStream.getOutputFields()
Fields	GroupedStream.getOutputFields()

Methods in org.apache.storm.trident.fluent with parameters of type Fields

Modifier and Type	Method and Description
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Aggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(CombinerAggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(ReducerAggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(ReducerAggregator agg, Fields functionFields)
IAggregatableStream	IAggregatableStream.each(Fields inputFields, Function function, Fields functionFields)
IAggregatableStream	GroupedStream.each(Fields inputFields, Function function, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(CombinerAggregator agg, Fields functionFields)
IAggregatableStream	IAggregatableStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
IAggregatableStream	GroupedStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateFactory stateFactory, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, Fields inputFields, CombinerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, Fields inputFields, ReducerAggregator agg, Fields functionFields)
TridentState	GroupedStream.persistentAggregate(StateSpec spec, ReducerAggregator agg, Fields functionFields)
Stream	GroupedStream.stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
Stream	GroupedStream.stateQuery(TridentState state, QueryFunction function, Fields functionFields)

Constructors in org.apache.storm.trident.fluent with parameters of type Fields

Constructor and Description
GroupedStream(Stream stream, Fields groupFields)

Uses of Fields in org.apache.storm.trident.operation

Methods in org.apache.storm.trident.operation with parameters of type Fields

Modifier and Type	Method and Description
TridentTupleView.ProjectionFactory	TridentOperationContext.makeProjectionFactory(Fields fields)
TridentTupleView.ProjectionFactory	TridentMultiReducerContext.makeProjectionFactory(int streamIndex, Fields fields)

Uses of Fields in org.apache.storm.trident.operation.impl

Constructors in org.apache.storm.trident.operation.impl with parameters of type Fields

Constructor and Description
ChainedAggregatorImpl(Aggregator[] aggs, Fields[] inputFields, ComboList.Factory fact)
GroupedAggregator(Aggregator agg, Fields group, Fields input, int outSize)

Constructor parameters in org.apache.storm.trident.operation.impl with type arguments of type Fields

Constructor and Description
GroupedMultiReducerExecutor(GroupedMultiReducer reducer, List<Fields> groupFields, List<Fields> inputFields)
GroupedMultiReducerExecutor(GroupedMultiReducer reducer, List<Fields> groupFields, List<Fields> inputFields)
JoinerMultiReducer(List<JoinType> types, int numGroupFields, List<Fields> sides)
PreservingFieldsOrderJoinerMultiReducer(List<JoinType> types, int numGroupFields, List<Fields> origins, List<Fields> joins, List<Fields> sides)
PreservingFieldsOrderJoinerMultiReducer(List<JoinType> types, int numGroupFields, List<Fields> origins, List<Fields> joins, List<Fields> sides)
PreservingFieldsOrderJoinerMultiReducer(List<JoinType> types, int numGroupFields, List<Fields> origins, List<Fields> joins, List<Fields> sides)

Uses of Fields in org.apache.storm.trident.planner

Fields in org.apache.storm.trident.planner declared as Fields

Modifier and Type	Field and Description
Fields	Node.allOutputFields
Fields	ProcessorNode.selfOutFields

Constructors in org.apache.storm.trident.planner with parameters of type Fields

Constructor and Description
InitialReceiver(String stream, Fields allFields)
Node(String streamId, String name, Fields allOutputFields)
PartitionNode(String streamId, String name, Fields allOutputFields, Grouping grouping)
ProcessorNode(String streamId, String name, Fields allOutputFields, Fields selfOutFields, TridentProcessor processor)
SpoutNode(String streamId, Fields allOutputFields, String txid, Object spout, SpoutNode.SpoutType type)

Uses of Fields in org.apache.storm.trident.planner.processor

Methods in org.apache.storm.trident.planner.processor that return Fields

Modifier and Type	Method and Description
Fields	TridentContext.getSelfOutputFields()

Constructors in org.apache.storm.trident.planner.processor with parameters of type Fields

Constructor and Description
AggregateProcessor(Fields inputFields, Aggregator agg)
EachProcessor(Fields inputFields, Function function)
MapProcessor(Fields inputFields, Function function)
PartitionPersistProcessor(String stateId, Fields inputFields, StateUpdater updater)
ProjectedProcessor(Fields projectFields)
StateQueryProcessor(String stateId, Fields inputFields, QueryFunction function)
TridentContext(Fields selfFields, List<TridentTuple.Factory> parentFactories, List<String> parentStreams, List<TupleReceiver> receivers, String outStreamId, int stateIndex, BatchOutputCollector collector)

Constructor parameters in org.apache.storm.trident.planner.processor with type arguments of type Fields

Constructor and Description
MultiReducerProcessor(List<Fields> inputFields, MultiReducer reducer)

Uses of Fields in org.apache.storm.trident.spout

Methods in org.apache.storm.trident.spout that return Fields

Modifier and Type	Method and Description
Fields	IBatchSpout.getOutputFields()
Fields	PartitionedTridentSpoutExecutor.getOutputFields()
Fields	ITridentSpout.getOutputFields()
Fields	IPartitionedTridentSpout.getOutputFields()
Fields	OpaquePartitionedTridentSpoutExecutor.getOutputFields()
Fields	BatchSpoutExecutor.getOutputFields()
Fields	RichSpoutBatchExecutor.getOutputFields()
Fields	IOpaquePartitionedTridentSpout.getOutputFields()

Uses of Fields in org.apache.storm.trident.state.map

Constructors in org.apache.storm.trident.state.map with parameters of type Fields

Constructor and Description
MapCombinerAggStateUpdater(CombinerAggregator agg, Fields groupFields, Fields inputFields)
MapReducerAggStateUpdater(ReducerAggregator agg, Fields groupFields, Fields inputFields)

Uses of Fields in org.apache.storm.trident.testing

Methods in org.apache.storm.trident.testing that return Fields

Modifier and Type	Method and Description
Fields	FixedBatchSpout.getOutputFields()
Fields	FeederCommitterBatchSpout.getOutputFields()
Fields	FeederBatchSpout.getOutputFields()

Constructors in org.apache.storm.trident.testing with parameters of type Fields

Constructor and Description
FixedBatchSpout(Fields fields, int maxBatchSize, List<Object>... outputs)

Uses of Fields in org.apache.storm.trident.tuple

Methods in org.apache.storm.trident.tuple that return Fields

Modifier and Type	Method and Description
Fields	TridentTupleView.getFields()

Methods in org.apache.storm.trident.tuple with parameters of type Fields

Modifier and Type	Method and Description
static ValuePointer[]	ValuePointer.buildIndex(Fields fieldsOrder, Map<String,ValuePointer> pointers)
static TridentTuple	TridentTupleView.createFreshTuple(Fields fields, List<Object> values)
static TridentTuple	TridentTupleView.createFreshTuple(Fields fields, Object... values)
List<Object>	TridentTupleView.select(Fields selector)

Constructors in org.apache.storm.trident.tuple with parameters of type Fields

Constructor and Description
FreshOutputFactory(Fields selfFields)
OperationOutputFactory(TridentTuple.Factory parent, Fields selfFields)
ProjectionFactory(TridentTuple.Factory parent, Fields projectFields)
RootFactory(Fields inputFields)

Uses of Fields in org.apache.storm.trident.util

Methods in org.apache.storm.trident.util that return Fields

Modifier and Type	Method and Description
static Fields	TridentUtils.fieldsConcat(Fields... fields)
static Fields	TridentUtils.fieldsSubtract(Fields all, Fields minus)
static Fields	TridentUtils.fieldsUnion(Fields... fields)
static Fields	TridentUtils.getSingleOutputStreamFields(IComponent component)

Methods in org.apache.storm.trident.util with parameters of type Fields

Modifier and Type	Method and Description
static Fields	TridentUtils.fieldsConcat(Fields... fields)
static Fields	TridentUtils.fieldsSubtract(Fields all, Fields minus)
static Fields	TridentUtils.fieldsUnion(Fields... fields)

Uses of Fields in org.apache.storm.trident.windowing

Constructors in org.apache.storm.trident.windowing with parameters of type Fields

Constructor and Description
StoreBasedTridentWindowManager(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator, BatchOutputCollector delegateCollector, Long maxTuplesCacheSize, Fields inputFields)
WindowTridentProcessor(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory, Fields inputFields, Aggregator aggregator, boolean storeTuplesInStore)

Uses of Fields in org.apache.storm.tuple

Methods in org.apache.storm.tuple that return Fields

Modifier and Type	Method and Description
Fields	ITuple.getFields() Gets the names of the fields in this tuple.
Fields	TupleImpl.getFields()

Methods in org.apache.storm.tuple with parameters of type Fields

Modifier and Type	Method and Description
List<Object>	ITuple.select(Fields selector) Returns a subset of the tuple based on the fields selector.
List<Object>	TupleImpl.select(Fields selector)
List<Object>	Fields.select(Fields selector, List<Object> tuple) Select values out of tuple given a Fields selector Note that this function can throw a NullPointerException if the fields in selector are not found in the index.