| Modifier and Type | Method and Description |
|---|---|
Context |
BasicIRCStreamDataset.construct(String channel,
String sender,
String login,
String hostname,
String message) |
| Constructor and Description |
|---|
BasicIRCStreamDataset(BlockingDroppingQueue<Context> buffer,
String hostname,
String channel)
Construct with the given buffer, connecting to the given host and
channel.
|
| Constructor and Description |
|---|
ContextRoundRobinTwitterSearchAPIDataset(List<twitter4j.Query> queries,
TwitterAPIToken token,
BlockingDroppingQueue<Context> buffer) |
| Modifier and Type | Method and Description |
|---|---|
Context |
Context.clone() |
Context |
Context.combine(Context that,
String thisprefix,
String thatprefix)
|
| Modifier and Type | Method and Description |
|---|---|
Context |
Context.combine(Context that,
String thisprefix,
String thatprefix)
|
| Modifier and Type | Method and Description |
|---|---|
Context |
ContextListFunction.apply(Context in) |
Context |
ContextFunctionAdaptor.apply(Context in) |
Context |
ContextListFilter.apply(Context in) |
Context |
ContextGenerator.apply(T in) |
| Modifier and Type | Method and Description |
|---|---|
static <IN> Operation<Context> |
ContextOperationAdaptor.create(Operation<IN> operation,
String extract)
Helper to create a new
ContextOperationAdaptor. |
static <IN,OUT> Function<Context,Context> |
ContextFunctionAdaptor.create(String extract,
String insert,
Function<IN,OUT> inner)
Create a new
ContextFunctionAdaptor that reads data from a given
key, applies a function and sets the result in a different key. |
static <IN,OUT> Function<Context,Context> |
ContextFunctionAdaptor.create(String extract,
String insert,
Function<IN,OUT> inner)
Create a new
ContextFunctionAdaptor that reads data from a given
key, applies a function and sets the result in a different key. |
| Modifier and Type | Method and Description |
|---|---|
T |
ContextTransform.apply(Context in) |
Context |
ContextListFunction.apply(Context in) |
Context |
ContextFunctionAdaptor.apply(Context in) |
Context |
ContextListFilter.apply(Context in) |
T |
ContextExtractor.extract(Context c)
Extract the data from the context
|
T |
KeyContextExtractor.extract(Context c) |
void |
KeyContextInsertor.insert(T obj,
Context c) |
void |
ContextInsertor.insert(T obj,
Context c)
Insert the object into the context
|
void |
ContextOperationAdaptor.perform(Context object) |
boolean |
ContextPredicateAdaptor.test(Context in) |
| Modifier and Type | Method and Description |
|---|---|
OUT |
ContextListTransformFunction.apply(List<Context> in) |
List<T> |
ContextListTransform.apply(List<Context> in) |
| Modifier and Type | Method and Description |
|---|---|
Context |
ContextStreamCombiner.next() |
| Modifier and Type | Method and Description |
|---|---|
static Stream<Context> |
ContextStreamCombiner.combine(Stream<Context> a,
Stream<Context> b)
Utility method to combine two streams.
|
| Modifier and Type | Method and Description |
|---|---|
static Stream<Context> |
ContextStreamCombiner.combine(Stream<Context> a,
Stream<Context> b)
Utility method to combine two streams.
|
static Stream<Context> |
ContextStreamCombiner.combine(Stream<Context> a,
Stream<Context> b)
Utility method to combine two streams.
|
| Constructor and Description |
|---|
ContextStreamCombiner(Stream<Context> a,
Stream<Context> b)
Construct the combiner to consume the two given streams.
|
ContextStreamCombiner(Stream<Context> a,
Stream<Context> b)
Construct the combiner to consume the two given streams.
|
ContextStreamCombiner(Stream<Context> a,
Stream<Context> b,
String aprefix,
String bprefix)
Construct the combiner to consume the two given streams, using the given
prefixes to modify the keys from the respective streams.
|
ContextStreamCombiner(Stream<Context> a,
Stream<Context> b,
String aprefix,
String bprefix)
Construct the combiner to consume the two given streams, using the given
prefixes to modify the keys from the respective streams.
|
| Modifier and Type | Method and Description |
|---|---|
Stream<Context> |
ContextRealTimeWindowFunction.apply(Stream<IN> inner) |