Package | Description |
---|---|
org.apache.storm.bolt |
Modifier and Type | Field and Description |
---|---|
protected JoinBolt.FieldSelector[] |
JoinBolt.outputFields |
Modifier and Type | Method and Description |
---|---|
JoinBolt.FieldSelector |
JoinBolt.JoinInfo.getJoinField() |
Modifier and Type | Method and Description |
---|---|
protected ArrayList<Object> |
JoinBolt.doProjection(ArrayList<Tuple> tuples,
JoinBolt.FieldSelector[] projectionFields) |
Object |
JoinBolt.ResultRecord.getField(JoinBolt.FieldSelector fieldSelector) |
protected Object |
JoinBolt.lookupField(JoinBolt.FieldSelector fieldSelector,
Tuple tuple) |
Constructor and Description |
---|
JoinInfo(JoinBolt.FieldSelector field) |
JoinInfo(JoinBolt.FieldSelector field,
String otherStream,
JoinBolt.JoinInfo otherStreamJoinInfo,
JoinBolt.JoinType joinType) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.