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:
  • Constructor Details

    • FieldSelector

      public FieldSelector(String fieldDescriptor)
    • FieldSelector

      public FieldSelector(String stream, String fieldDescriptor)
      Constructor.
      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 Details

    • getStreamName

      public String getStreamName()
    • getField

      public String[] getField()
    • getOutputName

      public String getOutputName()
    • toString

      public String toString()
      Overrides:
      toString in class Object