org.apache.storm.bolt

Class JoinBolt.FieldSelector

java.lang.Object

org.apache.storm.bolt.JoinBolt.FieldSelector

All Implemented Interfaces:

Serializable

Enclosing class:

JoinBolt

protected static class JoinBolt.FieldSelector
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FieldSelector(String fieldDescriptor)
FieldSelector(String stream, String fieldDescriptor)
FieldSelector(String stream, String[] field)

Method Summary

Modifier and Type	Method and Description
String[]	getField()
String	getOutputName()
String	getStreamName()
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

FieldSelector

public FieldSelector(String fieldDescriptor)

FieldSelector

public FieldSelector(String stream,
                     String fieldDescriptor)

Parameters:

stream - name of stream

fieldDescriptor - Simple fieldDescriptor like “x.y.z” and w/o a ‘stream1:’ stream qualifier.

FieldSelector

public FieldSelector(String stream,
                     String[] field)

Method Detail

getStreamName

public String getStreamName()

getField

public String[] getField()

getOutputName

public String getOutputName()

toString

public String toString()

Overrides:

toString in class Object