Uses of Class
backtype.storm.tuple.Fields

Packages that use Fields

Package	Description
backtype.storm.drpc
backtype.storm.grouping
backtype.storm.spout
backtype.storm.task
backtype.storm.testing
backtype.storm.topology
backtype.storm.tuple
storm.trident
storm.trident.fluent
storm.trident.operation
storm.trident.operation.impl
storm.trident.planner
storm.trident.planner.processor
storm.trident.spout
storm.trident.state.map
storm.trident.testing
storm.trident.tuple
storm.trident.util

Uses of Fields in backtype.storm.drpc

Methods in backtype.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 backtype.storm.grouping

Constructors in backtype.storm.grouping with parameters of type Fields

Constructor and Description
PartialKeyGrouping(Fields fields)

Uses of Fields in backtype.storm.spout

Methods in backtype.storm.spout that return Fields

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

Uses of Fields in backtype.storm.task

Methods in backtype.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 backtype.storm.task with type arguments of type Fields

Constructor and Description
GeneralTopologyContext(StormTopology topology, Map stormConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, String stormId)
TopologyContext(StormTopology topology, Map stormConf, Map<Integer,String> taskToComponent, Map<String,List<Integer>> componentToSortedTasks, Map<String,Map<String,Fields>> componentToStreamToFields, 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 registeredMetrics, clojure.lang.Atom openOrPrepareWasCalled)
WorkerTopologyContext(StormTopology topology, Map stormConf, 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)

Uses of Fields in backtype.storm.testing

Methods in backtype.storm.testing that return Fields

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

Constructors in backtype.storm.testing with parameters of type Fields

Constructor and Description
FeederSpout(Fields outFields)
IdentityBolt(Fields fields)
MemoryTransactionalSpout(Map<Integer,List<List<Object>>> partitions, Fields outFields, int takeAmt)
OpaqueMemoryTransactionalSpout(Map<Integer,List<List<Object>>> partitions, Fields outFields, int takeAmt)
PrepareBatchBolt(Fields outFields)
TestPlannerSpout(Fields outFields)
TestPlannerSpout(Fields outFields, boolean isDistributed)

Uses of Fields in backtype.storm.topology

Methods in backtype.storm.topology with parameters of type Fields

Modifier and Type	Method and Description
void	OutputFieldsDeclarer.declare(boolean direct, Fields fields)
void	OutputFieldsGetter.declare(boolean direct, Fields fields)
void	OutputFieldsDeclarer.declare(Fields fields) Uses default stream id.
void	OutputFieldsGetter.declare(Fields fields)
void	OutputFieldsDeclarer.declareStream(String streamId, boolean direct, Fields fields)
void	OutputFieldsGetter.declareStream(String streamId, boolean direct, Fields fields)
void	OutputFieldsDeclarer.declareStream(String streamId, Fields fields)
void	OutputFieldsGetter.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 backtype.storm.tuple

Methods in backtype.storm.tuple that return Fields

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

Methods in backtype.storm.tuple with parameters of type Fields

Modifier and Type	Method and Description
List<Object>	TupleImpl.select(Fields selector)
List<Object>	ITuple.select(Fields selector) Returns a subset of the tuple based on the fields selector.
List<Object>	Fields.select(Fields selector, List<Object> tuple)

Uses of Fields in storm.trident

Methods in storm.trident that return Fields

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

Methods in 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)
GroupedStream	Stream.groupBy(Fields fields)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, JoinType type)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed)
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, JoinType type)
Stream	TridentTopology.join(Stream s1, Fields joinFields1, Stream s2, Fields joinFields2, Fields outFields, List<JoinType> mixed)
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)
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)
Stream	Stream.stateQuery(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
Stream	Stream.stateQuery(TridentState state, QueryFunction function, Fields functionFields)

Method parameters in 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, JoinType type)
Stream	TridentTopology.join(List<Stream> streams, List<Fields> joinFields, Fields outFields, List<JoinType> mixed)
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 storm.trident.fluent

Methods in storm.trident.fluent that return Fields

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

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

Modifier and Type	Method and Description
Stream	GroupedStream.aggregate(Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Aggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Aggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(CombinerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(CombinerAggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(Fields inputFields, Aggregator 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, CombinerAggregator 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, ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
Stream	GroupedStream.aggregate(ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedAggregatorDeclarer.aggregate(ReducerAggregator agg, Fields functionFields)
ChainedFullAggregatorDeclarer	ChainedFullAggregatorDeclarer.aggregate(ReducerAggregator agg, Fields functionFields)
IAggregatableStream	IAggregatableStream.each(Fields inputFields, Function function, Fields functionFields)
IAggregatableStream	GroupedStream.each(Fields inputFields, Function function, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(CombinerAggregator agg, Fields functionFields)
IAggregatableStream	IAggregatableStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
IAggregatableStream	GroupedStream.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, Aggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, CombinerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.partitionAggregate(Fields inputFields, ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedPartitionAggregatorDeclarer.partitionAggregate(ReducerAggregator agg, Fields functionFields)
ChainedPartitionAggregatorDeclarer	ChainedAggregatorDeclarer.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 storm.trident.fluent with parameters of type Fields

Constructor and Description
GroupedStream(Stream stream, Fields groupFields)

Uses of Fields in storm.trident.operation

Methods in 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 storm.trident.operation.impl

Constructors in 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 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)

Uses of Fields in storm.trident.planner

Fields in storm.trident.planner declared as Fields

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

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

Constructor and Description
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)
SubtopologyBolt.InitialReceiver(String stream, Fields allFields)

Uses of Fields in storm.trident.planner.processor

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

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

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

Constructor and Description
AggregateProcessor(Fields inputFields, Aggregator agg)
EachProcessor(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 storm.trident.planner.processor with type arguments of type Fields

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

Uses of Fields in storm.trident.spout

Methods in storm.trident.spout that return Fields

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

Uses of Fields in storm.trident.state.map

Constructors in 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 storm.trident.testing

Methods in storm.trident.testing that return Fields

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

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

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

Uses of Fields in storm.trident.tuple

Methods in storm.trident.tuple that return Fields

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

Methods in 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 storm.trident.tuple with parameters of type Fields

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

Uses of Fields in storm.trident.util

Methods in 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 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)