Package | Description |
---|---|
org.apache.storm.trident | |
org.apache.storm.trident.operation.impl |
Modifier and Type | Method and Description |
---|---|
static JoinType |
JoinType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static JoinType[] |
JoinType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static List<JoinType> |
JoinType.mixed(JoinType... types) |
Modifier and Type | Method and Description |
---|---|
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(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) |
static List<JoinType> |
JoinType.mixed(JoinType... types) |
Modifier and Type | Method and Description |
---|---|
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,
List<JoinType> mixed) |
Stream |
TridentTopology.join(Stream s1,
Fields joinFields1,
Stream s2,
Fields joinFields2,
Fields outFields,
List<JoinType> mixed,
JoinOutFieldsMode mode) |
Constructor and Description |
---|
JoinerMultiReducer(List<JoinType> types,
int numGroupFields,
List<Fields> sides) |
PreservingFieldsOrderJoinerMultiReducer(List<JoinType> types,
int numGroupFields,
List<Fields> origins,
List<Fields> joins,
List<Fields> sides) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.